@Test public void testBuild_ImplicitName() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 1); Dataset<String> filtered = Filter.of(dataset) .by(s -> !s.equals("")) .output(); Filter filter = (Filter) flow.operators().iterator().next(); assertEquals("Filter", filter.getName()); }
public static <IN> ByBuilder<IN> of(Dataset<IN> input) { return new ByBuilder<>("Filter", input); }
Filter extends ElementWiseOperator<IN, IN> { public static <IN> ByBuilder<IN> of(Dataset<IN> input) { return new ByBuilder<>("Filter", input); } }
Filter extends ElementWiseOperator<IN, IN> { public static <IN> ByBuilder<IN> of(Dataset<IN> input) { return new ByBuilder<>("Filter", input); } Filter(String name,
         Flow flow, Dataset<IN> input,
         UnaryPredicate<IN> predicate,
         Set<OutputHint> outputHints); }
Filter extends ElementWiseOperator<IN, IN> { public static <IN> ByBuilder<IN> of(Dataset<IN> input) { return new ByBuilder<>("Filter", input); } Filter(String name,
         Flow flow, Dataset<IN> input,
         UnaryPredicate<IN> predicate,
         Set<OutputHint> outputHints); static ByBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); UnaryPredicate<IN> getPredicate(); @Override DAG<Operator<?, ?>> getBasicOps(); }
Filter extends ElementWiseOperator<IN, IN> { public static <IN> ByBuilder<IN> of(Dataset<IN> input) { return new ByBuilder<>("Filter", input); } Filter(String name,
         Flow flow, Dataset<IN> input,
         UnaryPredicate<IN> predicate,
         Set<OutputHint> outputHints); static ByBuilder<IN> of(Dataset<IN> input); static OfBuilder named(String name); UnaryPredicate<IN> getPredicate(); @Override DAG<Operator<?, ?>> getBasicOps();  }