private DataStream createAsyncOperator()

in src/main/java/org/apache/flink/benchmark/AsyncWaitOperatorBenchmark.java [89:100]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    private DataStream<Long> createAsyncOperator(DataStreamSource<Long> source) {
        switch (outputMode) {
            case ORDERED:
                return AsyncDataStream.orderedWait(
                        source, new BenchmarkAsyncFunctionExecutor(), 0, TimeUnit.MILLISECONDS);
            case UNORDERED:
                return AsyncDataStream.unorderedWait(
                        source, new BenchmarkAsyncFunctionExecutor(), 0, TimeUnit.MILLISECONDS);
            default:
                throw new UnsupportedOperationException("Unknown mode");
        }
    }