@Internal
    public Transformation<T> getTransformation() {
        return transformation;
    }
@Test
    void testGettingTransformationWithNewSinkAPI() {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        final Transformation<?> transformation =
                env.fromData(1, 2)
                        .sinkTo(TestSinkV2.<Integer>newBuilder().build())
                        .getTransformation();
        assertThat(transformation).isInstanceOf(SinkTransformation.class);
    }