类 SDFrameImpl<T>

    • 字段详细资料

      • data

        protected java.util.stream.Stream<T> data
    • 构造器详细资料

      • SDFrameImpl

        public SDFrameImpl​(java.util.stream.Stream<T> data)
      • SDFrameImpl

        public SDFrameImpl​(List<T> list)
    • 方法详细资料

      • from

        public <R> SDFrame<R> from​(java.util.stream.Stream<R> data)
        从接口复制的说明: SDFrame
        Convert to other SDFrame
        指定者:
        from 在接口中 IFrame<T>
        指定者:
        from 在接口中 SDFrame<T>
      • forEachDo

        public SDFrameImpl<T> forEachDo​(java.util.function.Consumer<? super T> action)
        从接口复制的说明: SDFrame
        Performs the given action for each element of the Iterable until all elements have been processed or the action throws an exception.
        指定者:
        forEachDo 在接口中 IFrame<T>
        指定者:
        forEachDo 在接口中 SDFrame<T>
      • map

        public <R> SDFrameImpl<R> map​(java.util.function.Function<T,​R> map)
        从接口复制的说明: SDFrame
        convert to the new Frame
        指定者:
        map 在接口中 IFrame<T>
        指定者:
        map 在接口中 SDFrame<T>
        类型参数:
        R - the new Frame type
        参数:
        map - convert operation
        返回:
        the new Frame
      • mapPercent

        public <R extends NumberSDFrame<T> mapPercent​(java.util.function.Function<T,​R> get,
                                                        SetFunction<T,​BigDecimal> set,
                                                        int scale)
        从接口复制的说明: SDFrame
        Percentage convert you can convert the value of a certain field to a percentage, Then assign a value to a certain column through SetFunction
        指定者:
        mapPercent 在接口中 IFrame<T>
        指定者:
        mapPercent 在接口中 SDFrame<T>
        类型参数:
        R - the percentage field type
        参数:
        get - need percentage convert field
        set - field for storing percentage values
        scale - percentage retain decimal places
      • partition

        public SDFrameImpl<List<T>> partition​(int n)
        从接口复制的说明: SDFrame
        partition cut the matrix into multiple small matrices, with each matrix size n
        指定者:
        partition 在接口中 IFrame<T>
        指定者:
        partition 在接口中 SDFrame<T>
        参数:
        n - size of each zone
      • join

        public <R,​K> SDFrameImpl<R> join​(IFrame<K> other,
                                               JoinOn<T,​K> on,
                                               Join<T,​K,​R> join)
        从接口复制的说明: SDFrame
        inner join Frame
        指定者:
        join 在接口中 IFrame<T>
        指定者:
        join 在接口中 SDFrame<T>
        类型参数:
        R - new Frame type
        K - other Frame type
        参数:
        other - other frame
        on - connection conditions
        join - Connection logic
      • leftJoin

        public <R,​K> SDFrameImpl<R> leftJoin​(IFrame<K> other,
                                                   JoinOn<T,​K> on,
                                                   Join<T,​K,​R> join)
        从接口复制的说明: SDFrame
        left join Frame if connection conditions false, The callback value K for Join will be null, always keep T
        指定者:
        leftJoin 在接口中 IFrame<T>
        指定者:
        leftJoin 在接口中 SDFrame<T>
        类型参数:
        R - new Frame type
        K - other Frame type
        参数:
        other - other frame
        on - connection conditions
        join - Connection logic
      • rightJoin

        public <R,​K> SDFrameImpl<R> rightJoin​(IFrame<K> other,
                                                    JoinOn<T,​K> on,
                                                    Join<T,​K,​R> join)
        从接口复制的说明: SDFrame
        right join Frame if connection conditions false, The callback value T for Join will be null, always keep K
        指定者:
        rightJoin 在接口中 IFrame<T>
        指定者:
        rightJoin 在接口中 SDFrame<T>
        类型参数:
        R - new Frame type
        K - other Frame type
        参数:
        other - other frame
        on - connection conditions
        join - Connection logic
      • toLists

        public List<T> toLists()
        从接口复制的说明: IFrame
        Convert to list
        指定者:
        toLists 在接口中 IFrame<T>
        返回:
        the list
      • stream

        public java.util.stream.Stream<T> stream()
        从接口复制的说明: IFrame
        get stream
        指定者:
        stream 在接口中 IFrame<T>
        返回:
        the stream
      • group

        public <K> SDFrame<FI2<K,​List<T>>> group​(java.util.function.Function<T,​K> key)
        从接口复制的说明: SDFrame
        Group list
        指定者:
        group 在接口中 IFrame<T>
        指定者:
        group 在接口中 SDFrame<T>
        参数:
        key - group field
      • sortDesc

        public SDFrameImpl<T> sortDesc​(Comparator<T> comparator)
        =========================== 排序相关 =====================================
        指定者:
        sortDesc 在接口中 IFrame<T>
        指定者:
        sortDesc 在接口中 SDFrame<T>
        参数:
        comparator - comparator
      • sortDesc

        public <R extends Comparable<? super R>> SDFrameImpl<T> sortDesc​(java.util.function.Function<T,​R> function)
        从接口复制的说明: SDFrame
        Descending order by field
        指定者:
        sortDesc 在接口中 IFrame<T>
        指定者:
        sortDesc 在接口中 SDFrame<T>
        类型参数:
        R - the sort field type
        参数:
        function - sort field
      • cutFirstRank

        public SDFrame<T> cutFirstRank​(Sorter<T> sorter,
                                       int n)
        从接口复制的说明: SDFrame
        Cut the top N rankings data The same value is considered to have the same ranking
        指定者:
        cutFirstRank 在接口中 IFrame<T>
        指定者:
        cutFirstRank 在接口中 SDFrame<T>
        参数:
        sorter - the ranking sorter
        n - the top n
      • cutFirst

        public SDFrame<T> cutFirst​(int n)
        =========================== 截取相关 =====================================
        指定者:
        cutFirst 在接口中 IFrame<T>
        指定者:
        cutFirst 在接口中 SDFrame<T>
        参数:
        n - the top n
      • cutPage

        public SDFrame<T> cutPage​(int page,
                                  int pageSize)
        从接口复制的说明: SDFrame
        cut paginated data
        指定者:
        cutPage 在接口中 IFrame<T>
        指定者:
        cutPage 在接口中 SDFrame<T>
        参数:
        page - The current page number is considered as the first page, regardless of whether it is passed as 0 or 1
        pageSize - page size
      • distinct

        public <R extends Comparable<R>> SDFrame<T> distinct​(java.util.function.Function<T,​R> function)
        从接口复制的说明: SDFrame
        distinct by field value
        指定者:
        distinct 在接口中 IFrame<T>
        指定者:
        distinct 在接口中 SDFrame<T>
        类型参数:
        R - field value type
        参数:
        function - the field
      • countDistinct

        public <R extends Comparable<R>> long countDistinct​(java.util.function.Function<T,​R> function)
        从接口复制的说明: SDFrame
        Calculate the quantity after deduplication
        指定者:
        countDistinct 在接口中 IFrame<T>
        指定者:
        countDistinct 在接口中 SDFrame<T>
      • where

        public SDFrame<T> where​(java.util.function.Predicate<? super T> predicate)
        =========================== 筛选相关 =====================================
        指定者:
        where 在接口中 IFrame<T>
        指定者:
        where 在接口中 SDFrame<T>
        参数:
        predicate - the predicate
      • whereNull

        public <R> SDFrame<T> whereNull​(java.util.function.Function<T,​R> function)
        从接口复制的说明: SDFrame
        Filter field values that are null, If it is string compatible, null and '' situations
        指定者:
        whereNull 在接口中 IFrame<T>
        指定者:
        whereNull 在接口中 SDFrame<T>
        类型参数:
        R - the filter field type
        参数:
        function - the filter field
      • whereNotNull

        public <R> SDFrame<T> whereNotNull​(java.util.function.Function<T,​R> function)
        从接口复制的说明: SDFrame
        Filter field values that are not null,If it is string compatible, null and '' situations
        指定者:
        whereNotNull 在接口中 IFrame<T>
        指定者:
        whereNotNull 在接口中 SDFrame<T>
        类型参数:
        R - the filter field type
        参数:
        function - the filter field
      • whereBetween

        public <R extends Comparable<R>> SDFrame<T> whereBetween​(java.util.function.Function<T,​R> function,
                                                                 R start,
                                                                 R end)
        从接口复制的说明: SDFrame
        Screening within the interval,front closed and back closed. [start,end] [start,end]
        指定者:
        whereBetween 在接口中 IFrame<T>
        指定者:
        whereBetween 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereBetweenN

        public <R extends Comparable<R>> SDFrame<T> whereBetweenN​(java.util.function.Function<T,​R> function,
                                                                  R start,
                                                                  R end)
        从接口复制的说明: SDFrame
        Screening within the interval , front open and back open (start,end)
        指定者:
        whereBetweenN 在接口中 IFrame<T>
        指定者:
        whereBetweenN 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereBetweenR

        public <R extends Comparable<R>> SDFrame<T> whereBetweenR​(java.util.function.Function<T,​R> function,
                                                                  R start,
                                                                  R end)
        从接口复制的说明: SDFrame
        Screening within the interval , front open and back close (start,end]
        指定者:
        whereBetweenR 在接口中 IFrame<T>
        指定者:
        whereBetweenR 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereBetweenL

        public <R extends Comparable<R>> SDFrame<T> whereBetweenL​(java.util.function.Function<T,​R> function,
                                                                  R start,
                                                                  R end)
        从接口复制的说明: SDFrame
        Screening within the interval , front close and back open [start,end)
        指定者:
        whereBetweenL 在接口中 IFrame<T>
        指定者:
        whereBetweenL 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereNotBetween

        public <R extends Comparable<R>> SDFrame<T> whereNotBetween​(java.util.function.Function<T,​R> function,
                                                                    R start,
                                                                    R end)
        从接口复制的说明: SDFrame
        Out of range screening, (front closed and back closed) [start,end]
        指定者:
        whereNotBetween 在接口中 IFrame<T>
        指定者:
        whereNotBetween 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereNotBetweenN

        public <R extends Comparable<R>> SDFrame<T> whereNotBetweenN​(java.util.function.Function<T,​R> function,
                                                                     R start,
                                                                     R end)
        从接口复制的说明: SDFrame
        Out of range screening, (front open and back open) (start,end)
        指定者:
        whereNotBetweenN 在接口中 IFrame<T>
        指定者:
        whereNotBetweenN 在接口中 SDFrame<T>
        参数:
        function - the filter field
        start - start value
        end - end value
      • whereIn

        public <R> SDFrame<T> whereIn​(java.util.function.Function<T,​R> function,
                                      List<R> list)
        从接口复制的说明: SDFrame
        The query value is within the specified range
        指定者:
        whereIn 在接口中 IFrame<T>
        指定者:
        whereIn 在接口中 SDFrame<T>
        参数:
        function - the filter field
        list - specified range
      • whereNotIn

        public <R> SDFrame<T> whereNotIn​(java.util.function.Function<T,​R> function,
                                         List<R> list)
        从接口复制的说明: SDFrame
        The query value is outside the specified range
        指定者:
        whereNotIn 在接口中 IFrame<T>
        指定者:
        whereNotIn 在接口中 SDFrame<T>
        参数:
        function - the filter field
        list - specified range
      • whereEq

        public <R> SDFrame<T> whereEq​(java.util.function.Function<T,​R> function,
                                      R value)
        从接口复制的说明: SDFrame
        Filter equals
        指定者:
        whereEq 在接口中 IFrame<T>
        指定者:
        whereEq 在接口中 SDFrame<T>
        参数:
        function - the field
        value - need value
      • whereNotEq

        public <R> SDFrame<T> whereNotEq​(java.util.function.Function<T,​R> function,
                                         R value)
        从接口复制的说明: SDFrame
        Filter not equals
        指定者:
        whereNotEq 在接口中 IFrame<T>
        指定者:
        whereNotEq 在接口中 SDFrame<T>
        参数:
        function - the field
        value - not need value
      • whereGt

        public <R extends Comparable<R>> SDFrame<T> whereGt​(java.util.function.Function<T,​R> function,
                                                            R value)
        从接口复制的说明: SDFrame
        Filter Greater than value
        指定者:
        whereGt 在接口中 IFrame<T>
        指定者:
        whereGt 在接口中 SDFrame<T>
        参数:
        function - the field
        value - not need value
      • whereGe

        public <R extends Comparable<R>> SDFrame<T> whereGe​(java.util.function.Function<T,​R> function,
                                                            R value)
        从接口复制的说明: SDFrame
        Filter Greater than or equal to
        指定者:
        whereGe 在接口中 IFrame<T>
        指定者:
        whereGe 在接口中 SDFrame<T>
        参数:
        function - the field
        value - not need value
      • whereLt

        public <R extends Comparable<R>> SDFrame<T> whereLt​(java.util.function.Function<T,​R> function,
                                                            R value)
        从接口复制的说明: SDFrame
        Filter LESS than value
        指定者:
        whereLt 在接口中 IFrame<T>
        指定者:
        whereLt 在接口中 SDFrame<T>
        参数:
        function - the field
        value - not need value
      • whereLe

        public <R extends Comparable<R>> SDFrame<T> whereLe​(java.util.function.Function<T,​R> function,
                                                            R value)
        从接口复制的说明: SDFrame
        Filter less than or equal to
        指定者:
        whereLe 在接口中 IFrame<T>
        指定者:
        whereLe 在接口中 SDFrame<T>
        参数:
        function - the field
        value - not need value
      • whereLike

        public <R> SDFrame<T> whereLike​(java.util.function.Function<T,​R> function,
                                        R value)
        从接口复制的说明: SDFrame
        Fuzzy query contains specified values
        指定者:
        whereLike 在接口中 IFrame<T>
        指定者:
        whereLike 在接口中 SDFrame<T>
        参数:
        function - the field
        value - query value
      • whereNotLike

        public <R> SDFrame<T> whereNotLike​(java.util.function.Function<T,​R> function,
                                           R value)
        从接口复制的说明: SDFrame
        Fuzzy query not contains specified values
        指定者:
        whereNotLike 在接口中 IFrame<T>
        指定者:
        whereNotLike 在接口中 SDFrame<T>
        参数:
        function - the field
        value - query value
      • whereLikeLeft

        public <R> SDFrame<T> whereLikeLeft​(java.util.function.Function<T,​R> function,
                                            R value)
        从接口复制的说明: SDFrame
        prefix fuzzy query contains specified values
        指定者:
        whereLikeLeft 在接口中 IFrame<T>
        指定者:
        whereLikeLeft 在接口中 SDFrame<T>
        参数:
        function - the field
        value - query value
      • whereLikeRight

        public <R> SDFrame<T> whereLikeRight​(java.util.function.Function<T,​R> function,
                                             R value)
        从接口复制的说明: SDFrame
        suffix fuzzy query contains specified values
        指定者:
        whereLikeRight 在接口中 IFrame<T>
        指定者:
        whereLikeRight 在接口中 SDFrame<T>
        参数:
        function - the field
        value - query value
      • groupBySum

        public <K,​R extends NumberSDFrame<FI2<K,​BigDecimal>> groupBySum​(java.util.function.Function<T,​K> key,
                                                                                      NumberFunction<T,​R> value)
        =========================== 分组相关 =====================================
        指定者:
        groupBySum 在接口中 IFrame<T>
        指定者:
        groupBySum 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupBySum

        public <K,​J,​R extends NumberSDFrame<FI3<K,​J,​BigDecimal>> groupBySum​(java.util.function.Function<T,​K> key,
                                                                                                      java.util.function.Function<T,​J> key2,
                                                                                                      NumberFunction<T,​R> value)
        从接口复制的说明: SDFrame
        Group summation
        指定者:
        groupBySum 在接口中 IFrame<T>
        指定者:
        groupBySum 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupBySum

        public <K,​J,​H,​R extends NumberSDFrame<FI4<K,​J,​H,​BigDecimal>> groupBySum​(java.util.function.Function<T,​K> key,
                                                                                                                      java.util.function.Function<T,​J> key2,
                                                                                                                      java.util.function.Function<T,​H> key3,
                                                                                                                      NumberFunction<T,​R> value)
        从接口复制的说明: SDFrame
        Group summation
        指定者:
        groupBySum 在接口中 IFrame<T>
        指定者:
        groupBySum 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field
        value - Aggregated field
      • groupByCount

        public <K,​J> SDFrame<FI3<K,​J,​Long>> groupByCount​(java.util.function.Function<T,​K> key,
                                                                           java.util.function.Function<T,​J> key2)
        从接口复制的说明: SDFrame
        Group count
        指定者:
        groupByCount 在接口中 IFrame<T>
        指定者:
        groupByCount 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
      • groupByCount

        public <K,​J,​H> SDFrame<FI4<K,​J,​H,​Long>> groupByCount​(java.util.function.Function<T,​K> key,
                                                                                           java.util.function.Function<T,​J> key2,
                                                                                           java.util.function.Function<T,​H> key3)
        从接口复制的说明: SDFrame
        Group count
        指定者:
        groupByCount 在接口中 IFrame<T>
        指定者:
        groupByCount 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field
      • groupBySumCount

        public <K,​J,​R extends NumberSDFrame<FI4<K,​J,​BigDecimal,​Long>> groupBySumCount​(java.util.function.Function<T,​K> key,
                                                                                                                      java.util.function.Function<T,​J> key2,
                                                                                                                      NumberFunction<T,​R> value)
        从接口复制的说明: SDFrame
        Group sum and count together
        指定者:
        groupBySumCount 在接口中 IFrame<T>
        指定者:
        groupBySumCount 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
        返回:
        FItem4(key, ke2,Sum, Count)
      • groupByAvg

        public <K,​J,​R extends NumberSDFrame<FI3<K,​J,​BigDecimal>> groupByAvg​(java.util.function.Function<T,​K> key,
                                                                                                      java.util.function.Function<T,​J> key2,
                                                                                                      NumberFunction<T,​R> value)
        从接口复制的说明: SDFrame
        Group average
        指定者:
        groupByAvg 在接口中 IFrame<T>
        指定者:
        groupByAvg 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByAvg

        public <K,​J,​H,​R extends NumberSDFrame<FI4<K,​J,​H,​BigDecimal>> groupByAvg​(java.util.function.Function<T,​K> key,
                                                                                                                      java.util.function.Function<T,​J> key2,
                                                                                                                      java.util.function.Function<T,​H> key3,
                                                                                                                      NumberFunction<T,​R> value)
        从接口复制的说明: SDFrame
        Group average
        指定者:
        groupByAvg 在接口中 IFrame<T>
        指定者:
        groupByAvg 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field
        value - Aggregated field
      • groupByMax

        public <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​T>> groupByMax​(java.util.function.Function<T,​K> key,
                                                                                            java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max
        指定者:
        groupByMax 在接口中 IFrame<T>
        指定者:
        groupByMax 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupByMax

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​T>> groupByMax​(java.util.function.Function<T,​K> key,
                                                                                                            java.util.function.Function<T,​J> key2,
                                                                                                            java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max
        指定者:
        groupByMax 在接口中 IFrame<T>
        指定者:
        groupByMax 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByMaxValue

        public <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​V>> groupByMaxValue​(java.util.function.Function<T,​K> key,
                                                                                                 java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max value
        指定者:
        groupByMaxValue 在接口中 IFrame<T>
        指定者:
        groupByMaxValue 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupByMaxValue

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​V>> groupByMaxValue​(java.util.function.Function<T,​K> key,
                                                                                                                 java.util.function.Function<T,​J> key2,
                                                                                                                 java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max value
        指定者:
        groupByMaxValue 在接口中 IFrame<T>
        指定者:
        groupByMaxValue 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByMin

        public <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​T>> groupByMin​(java.util.function.Function<T,​K> key,
                                                                                            java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group min
        指定者:
        groupByMin 在接口中 IFrame<T>
        指定者:
        groupByMin 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupByMin

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​T>> groupByMin​(java.util.function.Function<T,​K> key,
                                                                                                            java.util.function.Function<T,​J> key2,
                                                                                                            java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group min
        指定者:
        groupByMin 在接口中 IFrame<T>
        指定者:
        groupByMin 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByMinValue

        public <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​V>> groupByMinValue​(java.util.function.Function<T,​K> key,
                                                                                                 java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group min value
        指定者:
        groupByMinValue 在接口中 IFrame<T>
        指定者:
        groupByMinValue 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupByMinValue

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​V>> groupByMinValue​(java.util.function.Function<T,​K> key,
                                                                                                                 java.util.function.Function<T,​J> key2,
                                                                                                                 java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group min value
        指定者:
        groupByMinValue 在接口中 IFrame<T>
        指定者:
        groupByMinValue 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByMaxMinValue

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​MaxMin<V>>> groupByMaxMinValue​(java.util.function.Function<T,​K> key,
                                                                                                                            java.util.function.Function<T,​J> key2,
                                                                                                                            java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max and min value
        指定者:
        groupByMaxMinValue 在接口中 IFrame<T>
        指定者:
        groupByMaxMinValue 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • groupByMaxMin

        public <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​MaxMin<T>>> groupByMaxMin​(java.util.function.Function<T,​K> key,
                                                                                                       java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max and min element
        指定者:
        groupByMaxMin 在接口中 IFrame<T>
        指定者:
        groupByMaxMin 在接口中 SDFrame<T>
        参数:
        key - group field
        value - Aggregated field
      • groupByMaxMin

        public <K,​J,​V extends Comparable<? super V>> SDFrame<FI3<K,​J,​MaxMin<T>>> groupByMaxMin​(java.util.function.Function<T,​K> key,
                                                                                                                       java.util.function.Function<T,​J> key2,
                                                                                                                       java.util.function.Function<T,​V> value)
        从接口复制的说明: SDFrame
        Group max and min element
        指定者:
        groupByMaxMin 在接口中 IFrame<T>
        指定者:
        groupByMaxMin 在接口中 SDFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field
      • overRowNumberS

        public SDFrameImpl<T> overRowNumberS​(SetFunction<T,​Integer> setFunction,
                                             Window<T> overParam)
        从接口复制的说明: SDFrame
        rowNumber window function set the function result to the setFunction
        指定者:
        overRowNumberS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
      • overRowNumberS

        public SDFrame<T> overRowNumberS​(SetFunction<T,​Integer> setFunction)
        从接口复制的说明: SDFrame
        rowNumber window function set the function result to the setFunction
        指定者:
        overRowNumberS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
      • overRankS

        public SDFrameImpl<T> overRankS​(SetFunction<T,​Integer> setFunction,
                                        Window<T> overParam)
        从接口复制的说明: SDFrame
        rank window function set the function result to the setFunction
        指定者:
        overRankS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
      • overDenseRankS

        public SDFrameImpl<T> overDenseRankS​(SetFunction<T,​Integer> setFunction,
                                             Window<T> overParam)
        从接口复制的说明: SDFrame
        dense rank window function set the function result to the setFunction
        指定者:
        overDenseRankS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
      • overCumeDistS

        public SDFrameImpl<T> overCumeDistS​(SetFunction<T,​BigDecimal> setFunction,
                                            Window<T> overParam)
        从接口复制的说明: SDFrame
        Cume Dist window function set the function result to the setFunction
        指定者:
        overCumeDistS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
      • overLag

        public <F> SDFrameImpl<FI2<T,​F>> overLag​(Window<T> overParam,
                                                       java.util.function.Function<T,​F> field,
                                                       int n)
        从接口复制的说明: SDFrame
        Lag window function get the value of the first n rows of the current row
        指定者:
        overLag 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
        n - first n rows
      • overLagS

        public <F> SDFrame<T> overLagS​(SetFunction<T,​F> setFunction,
                                       Window<T> overParam,
                                       java.util.function.Function<T,​F> field,
                                       int n)
        从接口复制的说明: SDFrame
        Lag window function get the value of the first n rows of the current row
        指定者:
        overLagS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - first n rows
      • overLag

        public <F> SDFrameImpl<FI2<T,​F>> overLag​(java.util.function.Function<T,​F> field,
                                                       int n)
        从接口复制的说明: SDFrame
        Lag window function get the value of the first n rows of the current row
        指定者:
        overLag 在接口中 SDFrame<T>
        参数:
        field - field value
        n - first n rows
      • overLagS

        public <F> SDFrame<T> overLagS​(SetFunction<T,​F> setFunction,
                                       java.util.function.Function<T,​F> field,
                                       int n)
        从接口复制的说明: SDFrame
        Lag window function get the value of the first n rows of the current row
        指定者:
        overLagS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
        n - first n rows
      • overLeadS

        public <F> SDFrame<T> overLeadS​(SetFunction<T,​F> setFunction,
                                        Window<T> overParam,
                                        java.util.function.Function<T,​F> field,
                                        int n)
        从接口复制的说明: SDFrame
        lead window function get the value of the last n rows of the current row
        指定者:
        overLeadS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - last n rows
      • overLead

        public <F> SDFrameImpl<FI2<T,​F>> overLead​(Window<T> overParam,
                                                        java.util.function.Function<T,​F> field,
                                                        int n)
        从接口复制的说明: SDFrame
        lead window function get the value of the last n rows of the current row
        指定者:
        overLead 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
        n - last n rows
      • overLead

        public <F> SDFrameImpl<FI2<T,​F>> overLead​(java.util.function.Function<T,​F> field,
                                                        int n)
        从接口复制的说明: SDFrame
        lead window function get the value of the last n rows of the current row
        指定者:
        overLead 在接口中 SDFrame<T>
        参数:
        field - field value
        n - last n rows
      • overLeadS

        public <F> SDFrame<T> overLeadS​(SetFunction<T,​F> setFunction,
                                        java.util.function.Function<T,​F> field,
                                        int n)
        从接口复制的说明: SDFrame
        lead window function get the value of the last n rows of the current row
        指定者:
        overLeadS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
        n - last n rows
      • overNthValue

        public <F> SDFrameImpl<FI2<T,​F>> overNthValue​(Window<T> overParam,
                                                            java.util.function.Function<T,​F> field,
                                                            int n)
        从接口复制的说明: SDFrame
        NthValue window function get the Nth row within the window range
        指定者:
        overNthValue 在接口中 SDFrame<T>
        field - field value
        n - last n rows
      • overNthValueS

        public <F> SDFrame<T> overNthValueS​(SetFunction<T,​F> setFunction,
                                            Window<T> overParam,
                                            java.util.function.Function<T,​F> field,
                                            int n)
        从接口复制的说明: SDFrame
        NthValue window function get the Nth row within the window range
        指定者:
        overNthValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - last n rows
      • overNthValue

        public <F> SDFrameImpl<FI2<T,​F>> overNthValue​(java.util.function.Function<T,​F> field,
                                                            int n)
        从接口复制的说明: SDFrame
        NthValue window function get the Nth row within the window range
        指定者:
        overNthValue 在接口中 SDFrame<T>
        参数:
        field - field value
        n - last n rows
      • overNthValueS

        public <F> SDFrameImpl<T> overNthValueS​(SetFunction<T,​F> setFunction,
                                                java.util.function.Function<T,​F> field,
                                                int n)
        从接口复制的说明: SDFrame
        NthValue window function get the Nth row within the window range
        指定者:
        overNthValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
        n - last n rows
      • overFirstValue

        public <F> SDFrameImpl<FI2<T,​F>> overFirstValue​(Window<T> overParam,
                                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        FirstValue window function get the first row within the window range
        指定者:
        overFirstValue 在接口中 SDFrame<T>
        field - field value
      • overFirstValueS

        public <F> SDFrame<T> overFirstValueS​(SetFunction<T,​F> setFunction,
                                              Window<T> overParam,
                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        FirstValue window function get the first row within the window range
        指定者:
        overFirstValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overFirstValue

        public <F> SDFrameImpl<FI2<T,​F>> overFirstValue​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        FirstValue window function get the first row within the window range
        指定者:
        overFirstValue 在接口中 SDFrame<T>
        参数:
        field - field value
      • overFirstValueS

        public <F> SDFrameImpl<T> overFirstValueS​(SetFunction<T,​F> setFunction,
                                                  java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        FirstValue window function get the first row within the window range
        指定者:
        overFirstValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overLastValue

        public <F> SDFrameImpl<FI2<T,​F>> overLastValue​(Window<T> overParam,
                                                             java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        LastValue window function get the last row within the window range
        指定者:
        overLastValue 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
      • overLastValueS

        public <F> SDFrameImpl<T> overLastValueS​(SetFunction<T,​F> setFunction,
                                                 Window<T> overParam,
                                                 java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        LastValue window function get the last row within the window range
        指定者:
        overLastValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overLastValue

        public <F> SDFrameImpl<FI2<T,​F>> overLastValue​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        LastValue window function get the last row within the window range
        指定者:
        overLastValue 在接口中 SDFrame<T>
        参数:
        field - field value
      • overLastValueS

        public <F> SDFrame<T> overLastValueS​(SetFunction<T,​F> setFunction,
                                             java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        LastValue window function get the last row within the window range
        指定者:
        overLastValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overSum

        public <F> SDFrameImpl<FI2<T,​BigDecimal>> overSum​(Window<T> overParam,
                                                                java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        Sum window function calculate the sum within the window range
        指定者:
        overSum 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
      • overSum

        public <F> SDFrameImpl<FI2<T,​BigDecimal>> overSum​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        Sum window function calculate the sum within the window range
        指定者:
        overSum 在接口中 SDFrame<T>
        参数:
        field - field value
      • overSumS

        public <F> SDFrameImpl<T> overSumS​(SetFunction<T,​BigDecimal> setFunction,
                                           Window<T> overParam,
                                           java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        Sum window function calculate the sum within the window range
        指定者:
        overSumS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overSumS

        public <F> SDFrameImpl<T> overSumS​(SetFunction<T,​BigDecimal> setFunction,
                                           java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        Sum window function calculate the sum within the window range
        指定者:
        overSumS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overAvg

        public <F> SDFrameImpl<FI2<T,​BigDecimal>> overAvg​(Window<T> overParam,
                                                                java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        avg window function calculate the avg value within the window range
        指定者:
        overAvg 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
      • overAvg

        public <F> SDFrameImpl<FI2<T,​BigDecimal>> overAvg​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        avg window function calculate the avg value within the window range
        指定者:
        overAvg 在接口中 SDFrame<T>
        参数:
        field - field value
      • overAvgS

        public <F> SDFrameImpl<T> overAvgS​(SetFunction<T,​BigDecimal> setFunction,
                                           Window<T> overParam,
                                           java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        avg window function calculate the avg value within the window range
        指定者:
        overAvgS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overAvgS

        public <F> SDFrameImpl<T> overAvgS​(SetFunction<T,​BigDecimal> setFunction,
                                           java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        avg window function calculate the avg value within the window range
        指定者:
        overAvgS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overMaxValue

        public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,​F>> overMaxValue​(Window<T> overParam,
                                                                                          java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        max window function calculate the max value within the window range
        指定者:
        overMaxValue 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
      • overMaxValue

        public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,​F>> overMaxValue​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        max window function calculate the max value within the window range
        指定者:
        overMaxValue 在接口中 SDFrame<T>
        参数:
        field - field value
      • overMaxValueS

        public <F extends Comparable<? super F>> SDFrameImpl<T> overMaxValueS​(SetFunction<T,​F> setFunction,
                                                                              Window<T> overParam,
                                                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        max window function calculate the max value within the window range
        指定者:
        overMaxValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overMaxValueS

        public <F extends Comparable<? super F>> SDFrameImpl<T> overMaxValueS​(SetFunction<T,​F> setFunction,
                                                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        max window function calculate the max value within the window range
        指定者:
        overMaxValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overMinValue

        public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,​F>> overMinValue​(Window<T> overParam,
                                                                                          java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        min window function calculate the min value within the window range
        指定者:
        overMinValue 在接口中 SDFrame<T>
        参数:
        overParam - window param
        field - field value
      • overMinValue

        public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,​F>> overMinValue​(java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        min window function calculate the min value within the window range
        指定者:
        overMinValue 在接口中 SDFrame<T>
        参数:
        field - field value
      • overMinValueS

        public <F extends Comparable<? super F>> SDFrameImpl<T> overMinValueS​(SetFunction<T,​F> setFunction,
                                                                              Window<T> overParam,
                                                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        min window function calculate the min value within the window range
        指定者:
        overMinValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
      • overMinValueS

        public <F extends Comparable<? super F>> SDFrameImpl<T> overMinValueS​(SetFunction<T,​F> setFunction,
                                                                              java.util.function.Function<T,​F> field)
        从接口复制的说明: SDFrame
        min window function calculate the min value within the window range
        指定者:
        overMinValueS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        field - field value
      • overCount

        public SDFrameImpl<FI2<T,​Integer>> overCount​(Window<T> overParam)
        从接口复制的说明: SDFrame
        count window function calculate the count within the window range
        指定者:
        overCount 在接口中 SDFrame<T>
        参数:
        overParam - window param
      • overCountS

        public SDFrameImpl<T> overCountS​(SetFunction<T,​Integer> setFunction,
                                         Window<T> overParam)
        从接口复制的说明: SDFrame
        count window function calculate the count within the window range
        指定者:
        overCountS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
      • overCountS

        public SDFrameImpl<T> overCountS​(SetFunction<T,​Integer> setFunction)
        从接口复制的说明: SDFrame
        count window function calculate the count within the window range
        指定者:
        overCountS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
      • overNtile

        public SDFrameImpl<FI2<T,​Integer>> overNtile​(int n)
        从接口复制的说明: SDFrame
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        指定者:
        overNtile 在接口中 SDFrame<T>
        参数:
        n - size of buckets
      • overNtile

        public SDFrameImpl<FI2<T,​Integer>> overNtile​(Window<T> overParam,
                                                           int n)
        从接口复制的说明: SDFrame
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        指定者:
        overNtile 在接口中 SDFrame<T>
        参数:
        overParam - window param
        n - size of buckets
      • overNtileS

        public SDFrameImpl<T> overNtileS​(SetFunction<T,​Integer> setFunction,
                                         Window<T> overParam,
                                         int n)
        从接口复制的说明: SDFrame
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        指定者:
        overNtileS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        overParam - window param
        n - size of buckets
      • overNtileS

        public SDFrameImpl<T> overNtileS​(SetFunction<T,​Integer> setFunction,
                                         int n)
        从接口复制的说明: SDFrame
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        指定者:
        overNtileS 在接口中 SDFrame<T>
        参数:
        setFunction - function result accept
        n - size of buckets
      • replenish

        public <G,​C> SDFrameImpl<T> replenish​(java.util.function.Function<T,​G> groupDim,
                                                    java.util.function.Function<T,​C> collectDim,
                                                    List<C> allDim,
                                                    ReplenishFunction<G,​C,​T> getEmptyObject)
        从接口复制的说明: SDFrame
        Calculate the difference in groups and then add the difference to that group according to the groupDim dimension, and then summarize all collectDim fields within each group After summarizing, calculate the difference sets with allAbscissa, which are the entries that need to be supplemented. Then, generate empty objects according to the ReplenishFunction logic and add them to the group
        指定者:
        replenish 在接口中 IFrame<T>
        指定者:
        replenish 在接口中 SDFrame<T>
        类型参数:
        G - The type of grouping
        C - type of collection within the group The set supplemented by @ return
        参数:
        groupDim - Dimension fields for grouping
        collectDim - Data fields collected within the group
        allDim - All dimensions that need to be displayed within the group
        getEmptyObject - Logic for generating empty objects
      • replenish

        public <C> SDFrameImpl<T> replenish​(java.util.function.Function<T,​C> collectDim,
                                            List<C> allDim,
                                            java.util.function.Function<C,​T> getEmptyObject)
        从接口复制的说明: SDFrame
        Summarize all collectDim values, calculate the difference between them, and then add the missing difference to the Frame through getEmptyObject
        指定者:
        replenish 在接口中 IFrame<T>
        指定者:
        replenish 在接口中 SDFrame<T>
      • replenish

        public <G,​C> SDFrameImpl<T> replenish​(java.util.function.Function<T,​G> groupDim,
                                                    java.util.function.Function<T,​C> collectDim,
                                                    ReplenishFunction<G,​C,​T> getEmptyObject)
        从接口复制的说明: SDFrame
        such as IFrame.replenish(Function, Function, List, ReplenishFunction), but can not Specify allDim, will auto generate allDim, The default allDim is the value of all collectDim fields in the set
        指定者:
        replenish 在接口中 IFrame<T>
        指定者:
        replenish 在接口中 SDFrame<T>
        类型参数:
        G - The type of grouping
        C - type of collection within the group
        参数:
        groupDim - Dimension fields for grouping
        collectDim - Data fields collected within the group
        getEmptyObject - Logic for generating empty objects
      • returnThis

        protected SDFrameImpl<T> returnThis​(java.util.stream.Stream<T> stream)