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

类 AbstractWindowDataFrame<T>

java.lang.Object

io.github.burukeyou.dataframe.iframe.AbstractCommonFrame<T>

io.github.burukeyou.dataframe.iframe.AbstractWindowDataFrame<T>

类型参数:

T -

所有已实现的接口:

IFrame<T>, Iterable<T>

直接已知子类:

AbstractDataFrameImpl

public abstract class AbstractWindowDataFrame<T>
extends AbstractCommonFrame<T>

Window DataFrame implement

作者:

caizhihao

字段概要

字段

修饰符和类型	字段	说明
protected Window<T>	emptyWindow
protected Window<T>	window

从类继承的字段 io.github.burukeyou.dataframe.iframe.AbstractCommonFrame

defaultRoundingMode, defaultScale, fieldList, MSG, oldModeField

构造器概要

构造器

构造器	说明
AbstractWindowDataFrame()

方法概要

修饰符和类型	方法	说明
protected void	dfsFindWindow(List<List<T>> result, List<T> windowList, List<java.util.function.Function<T,?>> partitionList, int index)
<F> BigDecimal	getBigDecimalValue(T obj, java.util.function.Function<T,F> field)
FI2<Integer,Integer>	getFirstSlidingWindow(List<T> windowList, Window<T> overParam)
<V> FI2<Integer,Integer>	getIndexRange(Window<T> overParam, int currentIndex, List<V> windowList)
boolean	isAllRow(Window<T> overParam)
boolean	isInRange(FI2<Integer,Integer> round, int index)
protected <V> List<FI2<T,V>>	overAbject(Window<T> overParam, SupplierFunction<T,V> supplier)
<F> List<FI2<T,BigDecimal>>	slidingWindowAvg(List<T> nums, Window<T> overParam, java.util.function.Function<T,F> field)
<F extends Comparable<? super F>> List<FI2<T,F>>	slidingWindowForMaxValue(List<T> nums, Window<T> overParam, java.util.function.Function<T,F> field)
<F extends Comparable<? super F>> List<FI2<T,F>>	slidingWindowForMinValue(List<T> nums, Window<T> overParam, java.util.function.Function<T,F> field)
<F> List<FI2<T,BigDecimal>>	slidingWindowSum(List<T> nums, Window<T> overParam, java.util.function.Function<T,F> field)
<F extends Comparable<? super F>> void	updateSlidingWindowMaxQueue(LinkedList<Integer> queue, FieldValueList<T,F> obj, int i)
<F extends Comparable<? super F>> void	updateSlidingWindowMinQueue(LinkedList<Integer> queue, FieldValueList<T,F> obj, int i)
protected <F> List<FI2<T,BigDecimal>>	windowFunctionForAvg(Window<T> overParam, java.util.function.Function<T,F> field)
protected List<FI2<T,Integer>>	windowFunctionForCount(Window<T> overParam)
protected List<FI2<T,BigDecimal>>	windowFunctionForCumeDist(Window<T> overParam)
protected List<FI2<T,Integer>>	windowFunctionForDenseRank(Window<T> overParam)
protected <F> List<FI2<T,F>>	windowFunctionForLag(Window<T> overParam, java.util.function.Function<T,F> field, int n)	获取当前行的前N行的值
protected <F> List<FI2<T,F>>	windowFunctionForLead(Window<T> overParam, java.util.function.Function<T,F> field, int n)	获取当前行的后N行的值
protected <F extends Comparable<? super F>> List<FI2<T,F>>	windowFunctionForMaxValue(Window<T> overParam, java.util.function.Function<T,F> field)
protected <F extends Comparable<? super F>> List<FI2<T,F>>	windowFunctionForMinValue(Window<T> overParam, java.util.function.Function<T,F> field)
protected <F> List<FI2<T,F>>	windowFunctionForNthValue(Window<T> overParam, java.util.function.Function<T,F> field, int n)	获取窗口内第N行的值
protected List<FI2<T,Integer>>	windowFunctionForNtile(Window<T> overParam, int n)
protected List<FI2<T,BigDecimal>>	windowFunctionForPercentRank(Window<T> overParam)
protected List<FI2<T,Integer>>	windowFunctionForRank(Window<T> overParam)
protected List<FI2<T,Integer>>	windowFunctionForRowNumber(Window<T> overParam)
protected <F> List<FI2<T,BigDecimal>>	windowFunctionForSum(Window<T> overParam, java.util.function.Function<T,F> field)

从类继承的方法 io.github.burukeyou.dataframe.iframe.AbstractCommonFrame

bigDecimalToClassValue, buildPrintDataArr, getOldRoundingMode, getSuperClassActualTypeArguments, getSuperInterfaceActualTypeArguments, initDefaultScale, rankingSameAsc, rankingSameAsc, transmitMember

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 io.github.burukeyou.dataframe.iframe.IFrame

addRankCol, addRankCol, addRowNumberCol, addRowNumberCol, addRowNumberCol, addRowNumberCol, append, avg, col, columns, count, countDistinct, countDistinct, cut, cutFirst, cutFirstRank, cutLast, cutPage, defaultScale, defaultScale, distinct, distinct, distinct, forEachDo, from, group, groupByAvg, groupByAvg, groupByAvg, groupByCount, groupByCount, groupByCount, groupByMax, groupByMax, groupByMaxMin, groupByMaxMin, groupByMaxMinValue, groupByMaxMinValue, groupByMaxValue, groupByMaxValue, groupByMin, groupByMin, groupByMinValue, groupByMinValue, groupBySum, groupBySum, groupBySum, groupBySumCount, groupBySumCount, head, head, join, join, leftJoin, leftJoin, map, mapPercent, mapPercent, max, maxMin, maxMinValue, maxValue, min, minValue, page, partition, replenish, replenish, replenish, rightJoin, rightJoin, show, show, sortAsc, sortAsc, sortDesc, sortDesc, stream, subList, sum, tail, tail, toLists, union, where, whereBetween, whereBetweenL, whereBetweenN, whereBetweenR, whereEq, whereGe, whereGt, whereIn, whereLe, whereLike, whereLikeLeft, whereLikeRight, whereLt, whereNotBetween, whereNotBetweenN, whereNotEq, whereNotIn, whereNotLike, whereNotNull, whereNotTrue, whereNull, whereTrue

