@Test public void testBuild_ImplicitName() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 1); Dataset<String> mapped = MapElements.of(dataset) .using(s -> s) .output(); MapElements map = (MapElements) flow.operators().iterator().next(); assertEquals("MapElements", map.getName()); }
public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("MapElements", input); }
MapElements extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("MapElements", input); } }
MapElements extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("MapElements", input); } MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper,
              Set<OutputHint> outputHints);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunctionEnv<IN, OUT> mapper, Set<OutputHint> outputHints); }
MapElements extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("MapElements", input); } MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper,
              Set<OutputHint> outputHints);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunctionEnv<IN, OUT> mapper, Set<OutputHint> outputHints); static UsingBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps(); UnaryFunctionEnv<IN, OUT> getMapper(); }
MapElements extends ElementWiseOperator<IN, OUT> { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<>("MapElements", input); } MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunction<IN, OUT> mapper,
              Set<OutputHint> outputHints);   MapElements(String name,
              Flow flow,
              Dataset<IN> input,
              UnaryFunctionEnv<IN, OUT> mapper, Set<OutputHint> outputHints); static UsingBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps(); UnaryFunctionEnv<IN, OUT> getMapper();  }