@Nonnull
    public static <K, V> Sink<ChangeRecord> map(
            @Nonnull String mapName,
            @Nonnull FunctionEx<? super ChangeRecord, ? extends K> keyFn,
            @Nonnull FunctionEx<? super ChangeRecord, ? extends V> valueFn
    ) {
        String name = "mapCdcSink(" + mapName + ')';
        return sink(name, mapName, null, keyFn, valueFn);
    }
@Test
    public void deleteFromLocalMap_ViaValueProjection() {
        p.readFrom(items(SYNC1, INSERT2))
                .writeTo(localSync());
        execute().join();

        p = Pipeline.create();
        p.readFrom(items(UPDATE1))
                .writeTo(CdcSinks.map(MAP,
                        r -> (Integer) r.key().toMap().get(ID),
                        r -> null
                ));
        execute().join();

        assertMap(hz(), null, "gbailey@foobar.com");

        hz().getMap(MAP).destroy();
    }