@Test public void testBuild_ImplicitName() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 1); Dataset<String> mapped = FlatMap.of(dataset) .using((String s, Collector<String> c) -> c.collect(s)) .output(); FlatMap map = (FlatMap) flow.operators().iterator().next(); assertEquals("FlatMap", map.getName()); }
public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("FlatMap", input); }
FlatMap extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("FlatMap", input); } }
FlatMap extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("FlatMap", input); } FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn,
          Set<OutputHint> outputHints);   FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn); }
FlatMap extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("FlatMap", input); } FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn,
          Set<OutputHint> outputHints);   FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn); static UsingBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); UnaryFunctor<IN, OUT> getFunctor(); @Nullable ExtractEventTime<IN> getEventTimeExtractor(); }
FlatMap extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("FlatMap", input); } FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn,
          Set<OutputHint> outputHints);   FlatMap(String name, Flow flow, Dataset<IN> input,
          UnaryFunctor<IN, OUT> functor,
          @Nullable ExtractEventTime<IN> evtTimeFn); static UsingBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); UnaryFunctor<IN, OUT> getFunctor(); @Nullable ExtractEventTime<IN> getEventTimeExtractor();  }