@SuppressWarnings("unchecked") @Test public void testBuild_NegatedPredicate() { Flow flow = Flow.create("split-test"); Dataset<Integer> dataset = Util.createMockDataset(flow, 1); Split.of(dataset) .using((UnaryPredicate<Integer>) what -> what % 2 == 0) .output(); Filter<Integer> oddNumbers = (Filter<Integer>) getOperator( flow, Split.DEFAULT_NAME + Split.NEGATIVE_FILTER_SUFFIX); assertFalse(oddNumbers.getPredicate().apply(0)); assertFalse(oddNumbers.getPredicate().apply(2)); assertFalse(oddNumbers.getPredicate().apply(4)); assertTrue(oddNumbers.getPredicate().apply(1)); assertTrue(oddNumbers.getPredicate().apply(3)); assertTrue(oddNumbers.getPredicate().apply(5)); }
public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<IN>(DEFAULT_NAME, input); }
Split { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<IN>(DEFAULT_NAME, input); } }
Split { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<IN>(DEFAULT_NAME, input); }  }
Split { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<IN>(DEFAULT_NAME, input); }  static OfBuilder named(String name); static UsingBuilder<IN> of(Dataset<IN> input); }
Split { public static <IN> UsingBuilder<IN> of(Dataset<IN> input) { return new UsingBuilder<IN>(DEFAULT_NAME, input); }  static OfBuilder named(String name); static UsingBuilder<IN> of(Dataset<IN> input);  }