@Nonnull
    public static <T> Sink<T> list(@Nonnull String listName) {
        return fromProcessor("listSink(" + listName + ')', writeListP(listName));
    }
@Test
    public void when_setLocalParallelism_then_sinkHasIt() {
        //Given
        String sinkName = randomName();
        int localParallelism = 5;
        SinkStage stage = p
                .readFrom(Sources.list(sinkName))
                .writeTo(Sinks.list(sinkName));

        //When
        stage.setLocalParallelism(localParallelism);

        //Then
        assertEquals(localParallelism, transformOf(stage).localParallelism());
    }