@Test public void testBuild_Windowing() { Flow flow = Flow.create("TEST"); Dataset<String> dataset = Util.createMockDataset(flow, 3); Dataset<String> uniq = Distinct.of(dataset) .windowBy(Time.of(Duration.ofHours(1))) .output(); Distinct distinct = (Distinct) flow.operators().iterator().next(); assertTrue(distinct.getWindowing() instanceof Time); }
public static <IN> MappedBuilder<IN, IN> of(Dataset<IN> input) { return new MappedBuilder<>("Distinct", input); }
Distinct extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, ELEM, ELEM, W, Distinct<IN, ELEM, W>> { public static <IN> MappedBuilder<IN, IN> of(Dataset<IN> input) { return new MappedBuilder<>("Distinct", input); } }
Distinct extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, ELEM, ELEM, W, Distinct<IN, ELEM, W>> { public static <IN> MappedBuilder<IN, IN> of(Dataset<IN> input) { return new MappedBuilder<>("Distinct", input); } Distinct(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, ELEM> mapper,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); }
Distinct extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, ELEM, ELEM, W, Distinct<IN, ELEM, W>> { public static <IN> MappedBuilder<IN, IN> of(Dataset<IN> input) { return new MappedBuilder<>("Distinct", input); } Distinct(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, ELEM> mapper,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); static MappedBuilder<IN, IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps(); }
Distinct extends StateAwareWindowWiseSingleInputOperator<
        IN, IN, IN, ELEM, ELEM, W, Distinct<IN, ELEM, W>> { public static <IN> MappedBuilder<IN, IN> of(Dataset<IN> input) { return new MappedBuilder<>("Distinct", input); } Distinct(String name,
           Flow flow,
           Dataset<IN> input,
           UnaryFunction<IN, ELEM> mapper,
           @Nullable Windowing<IN, W> windowing,
           Set<OutputHint> outputHints); static MappedBuilder<IN, IN> of(Dataset<IN> input); static OfBuilder named(String name); @Override DAG<Operator<?, ?>> getBasicOps();  }