@Test public void testBuild_ImplicitName() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 3); SumByKey.of(dataset) .keyBy(s -> s) .output(); SumByKey sum = (SumByKey) flow.operators().iterator().next(); assertEquals("SumByKey", sum.getName()); }
public static <IN> KeyByBuilder<IN> of(Dataset<IN> input) { return new KeyByBuilder<>("SumByKey", input); }
SumByKey extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, KEY, Pair<KEY, Long>, W, SumByKey<IN, KEY, W>> { public static <IN> KeyByBuilder<IN> of(Dataset<IN> input) { return new KeyByBuilder<>("SumByKey", input); } }
SumByKey extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, KEY, Pair<KEY, Long>, W, SumByKey<IN, KEY, W>> { public static <IN> KeyByBuilder<IN> of(Dataset<IN> input) { return new KeyByBuilder<>("SumByKey", input); } SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing);   SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); }
SumByKey extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, KEY, Pair<KEY, Long>, W, SumByKey<IN, KEY, W>> { public static <IN> KeyByBuilder<IN> of(Dataset<IN> input) { return new KeyByBuilder<>("SumByKey", input); } SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing);   SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); static KeyByBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps(); }
SumByKey extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, KEY, Pair<KEY, Long>, W, SumByKey<IN, KEY, W>> { public static <IN> KeyByBuilder<IN> of(Dataset<IN> input) { return new KeyByBuilder<>("SumByKey", input); } SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing);   SumByKey(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, KEY> keyExtractor,
           UnaryFunction<IN, Long> valueExtractor,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); static KeyByBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps();  }