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