@Nonnull
    public static <K, V> Sink<Entry<K, V>> map(@Nonnull String mapName) {
        return map(mapName, Entry::getKey, Entry::getValue);
    }
@Test
    public void map_withToKeyValueFunctions() {
        // Given
        BatchStage<Integer> sourceStage = p.readFrom(TestSources.items(0, 1, 2, 3, 4));

        // When
        sourceStage.writeTo(Sinks.map(sinkName, t -> t, Object::toString));

        // Then
        execute();
        IMap<Integer, String> sinkMap = hz().getMap(sinkName);
        assertEquals(5, sinkMap.size());
        IntStream.range(0, 5).forEach(i -> assertEquals(String.valueOf(i), sinkMap.get(i)));
    }