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

类 AbstractDataFrameImpl<T>

    • 构造器详细资料

      • AbstractDataFrameImpl

        protected AbstractDataFrameImpl()

    • 方法详细资料

      • whereNullStream

        protected <R> java.util.stream.Stream<T> whereNullStream​(java.util.function.Function<T,​R> function)

      • whereNotNullStream

        protected <R> java.util.stream.Stream<T> whereNotNullStream​(java.util.function.Function<T,​R> function)

      • whereBetweenStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereBetweenStream​(java.util.function.Function<T,​R> function,
                                                                               R start,
                                                                               R end)

      • whereBetweenNStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereBetweenNStream​(java.util.function.Function<T,​R> function,
                                                                                R start,
                                                                                R end)

      • whereBetweenRStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereBetweenRStream​(java.util.function.Function<T,​R> function,
                                                                                R start,
                                                                                R end)

      • whereBetweenLStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereBetweenLStream​(java.util.function.Function<T,​R> function,
                                                                                R start,
                                                                                R end)

      • whereNotBetweenStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereNotBetweenStream​(java.util.function.Function<T,​R> function,
                                                                                  R start,
                                                                                  R end)

      • whereNotBetweenNStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereNotBetweenNStream​(java.util.function.Function<T,​R> function,
                                                                                   R start,
                                                                                   R end)

      • whereInStream

        public <R> java.util.stream.Stream<T> whereInStream​(java.util.function.Function<T,​R> function,
                                                    List<R> list)

      • whereNotInStream

        public <R> java.util.stream.Stream<T> whereNotInStream​(java.util.function.Function<T,​R> function,
                                                       List<R> list)

      • whereEqStream

        public <R> java.util.stream.Stream<T> whereEqStream​(java.util.function.Function<T,​R> function,
                                                    R value)

      • whereNotEqStream

        public <R> java.util.stream.Stream<T> whereNotEqStream​(java.util.function.Function<T,​R> function,
                                                       R value)

      • whereGtStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereGtStream​(java.util.function.Function<T,​R> function,
                                                                          R value)

      • whereGeStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereGeStream​(java.util.function.Function<T,​R> function,
                                                                          R value)

      • whereLtStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereLtStream​(java.util.function.Function<T,​R> function,
                                                                          R value)

      • whereLeStream

        public <R extends Comparable<R>> java.util.stream.Stream<T> whereLeStream​(java.util.function.Function<T,​R> function,
                                                                          R value)

      • whereLikeStream

        public <R> java.util.stream.Stream<T> whereLikeStream​(java.util.function.Function<T,​R> function,
                                                      R value)

      • whereNotLikeStream

        public <R> java.util.stream.Stream<T> whereNotLikeStream​(java.util.function.Function<T,​R> function,
                                                         R value)

      • whereLikeLeftStream

        public <R> java.util.stream.Stream<T> whereLikeLeftStream​(java.util.function.Function<T,​R> function,
                                                          R value)

      • whereLikeRightStream

        public <R> java.util.stream.Stream<T> whereLikeRightStream​(java.util.function.Function<T,​R> function,
                                                           R value)

      • sum

        public <R> BigDecimal sum​(java.util.function.Function<T,​R> function)
        =========================== 汇总相关 =====================================
        参数:
        function - the field

      • avg

        public <R> BigDecimal avg​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        average the values of the field
        参数:
        function - the field

      • maxMinValue

        public <R extends Comparable<? super R>> MaxMin<R> maxMinValue​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the maximum and minimum value
        参数:
        function - the field

      • maxMin

        public <R extends Comparable<? super R>> MaxMin<T> maxMin​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the maximum and minimum element
        参数:
        function - the field

      • maxValue

        public <R extends Comparable<? super R>> R maxValue​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the maximum value
        参数:
        function - the field

      • max

        public <R extends Comparable<R>> T max​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the maximum element
        参数:
        function - the field

      • minValue

        public <R extends Comparable<? super R>> R minValue​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the minimum value
        参数:
        function - the field

      • min

        public <R extends Comparable<R>> T min​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Finding the minimum element
        参数:
        function - the field

      • count

        public long count()
        从接口复制的说明: IFrame
        get row count

      • groupKey

        protected <K> List<FI2<K,​List<T>>> groupKey​(java.util.function.Function<T,​K> K)

      • groupKey

        protected <K,​V> List<FI2<K,​V>> groupKey​(java.util.function.Function<T,​K> K,
                                                    java.util.stream.Collector<T,​?,​V> tBigDecimalCollector)
        一级分组
        参数:
        K - 一级分组K
        tBigDecimalCollector - 聚合方式

      • groupKey

        protected <K,​J,​V> List<FI3<K,​J,​V>> groupKey​(java.util.function.Function<T,​K> K,
                                                                    java.util.function.Function<T,​J> J,
                                                                    java.util.stream.Collector<T,​?,​V> tBigDecimalCollector)
        二级分组
        参数:
        K - 一级分组K
        J - 二级分组K
        tBigDecimalCollector - 聚合方式

      • groupKey

        protected <K,​J,​H,​V> List<FI4<K,​J,​H,​V>> groupKey​(java.util.function.Function<T,​K> K,
                                                                                    java.util.function.Function<T,​J> J,
                                                                                    java.util.function.Function<T,​H> H,
                                                                                    java.util.stream.Collector<T,​?,​V> collectorType)
        三级分组
        参数:
        K - 一级分组K
        J - 二级分组K
        H - 三级分组K
        collectorType - 聚合方式

      • groupToMap

        protected <K,​J,​V extends Comparable<V>> Map<K,​Map<J,​T>> groupToMap​(java.util.function.Function<T,​K> key,
                                                                                           java.util.function.Function<T,​J> key2,
                                                                                           java.util.function.Function<List<T>,​T> getListMaxFunction)

      • getListMaxFunction

        protected <V extends Comparable<? super V>> java.util.function.Function<List<T>,​T> getListMaxFunction​(java.util.function.Function<T,​V> value)

      • getListMinFunction

        protected <V extends Comparable<? super V>> java.util.function.Function<List<T>,​T> getListMinFunction​(java.util.function.Function<T,​V> value)

      • getListGroupMaxMinValueFunction

        protected <V extends Comparable<? super V>> java.util.function.Function<List<T>,​MaxMin<V>> getListGroupMaxMinValueFunction​(java.util.function.Function<T,​V> value)

      • getListGroupMaxMinFunction

        protected <V extends Comparable<? super V>> java.util.function.Function<List<T>,​MaxMin<T>> getListGroupMaxMinFunction​(java.util.function.Function<T,​V> value)

      • streamFilterNull

        public <R> java.util.stream.Stream<T> streamFilterNull​(java.util.function.Function<T,​R> function)

      • buildFieldList

        protected <F> List<String> buildFieldList​(F f)

      • columns

        public List<String> columns()
        从接口复制的说明: IFrame
        Get column headers

      • col

        public <R> List<R> col​(java.util.function.Function<T,​R> function)
        从接口复制的说明: IFrame
        Get a column value

      • page

        public List<T> page​(int page,
                    int pageSize)
        从接口复制的说明: IFrame
        Get paginated data
        参数:
        page - The current page number is considered as the first page, regardless of whether it is passed as 0 or 1
        pageSize - page size

      • show

        public void show()
        从接口复制的说明: IFrame
        print the 10 row to the console

      • show

        public void show​(int n)
        从接口复制的说明: IFrame
        print the n row to the console

      • joinList

        protected <R,​K> List<R> joinList​(IFrame<K> other,
                                       JoinOn<T,​K> on,
                                       Join<T,​K,​R> join)

      • leftJoinList

        protected <R,​K> List<R> leftJoinList​(IFrame<K> other,
                                           JoinOn<T,​K> on,
                                           Join<T,​K,​R> join)

      • rightJoinList

        protected <R,​K> List<R> rightJoinList​(IFrame<K> other,
                                            JoinOn<T,​K> on,
                                            Join<T,​K,​R> join)

      • head

        public List<T> head​(int n)
        从接口复制的说明: IFrame
        Get the first n elements

      • tail

        public List<T> tail​(int n)
        从接口复制的说明: IFrame
        Get the last n elements

      • head

        public T head()
        从接口复制的说明: IFrame
        Get the first element

      • tail

        public T tail()
        从接口复制的说明: IFrame
        Get the last element

      • subList

        public List<T> subList​(Integer startIndex,
                       Integer endIndex)
        从接口复制的说明: IFrame
        Get elements within the scope. [startIndex,endIndex]

      • replenish

        protected static <T,​C> List<T> replenish​(List<T> itemDTOList,
                                               java.util.function.Function<T,​C> collectDim,
                                               List<C> allDim,
                                               java.util.function.Function<C,​T> getEmptyObject)

      • replenish

        public static <T,​G,​C> List<T> replenish​(List<T> itemDTOList,
                                                    java.util.function.Function<T,​G> groupDim,
                                                    java.util.function.Function<T,​C> collectDim,
                                                    List<C> allDim,
                                                    ReplenishFunction<G,​C,​T> getEmptyObject)
        分组计算差集， 然后将差集补充到该分组内 将原始集合(itemDTOList) 按照groupDim维度进分组， 然后将每个分组内的所有collectDim字段进行汇总 汇总后 与 allAbscissa进行计算差集，这些差集就是需要补充的条目， 然后将这些差集按照getEmptyObject逻辑生成空对象添加到该分组内
        类型参数:
        T - 原始集合的类型
        G - 分组的类型
        C - 组内收集的类型
        参数:
        itemDTOList - 原始集合
        groupDim - 分组的维度字段
        collectDim - 组内收集的数据字段
        allDim - 组内需要展示的所有维度
        getEmptyObject - 生成空对象的逻辑
        返回:
        补充后的集合

      • replenish

        protected static <T,​G,​C> List<T> replenish​(List<T> itemDTOList,
                                                       java.util.function.Function<T,​G> groupDim,
                                                       java.util.function.Function<T,​C> collectDim,
                                                       ReplenishFunction<G,​C,​T> getEmptyObject)

      • mergeCollection

        protected static <C> List<C> mergeCollection​(Collection<List<C>> values)

      • getApplyValue

        protected <R> R getApplyValue​(java.util.function.Function<T,​R> fun,
                              T obj)