@Test public void testBuild_Hints() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 1); Dataset<String> dataSetWithHint = MapElements.of(dataset).using(i -> i).output(SizeHint.FITS_IN_MEMORY); assertTrue(dataSetWithHint.getProducer().getHints().contains(SizeHint.FITS_IN_MEMORY)); assertEquals(1, dataSetWithHint.getProducer().getHints().size()); Dataset<String> dataSetWithoutHint = MapElements.of(dataset).using(i -> i).output(); assertEquals(0, dataSetWithoutHint.getProducer().getHints().size()); }
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();  }