从接口继承的方法 java.lang.Iterable

forEach, iterator, spliterator

字段详细资料

emptyWindow

protected final Window<T> emptyWindow

window

protected Window<T> window

构造器详细资料

AbstractWindowDataFrame

public AbstractWindowDataFrame()

方法详细资料

overAbject

protected <V> List<FI2<T,V>> overAbject(Window<T> overParam,
                                              SupplierFunction<T,V> supplier)

dfsFindWindow

protected void dfsFindWindow(List<List<T>> result,
                             List<T> windowList,
                             List<java.util.function.Function<T,?>> partitionList,
                             int index)

windowFunctionForRowNumber

protected List<FI2<T,Integer>> windowFunctionForRowNumber(Window<T> overParam)

windowFunctionForRank

protected List<FI2<T,Integer>> windowFunctionForRank(Window<T> overParam)

windowFunctionForDenseRank

protected List<FI2<T,Integer>> windowFunctionForDenseRank(Window<T> overParam)

windowFunctionForPercentRank

protected List<FI2<T,BigDecimal>> windowFunctionForPercentRank(Window<T> overParam)

windowFunctionForCumeDist

protected List<FI2<T,BigDecimal>> windowFunctionForCumeDist(Window<T> overParam)

windowFunctionForLag

protected <F> List<FI2<T,F>> windowFunctionForLag(Window<T> overParam,
                                                        java.util.function.Function<T,F> field,
                                                        int n)

获取当前行的前N行的值

windowFunctionForLead

protected <F> List<FI2<T,F>> windowFunctionForLead(Window<T> overParam,
                                                         java.util.function.Function<T,F> field,
                                                         int n)

获取当前行的后N行的值

windowFunctionForNthValue

protected <F> List<FI2<T,F>> windowFunctionForNthValue(Window<T> overParam,
                                                             java.util.function.Function<T,F> field,
                                                             int n)

获取窗口内第N行的值

getIndexRange

public <V> FI2<Integer,Integer> getIndexRange(Window<T> overParam,
                                                    int currentIndex,
                                                    List<V> windowList)

isInRange

public boolean isInRange(FI2<Integer,Integer> round,
                         int index)

isAllRow

public boolean isAllRow(Window<T> overParam)

windowFunctionForSum

protected <F> List<FI2<T,BigDecimal>> windowFunctionForSum(Window<T> overParam,
                                                                 java.util.function.Function<T,F> field)

slidingWindowSum

public <F> List<FI2<T,BigDecimal>> slidingWindowSum(List<T> nums,
                                                          Window<T> overParam,
                                                          java.util.function.Function<T,F> field)

getBigDecimalValue

public <F> BigDecimal getBigDecimalValue(T obj,
                                         java.util.function.Function<T,F> field)

windowFunctionForAvg

protected <F> List<FI2<T,BigDecimal>> windowFunctionForAvg(Window<T> overParam,
                                                                 java.util.function.Function<T,F> field)

slidingWindowAvg

public <F> List<FI2<T,BigDecimal>> slidingWindowAvg(List<T> nums,
                                                          Window<T> overParam,
                                                          java.util.function.Function<T,F> field)

getFirstSlidingWindow

public FI2<Integer,Integer> getFirstSlidingWindow(List<T> windowList,
                                                        Window<T> overParam)

updateSlidingWindowMaxQueue

public <F extends Comparable<? super F>> void updateSlidingWindowMaxQueue(LinkedList<Integer> queue,
                                                                          FieldValueList<T,F> obj,
                                                                          int i)

updateSlidingWindowMinQueue

public <F extends Comparable<? super F>> void updateSlidingWindowMinQueue(LinkedList<Integer> queue,
                                                                          FieldValueList<T,F> obj,
                                                                          int i)

slidingWindowForMaxValue

public <F extends Comparable<? super F>> List<FI2<T,F>> slidingWindowForMaxValue(List<T> nums,
                                                                                       Window<T> overParam,
                                                                                       java.util.function.Function<T,F> field)

slidingWindowForMinValue

public <F extends Comparable<? super F>> List<FI2<T,F>> slidingWindowForMinValue(List<T> nums,
                                                                                       Window<T> overParam,
                                                                                       java.util.function.Function<T,F> field)

windowFunctionForMaxValue

protected <F extends Comparable<? super F>> List<FI2<T,F>> windowFunctionForMaxValue(Window<T> overParam,
                                                                                           java.util.function.Function<T,F> field)

windowFunctionForMinValue

protected <F extends Comparable<? super F>> List<FI2<T,F>> windowFunctionForMinValue(Window<T> overParam,
                                                                                           java.util.function.Function<T,F> field)

windowFunctionForCount

protected List<FI2<T,Integer>> windowFunctionForCount(Window<T> overParam)

windowFunctionForNtile

protected List<FI2<T,Integer>> windowFunctionForNtile(Window<T> overParam,
                                                            int n)