Package org.apache.flink.api.java.operators

Class SortedGrouping<T>

    • Constructor Detail

      • SortedGrouping

        public SortedGrouping​(DataSet<T> set,
                      org.apache.flink.api.common.operators.Keys<T> keys,
                      int field,
                      org.apache.flink.api.common.operators.Order order)
        Deprecated.

      • SortedGrouping

        public SortedGrouping​(DataSet<T> set,
                      org.apache.flink.api.common.operators.Keys<T> keys,
                      String field,
                      org.apache.flink.api.common.operators.Order order)
        Deprecated.

      • SortedGrouping

        public SortedGrouping​(DataSet<T> set,
                      org.apache.flink.api.common.operators.Keys<T> keys,
                      org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,​K> keySelector,
                      org.apache.flink.api.common.operators.Order order)
        Deprecated.

    • Method Detail

      • getGroupSortKeyPositions

        protected int[] getGroupSortKeyPositions()
        Deprecated.

      • getGroupSortOrders

        protected org.apache.flink.api.common.operators.Order[] getGroupSortOrders()
        Deprecated.

      • getGroupOrdering

        protected org.apache.flink.api.common.operators.Ordering getGroupOrdering()
        Deprecated.

      • withPartitioner

        public SortedGrouping<T> withPartitioner​(org.apache.flink.api.common.functions.Partitioner<?> partitioner)
        Deprecated.
        Uses a custom partitioner for the grouping.
        Parameters:
        partitioner - The custom partitioner.
        Returns:
        The grouping object itself, to allow for method chaining.

      • getSortSelectionFunctionKey

        protected org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,​?> getSortSelectionFunctionKey()
        Deprecated.

      • reduceGroup

        public <R> GroupReduceOperator<T,​R> reduceGroup​(org.apache.flink.api.common.functions.GroupReduceFunction<T,​R> reducer)
        Deprecated.
        Applies a GroupReduce transformation on a grouped and sorted DataSet.

        The transformation calls a RichGroupReduceFunction for each group of the DataSet. A GroupReduceFunction can iterate over all elements of a group and emit any number of output elements including none.

        Parameters:
        reducer - The GroupReduceFunction that is applied on each group of the DataSet.
        Returns:
        A GroupReduceOperator that represents the reduced DataSet.
        See Also:
        RichGroupReduceFunction, GroupReduceOperator, DataSet

      • combineGroup

        public <R> GroupCombineOperator<T,​R> combineGroup​(org.apache.flink.api.common.functions.GroupCombineFunction<T,​R> combiner)
        Deprecated.
        Applies a GroupCombineFunction on a grouped DataSet. A CombineFunction is similar to a GroupReduceFunction but does not perform a full data exchange. Instead, the CombineFunction calls the combine method once per partition for combining a group of results. This operator is suitable for combining values into an intermediate format before doing a proper groupReduce where the data is shuffled across the node for further reduction. The GroupReduce operator can also be supplied with a combiner by implementing the RichGroupReduce function. The combine method of the RichGroupReduce function demands input and output type to be the same. The CombineFunction, on the other side, can have an arbitrary output type.
        Parameters:
        combiner - The GroupCombineFunction that is applied on the DataSet.
        Returns:
        A GroupCombineOperator which represents the combined DataSet.

      • first

        public GroupReduceOperator<T,​T> first​(int n)
        Deprecated.
        Returns a new set containing the first n elements in this grouped and sorted DataSet.
        Parameters:
        n - The desired number of elements for each group.
        Returns:
        A GroupReduceOperator that represents the DataSet containing the elements.

      • sortGroup

        public SortedGrouping<T> sortGroup​(int field,
                                   org.apache.flink.api.common.operators.Order order)
        Deprecated.
        Sorts Tuple elements within a group on the specified field in the specified Order.

        Note: Only groups of Tuple or Pojo elements can be sorted.

        Groups can be sorted by multiple fields by chaining sortGroup(int, Order) calls.

        Parameters:
        field - The Tuple field on which the group is sorted.
        order - The Order in which the specified Tuple field is sorted.
        Returns:
        A SortedGrouping with specified order of group element.
        See Also:
        Tuple, Order

      • sortGroup

        public SortedGrouping<T> sortGroup​(String field,
                                   org.apache.flink.api.common.operators.Order order)
        Deprecated.
        Sorts Tuple or POJO elements within a group on the specified field in the specified Order.

        Note: Only groups of Tuple or Pojo elements can be sorted.

        Groups can be sorted by multiple fields by chaining sortGroup(String, Order) calls.

        Parameters:
        field - The Tuple or Pojo field on which the group is sorted.
        order - The Order in which the specified field is sorted.
        Returns:
        A SortedGrouping with specified order of group element.
        See Also:
        Tuple, Order