src/main/java/org/apache/flink/benchmark/TwoInputBenchmark.java [71:78]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        source1.connect(source2)
                .transform(
                        "custom operator",
                        TypeInformation.of(Long.class),
                        new MultiplyByTwoCoStreamMap())
                .addSink(new DiscardingSink<>());

        env.execute();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/benchmark/TwoInputBenchmark.java [94:101]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        source1.connect(source2)
                .transform(
                        "custom operator",
                        TypeInformation.of(Long.class),
                        new MultiplyByTwoCoStreamMap())
                .addSink(new DiscardingSink<>());

        env.execute();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -