程序包 io.github.burukeyou.dataframe.iframe

接口 SDFrame<T>

  • 所有超级接口:
    IFrame<T>, Iterable<T>
    所有已知子接口:
    WindowSDFrame<T>
    所有已知实现类:
    SDFrameImpl, WindowSDFrameImpl
    public interface SDFrame<T>
extends IFrame<T>
    Stream DataFrame The operations before and after are continuous, consistent with the stream flow, and some operations terminate the execution of the operation. The stream cannot be reused and needs to be re read to generate the stream, making it suitable for serial use
    作者:
    caizhihao

    • 方法详细资料

      • read

        static <R> SDFrame<R> read​(List<R> list)
        Convert a list to SDFrame

      • read

        static <K,​V> SDFrame<FI2<K,​V>> read​(Map<K,​V> map)
        Convert a map to SDFrame

      • readMap

        static <K,​J,​V> SDFrame<FI3<K,​J,​V>> readMap​(Map<K,​Map<J,​V>> map)
        Convert a map to SDFrame

      • from

        <R> SDFrame<R> from​(java.util.stream.Stream<R> data)
        Convert to other SDFrame
        指定者:
        from 在接口中 IFrame<T>

      • forEachDo

        SDFrame<T> forEachDo​(java.util.function.Consumer<? super T> action)
        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>

      • show

        void show()
        print the 10 row to the console
        指定者:
        show 在接口中 IFrame<T>

      • show

        void show​(int n)
        print the n row to the console
        指定者:
        show 在接口中 IFrame<T>

      • col

        <R> List<R> col​(java.util.function.Function<T,​R> function)
        Get a column value
        指定者:
        col 在接口中 IFrame<T>

      • append

        SDFrame<T> append​(T t)
        add element to Frame
        指定者:
        append 在接口中 IFrame<T>
        参数:
        t - element

      • union

        SDFrame<T> union​(IFrame<T> other)
        add other Frame to this
        指定者:
        union 在接口中 IFrame<T>
        参数:
        other - other Frame

      • join

        <R,​K> SDFrame<R> join​(IFrame<K> other,
                            JoinOn<T,​K> on,
                            Join<T,​K,​R> join)
        inner join Frame
        指定者:
        join 在接口中 IFrame<T>
        类型参数:
        R - new Frame type
        K - other Frame type
        参数:
        other - other frame
        on - connection conditions
        join - Connection logic

      • join

        <R,​K> SDFrame<R> join​(IFrame<K> other,
                            JoinOn<T,​K> on)
        inner join Frame such as IFrame.join(IFrame, JoinOn, Join), but the default Join is DefaultJoin, it will automatically map to a new Frame based on the same name
        指定者:
        join 在接口中 IFrame<T>
        类型参数:
        R - new Frame type
        K - other Frame type
        参数:
        other - other frame
        on - connection conditions

      • leftJoin

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

      • rightJoin

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

      • map

        <R> SDFrame<R> map​(java.util.function.Function<T,​R> map)
        convert to the new Frame
        指定者:
        map 在接口中 IFrame<T>
        类型参数:
        R - the new Frame type
        参数:
        map - convert operation
        返回:
        the new Frame

      • mapPercent

        <R extends Number> SDFrame<T> mapPercent​(java.util.function.Function<T,​R> get,
                                         SetFunction<T,​BigDecimal> set,
                                         int scale)
        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>
        类型参数:
        R - the percentage field type
        参数:
        get - need percentage convert field
        set - field for storing percentage values
        scale - percentage retain decimal places

      • partition

        SDFrame<List<T>> partition​(int n)
        partition cut the matrix into multiple small matrices, with each matrix size n
        指定者:
        partition 在接口中 IFrame<T>
        参数:
        n - size of each zone

      • sortDesc

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

      • sortAsc

        <R extends Comparable<R>> SDFrame<T> sortAsc​(java.util.function.Function<T,​R> function)
        Ascending order
        指定者:
        sortAsc 在接口中 IFrame<T>
        参数:
        function - sort field

      • cutFirst

        SDFrame<T> cutFirst​(int n)
        Cut the top n element
        指定者:
        cutFirst 在接口中 IFrame<T>
        参数:
        n - the top n

      • cutLast

        SDFrame<T> cutLast​(int n)
        Cut the last n element
        指定者:
        cutLast 在接口中 IFrame<T>
        参数:
        n - the last n

      • cutPage

        SDFrame<T> cutPage​(int page,
                   int pageSize)
        cut paginated data
        指定者:
        cutPage 在接口中 IFrame<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

      • cutFirstRank

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

      • head

        T head()
        Get the first element
        指定者:
        head 在接口中 IFrame<T>

      • head

        List<T> head​(int n)
        Get the first n elements
        指定者:
        head 在接口中 IFrame<T>

      • tail

        T tail()
        Get the last element
        指定者:
        tail 在接口中 IFrame<T>

      • tail

        List<T> tail​(int n)
        Get the last n elements
        指定者:
        tail 在接口中 IFrame<T>

      • distinct

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

      • countDistinct

        <R extends Comparable<R>> long countDistinct​(java.util.function.Function<T,​R> function)
        Calculate the quantity after deduplication
        指定者:
        countDistinct 在接口中 IFrame<T>

      • countDistinct

        long countDistinct​(Comparator<T> comparator)
        Calculate the quantity after deduplication
        指定者:
        countDistinct 在接口中 IFrame<T>

      • where

        SDFrame<T> where​(java.util.function.Predicate<? super T> predicate)
        filter by predicate
        指定者:
        where 在接口中 IFrame<T>
        参数:
        predicate - the predicate

      • whereNull

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

      • whereNotNull

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

      • whereBetween

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

      • whereBetweenN

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

      • whereBetweenR

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

      • whereBetweenL

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

      • whereNotBetween

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

      • whereNotBetweenN

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

      • whereIn

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

      • whereNotIn

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

      • whereTrue

        SDFrame<T> whereTrue​(java.util.function.Predicate<T> predicate)
        filter true by predicate
        指定者:
        whereTrue 在接口中 IFrame<T>

      • whereNotTrue

        SDFrame<T> whereNotTrue​(java.util.function.Predicate<T> predicate)
        filter not true by predicate
        指定者:
        whereNotTrue 在接口中 IFrame<T>

      • whereEq

        <R> SDFrame<T> whereEq​(java.util.function.Function<T,​R> function,
                       R value)
        Filter equals
        指定者:
        whereEq 在接口中 IFrame<T>
        参数:
        function - the field
        value - need value

      • whereNotEq

        <R> SDFrame<T> whereNotEq​(java.util.function.Function<T,​R> function,
                          R value)
        Filter not equals
        指定者:
        whereNotEq 在接口中 IFrame<T>
        参数:
        function - the field
        value - not need value

      • whereGt

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

      • whereGe

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

      • whereLt

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

      • whereLe

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

      • whereLike

        <R> SDFrame<T> whereLike​(java.util.function.Function<T,​R> function,
                         R value)
        Fuzzy query contains specified values
        指定者:
        whereLike 在接口中 IFrame<T>
        参数:
        function - the field
        value - query value

      • whereNotLike

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

      • whereLikeLeft

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

      • whereLikeRight

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

      • sum

        <R> BigDecimal sum​(java.util.function.Function<T,​R> function)
        Sum the values of the field
        指定者:
        sum 在接口中 IFrame<T>
        参数:
        function - the field

      • avg

        <R> BigDecimal avg​(java.util.function.Function<T,​R> function)
        average the values of the field
        指定者:
        avg 在接口中 IFrame<T>
        参数:
        function - the field

      • maxMin

        <R extends Comparable<? super R>> MaxMin<T> maxMin​(java.util.function.Function<T,​R> function)
        Finding the maximum and minimum element
        指定者:
        maxMin 在接口中 IFrame<T>
        参数:
        function - the field

      • maxMinValue

        <R extends Comparable<? super R>> MaxMin<R> maxMinValue​(java.util.function.Function<T,​R> function)
        Finding the maximum and minimum value
        指定者:
        maxMinValue 在接口中 IFrame<T>
        参数:
        function - the field

      • max

        <R extends Comparable<R>> T max​(java.util.function.Function<T,​R> function)
        Finding the maximum element
        指定者:
        max 在接口中 IFrame<T>
        参数:
        function - the field

      • maxValue

        <R extends Comparable<? super R>> R maxValue​(java.util.function.Function<T,​R> function)
        Finding the maximum value
        指定者:
        maxValue 在接口中 IFrame<T>
        参数:
        function - the field

      • minValue

        <R extends Comparable<? super R>> R minValue​(java.util.function.Function<T,​R> function)
        Finding the minimum value
        指定者:
        minValue 在接口中 IFrame<T>
        参数:
        function - the field

      • min

        <R extends Comparable<R>> T min​(java.util.function.Function<T,​R> function)
        Finding the minimum element
        指定者:
        min 在接口中 IFrame<T>
        参数:
        function - the field

      • count

        long count()
        get row count
        指定者:
        count 在接口中 IFrame<T>

      • group

        <K> SDFrame<FI2<K,​List<T>>> group​(java.util.function.Function<T,​K> key)
        Group list
        指定者:
        group 在接口中 IFrame<T>
        参数:
        key - group field

      • groupBySum

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

      • groupBySum

        <K,​J,​H,​R extends Number> SDFrame<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)
        Group summation
        指定者:
        groupBySum 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field
        value - Aggregated field

      • groupByCount

        <K> SDFrame<FI2<K,​Long>> groupByCount​(java.util.function.Function<T,​K> key)
        Group count
        指定者:
        groupByCount 在接口中 IFrame<T>
        参数:
        key - group field

      • groupByCount

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

      • groupByCount

        <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)
        Group count
        指定者:
        groupByCount 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field

      • groupBySumCount

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

      • groupByAvg

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

      • groupByAvg

        <K,​J,​H,​R extends Number> SDFrame<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)
        Group average
        指定者:
        groupByAvg 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        key3 - third level group field
        value - Aggregated field

      • groupByMax

        <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)
        Group max
        指定者:
        groupByMax 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMax

        <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)
        Group max
        指定者:
        groupByMax 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • groupByMaxValue

        <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)
        Group max value
        指定者:
        groupByMaxValue 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMaxValue

        <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)
        Group max value
        指定者:
        groupByMaxValue 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • groupByMin

        <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)
        Group min
        指定者:
        groupByMin 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMin

        <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)
        Group min
        指定者:
        groupByMin 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • groupByMinValue

        <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)
        Group min value
        指定者:
        groupByMinValue 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMinValue

        <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)
        Group min value
        指定者:
        groupByMinValue 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • groupByMaxMinValue

        <K,​V extends Comparable<? super V>> SDFrame<FI2<K,​MaxMin<V>>> groupByMaxMinValue​(java.util.function.Function<T,​K> key,
                                                                                             java.util.function.Function<T,​V> value)
        Group max and min value
        指定者:
        groupByMaxMinValue 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMaxMinValue

        <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)
        Group max and min value
        指定者:
        groupByMaxMinValue 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • groupByMaxMin

        <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)
        Group max and min element
        指定者:
        groupByMaxMin 在接口中 IFrame<T>
        参数:
        key - group field
        value - Aggregated field

      • groupByMaxMin

        <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)
        Group max and min element
        指定者:
        groupByMaxMin 在接口中 IFrame<T>
        参数:
        key - group field
        key2 - secondary level group field
        value - Aggregated field

      • overRowNumber

        SDFrame<FI2<T,​Integer>> overRowNumber​(Window<T> overParam)
        rowNumber window function
        参数:
        overParam - window param

      • overRowNumberS

        SDFrame<T> overRowNumberS​(SetFunction<T,​Integer> setFunction,
                          Window<T> overParam)
        rowNumber window function set the function result to the setFunction
        参数:
        setFunction - function result accept
        overParam - window param

      • overRowNumberS

        SDFrame<T> overRowNumberS​(SetFunction<T,​Integer> setFunction)
        rowNumber window function set the function result to the setFunction
        参数:
        setFunction - function result accept

      • overRank

        SDFrame<FI2<T,​Integer>> overRank​(Window<T> overParam)
        rank window function
        参数:
        overParam - window param

      • overRankS

        SDFrame<T> overRankS​(SetFunction<T,​Integer> setFunction,
                     Window<T> overParam)
        rank window function set the function result to the setFunction
        参数:
        setFunction - function result accept
        overParam - window param

      • overDenseRank

        SDFrame<FI2<T,​Integer>> overDenseRank​(Window<T> overParam)
        dense rank window function
        参数:
        overParam - window param

      • overDenseRankS

        SDFrame<T> overDenseRankS​(SetFunction<T,​Integer> setFunction,
                          Window<T> overParam)
        dense rank window function set the function result to the setFunction
        参数:
        setFunction - function result accept
        overParam - window param

      • overPercentRank

        SDFrame<FI2<T,​BigDecimal>> overPercentRank​(Window<T> overParam)
        Percent rank window function
        参数:
        overParam - window param

      • overPercentRankS

        SDFrame<T> overPercentRankS​(SetFunction<T,​BigDecimal> setFunction,
                            Window<T> overParam)
        Percent rank window function set the function result to the setFunction
        参数:
        setFunction - function result accept
        overParam - window param

      • overCumeDist

        SDFrame<FI2<T,​BigDecimal>> overCumeDist​(Window<T> overParam)
        Cume Dist window function
        参数:
        overParam - window param

      • overCumeDistS

        SDFrame<T> overCumeDistS​(SetFunction<T,​BigDecimal> setFunction,
                         Window<T> overParam)
        Cume Dist window function set the function result to the setFunction
        参数:
        setFunction - function result accept
        overParam - window param

      • overLag

        <F> SDFrame<FI2<T,​F>> overLag​(Window<T> overParam,
                                    java.util.function.Function<T,​F> field,
                                    int n)
        Lag window function get the value of the first n rows of the current row
        参数:
        overParam - window param
        field - field value
        n - first n rows

      • overLagS

        <F> SDFrame<T> overLagS​(SetFunction<T,​F> setFunction,
                        Window<T> overParam,
                        java.util.function.Function<T,​F> field,
                        int n)
        Lag window function get the value of the first n rows of the current row
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - first n rows

      • overLag

        <F> SDFrame<FI2<T,​F>> overLag​(java.util.function.Function<T,​F> field,
                                    int n)
        Lag window function get the value of the first n rows of the current row
        参数:
        field - field value
        n - first n rows

      • overLagS

        <F> SDFrame<T> overLagS​(SetFunction<T,​F> setFunction,
                        java.util.function.Function<T,​F> field,
                        int n)
        Lag window function get the value of the first n rows of the current row
        参数:
        setFunction - function result accept
        field - field value
        n - first n rows

      • overLead

        <F> SDFrame<FI2<T,​F>> overLead​(Window<T> overParam,
                                     java.util.function.Function<T,​F> field,
                                     int n)
        lead window function get the value of the last n rows of the current row
        参数:
        overParam - window param
        field - field value
        n - last n rows

      • overLeadS

        <F> SDFrame<T> overLeadS​(SetFunction<T,​F> setFunction,
                         Window<T> overParam,
                         java.util.function.Function<T,​F> field,
                         int n)
        lead window function get the value of the last n rows of the current row
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - last n rows

      • overLead

        <F> SDFrame<FI2<T,​F>> overLead​(java.util.function.Function<T,​F> field,
                                     int n)
        lead window function get the value of the last n rows of the current row
        参数:
        field - field value
        n - last n rows

      • overLeadS

        <F> SDFrame<T> overLeadS​(SetFunction<T,​F> setFunction,
                         java.util.function.Function<T,​F> field,
                         int n)
        lead window function get the value of the last n rows of the current row
        参数:
        setFunction - function result accept
        field - field value
        n - last n rows

      • overNthValue

        <F> SDFrame<FI2<T,​F>> overNthValue​(Window<T> overParam,
                                         java.util.function.Function<T,​F> field,
                                         int n)
        NthValue window function get the Nth row within the window range
        参数:
        field - field value
        n - last n rows

      • overNthValueS

        <F> SDFrame<T> overNthValueS​(SetFunction<T,​F> setFunction,
                             Window<T> overParam,
                             java.util.function.Function<T,​F> field,
                             int n)
        NthValue window function get the Nth row within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value
        n - last n rows

      • overNthValue

        <F> SDFrame<FI2<T,​F>> overNthValue​(java.util.function.Function<T,​F> field,
                                         int n)
        NthValue window function get the Nth row within the window range
        参数:
        field - field value
        n - last n rows

      • overNthValueS

        <F> SDFrame<T> overNthValueS​(SetFunction<T,​F> setFunction,
                             java.util.function.Function<T,​F> field,
                             int n)
        NthValue window function get the Nth row within the window range
        参数:
        setFunction - function result accept
        field - field value
        n - last n rows

      • overFirstValue

        <F> SDFrame<FI2<T,​F>> overFirstValue​(Window<T> overParam,
                                           java.util.function.Function<T,​F> field)
        FirstValue window function get the first row within the window range
        参数:
        field - field value

      • overFirstValueS

        <F> SDFrame<T> overFirstValueS​(SetFunction<T,​F> setFunction,
                               Window<T> overParam,
                               java.util.function.Function<T,​F> field)
        FirstValue window function get the first row within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overFirstValue

        <F> SDFrame<FI2<T,​F>> overFirstValue​(java.util.function.Function<T,​F> field)
        FirstValue window function get the first row within the window range
        参数:
        field - field value

      • overFirstValueS

        <F> SDFrame<T> overFirstValueS​(SetFunction<T,​F> setFunction,
                               java.util.function.Function<T,​F> field)
        FirstValue window function get the first row within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overLastValue

        <F> SDFrame<FI2<T,​F>> overLastValue​(Window<T> overParam,
                                          java.util.function.Function<T,​F> field)
        LastValue window function get the last row within the window range
        参数:
        overParam - window param
        field - field value

      • overLastValueS

        <F> SDFrame<T> overLastValueS​(SetFunction<T,​F> setFunction,
                              Window<T> overParam,
                              java.util.function.Function<T,​F> field)
        LastValue window function get the last row within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overLastValue

        <F> SDFrame<FI2<T,​F>> overLastValue​(java.util.function.Function<T,​F> field)
        LastValue window function get the last row within the window range
        参数:
        field - field value

      • overLastValueS

        <F> SDFrame<T> overLastValueS​(SetFunction<T,​F> setFunction,
                              java.util.function.Function<T,​F> field)
        LastValue window function get the last row within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overSum

        <F> SDFrame<FI2<T,​BigDecimal>> overSum​(Window<T> overParam,
                                             java.util.function.Function<T,​F> field)
        Sum window function calculate the sum within the window range
        参数:
        overParam - window param
        field - field value

      • overSum

        <F> SDFrame<FI2<T,​BigDecimal>> overSum​(java.util.function.Function<T,​F> field)
        Sum window function calculate the sum within the window range
        参数:
        field - field value

      • overSumS

        <F> SDFrame<T> overSumS​(SetFunction<T,​BigDecimal> setFunction,
                        Window<T> overParam,
                        java.util.function.Function<T,​F> field)
        Sum window function calculate the sum within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overSumS

        <F> SDFrame<T> overSumS​(SetFunction<T,​BigDecimal> setFunction,
                        java.util.function.Function<T,​F> field)
        Sum window function calculate the sum within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overAvg

        <F> SDFrame<FI2<T,​BigDecimal>> overAvg​(Window<T> overParam,
                                             java.util.function.Function<T,​F> field)
        avg window function calculate the avg value within the window range
        参数:
        overParam - window param
        field - field value

      • overAvg

        <F> SDFrame<FI2<T,​BigDecimal>> overAvg​(java.util.function.Function<T,​F> field)
        avg window function calculate the avg value within the window range
        参数:
        field - field value

      • overAvgS

        <F> SDFrame<T> overAvgS​(SetFunction<T,​BigDecimal> setFunction,
                        Window<T> overParam,
                        java.util.function.Function<T,​F> field)
        avg window function calculate the avg value within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overAvgS

        <F> SDFrame<T> overAvgS​(SetFunction<T,​BigDecimal> setFunction,
                        java.util.function.Function<T,​F> field)
        avg window function calculate the avg value within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overMaxValue

        <F extends Comparable<? super F>> SDFrame<FI2<T,​F>> overMaxValue​(Window<T> overParam,
                                                                       java.util.function.Function<T,​F> field)
        max window function calculate the max value within the window range
        参数:
        overParam - window param
        field - field value

      • overMaxValue

        <F extends Comparable<? super F>> SDFrame<FI2<T,​F>> overMaxValue​(java.util.function.Function<T,​F> field)
        max window function calculate the max value within the window range
        参数:
        field - field value

      • overMaxValueS

        <F extends Comparable<? super F>> SDFrame<T> overMaxValueS​(SetFunction<T,​F> setFunction,
                                                           Window<T> overParam,
                                                           java.util.function.Function<T,​F> field)
        max window function calculate the max value within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overMaxValueS

        <F extends Comparable<? super F>> SDFrame<T> overMaxValueS​(SetFunction<T,​F> setFunction,
                                                           java.util.function.Function<T,​F> field)
        max window function calculate the max value within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overMinValue

        <F extends Comparable<? super F>> SDFrame<FI2<T,​F>> overMinValue​(Window<T> overParam,
                                                                       java.util.function.Function<T,​F> field)
        min window function calculate the min value within the window range
        参数:
        overParam - window param
        field - field value

      • overMinValue

        <F extends Comparable<? super F>> SDFrame<FI2<T,​F>> overMinValue​(java.util.function.Function<T,​F> field)
        min window function calculate the min value within the window range
        参数:
        field - field value

      • overMinValueS

        <F extends Comparable<? super F>> SDFrame<T> overMinValueS​(SetFunction<T,​F> setFunction,
                                                           Window<T> overParam,
                                                           java.util.function.Function<T,​F> field)
        min window function calculate the min value within the window range
        参数:
        setFunction - function result accept
        overParam - window param
        field - field value

      • overMinValueS

        <F extends Comparable<? super F>> SDFrame<T> overMinValueS​(SetFunction<T,​F> setFunction,
                                                           java.util.function.Function<T,​F> field)
        min window function calculate the min value within the window range
        参数:
        setFunction - function result accept
        field - field value

      • overCount

        SDFrame<FI2<T,​Integer>> overCount​(Window<T> overParam)
        count window function calculate the count within the window range
        参数:
        overParam - window param

      • overCount

        SDFrame<FI2<T,​Integer>> overCount()
        count window function calculate the count within the window range

      • overCountS

        SDFrame<T> overCountS​(SetFunction<T,​Integer> setFunction,
                      Window<T> overParam)
        count window function calculate the count within the window range
        参数:
        setFunction - function result accept
        overParam - window param

      • overCountS

        SDFrame<T> overCountS​(SetFunction<T,​Integer> setFunction)
        count window function calculate the count within the window range
        参数:
        setFunction - function result accept

      • overNtile

        SDFrame<FI2<T,​Integer>> overNtile​(int n)
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        参数:
        n - size of buckets

      • overNtile

        SDFrame<FI2<T,​Integer>> overNtile​(Window<T> overParam,
                                        int n)
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        参数:
        n - size of buckets
        overParam - window param

      • overNtileS

        SDFrame<T> overNtileS​(SetFunction<T,​Integer> setFunction,
                      Window<T> overParam,
                      int n)
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        参数:
        setFunction - function result accept
        n - size of buckets
        overParam - window param

      • overNtileS

        SDFrame<T> overNtileS​(SetFunction<T,​Integer> setFunction,
                      int n)
        Ntile window function assign bucket numbers evenly to windows, starting from 1
        参数:
        setFunction - function result accept
        n - size of buckets

      • replenish

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

      • replenish

        <G,​C> SDFrame<T> replenish​(java.util.function.Function<T,​G> groupDim,
                                 java.util.function.Function<T,​C> collectDim,
                                 List<C> allDim,
                                 ReplenishFunction<G,​C,​T> getEmptyObject)
        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>
        类型参数:
        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

        <G,​C> SDFrame<T> replenish​(java.util.function.Function<T,​G> groupDim,
                                 java.util.function.Function<T,​C> collectDim,
                                 ReplenishFunction<G,​C,​T> getEmptyObject)
        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>
        类型参数:
        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