类 SDFrameImpl<T>
- java.lang.Object
-
- io.github.burukeyou.dataframe.iframe.AbstractCommonFrame<T>
-
- io.github.burukeyou.dataframe.iframe.AbstractWindowDataFrame<T>
-
- io.github.burukeyou.dataframe.iframe.AbstractDataFrameImpl<T>
-
- io.github.burukeyou.dataframe.iframe.SDFrameImpl<T>
-
- 直接已知子类:
WindowSDFrameImpl
public class SDFrameImpl<T> extends AbstractDataFrameImpl<T> implements SDFrame<T>
- 作者:
- caizhihao
-
-
字段概要
字段 修饰符和类型 字段 说明 protected java.util.stream.Stream<T>data-
从类继承的字段 io.github.burukeyou.dataframe.iframe.AbstractWindowDataFrame
emptyWindow, window
-
从类继承的字段 io.github.burukeyou.dataframe.iframe.AbstractCommonFrame
defaultRoundingMode, defaultScale, fieldList, MSG, oldModeField
-
-
构造器概要
构造器 构造器 说明 SDFrameImpl(List<T> list)SDFrameImpl(java.util.stream.Stream<T> data)
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 SDFrameImpl<FI2<T,Integer>>addRankCol(Sorter<T> sorter)Add ranking columns by comparator Ranking logic, the same value means the Ranking is the same.SDFrame<T>addRankCol(Sorter<T> sorter, SetFunction<T,Integer> set)Add ranking column to a certain column by ComparatorSDFrameImpl<FI2<T,Integer>>addRowNumberCol()ddd ordinal columnSDFrameImpl<T>addRowNumberCol(SetFunction<T,Integer> set)Add a numbered column to a specific columnSDFrameImpl<FI2<T,Integer>>addRowNumberCol(Sorter<T> sorter)Sort by comparator first, then add ordinal columnsSDFrameImpl<T>addRowNumberCol(Sorter<T> sorter, SetFunction<T,Integer> set)Add a numbered column to a specific columnSDFrameImpl<T>append(T t)add element to Framelongcount()get row countlongcountDistinct(Comparator<T> comparator)Calculate the quantity after deduplication<R extends Comparable<R>>
longcountDistinct(java.util.function.Function<T,R> function)Calculate the quantity after deduplicationSDFrame<T>cut(Integer startIndex, Integer endIndex)cut elements within the scopeSDFrame<T>cutFirst(int n)=========================== 截取相关 =====================================SDFrame<T>cutFirstRank(Sorter<T> sorter, int n)Cut the top N rankings data The same value is considered to have the same rankingSDFrame<T>cutLast(int n)Cut the last n elementSDFrame<T>cutPage(int page, int pageSize)cut paginated dataSDFrame<T>defaultScale(int scale)Set default decimal placesSDFrame<T>defaultScale(int scale, RoundingMode roundingMode)Set default decimal placesSDFrame<T>distinct()distinct by T value<R extends Comparable<R>>
SDFrame<T>distinct(Comparator<T> comparator)distinct by comparator<R extends Comparable<R>>
SDFrame<T>distinct(java.util.function.Function<T,R> function)distinct by field value<F> SDFrameImpl<T>fi2Frame(SDFrameImpl<FI2<T,F>> frame, SetFunction<T,F> setFunction)SDFrameImpl<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.<R> SDFrame<R>from(java.util.stream.Stream<R> data)Convert to other SDFrame<K> SDFrame<FI2<K,List<T>>>group(java.util.function.Function<T,K> key)Group list<K,R extends Number>
SDFrame<FI2<K,BigDecimal>>groupByAvg(java.util.function.Function<T,K> key, NumberFunction<T,R> value)Group average<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<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<K> SDFrame<FI2<K,Long>>groupByCount(java.util.function.Function<T,K> key)Group count<K,J>
SDFrame<FI3<K,J,Long>>groupByCount(java.util.function.Function<T,K> key, java.util.function.Function<T,J> key2)Group count<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<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<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<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<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<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<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<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<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<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<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<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<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<K,R extends Number>
SDFrame<FI2<K,BigDecimal>>groupBySum(java.util.function.Function<T,K> key, NumberFunction<T,R> value)=========================== 分组相关 =====================================<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<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<K,R extends Number>
SDFrame<FI3<K,BigDecimal,Long>>groupBySumCount(java.util.function.Function<T,K> key, NumberFunction<T,R> value)Group sum and count together<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<R,K>
SDFrameImpl<R>join(IFrame<K> other, JoinOn<T,K> on)inner join Frame such asIFrame.join(IFrame, JoinOn, Join), but the default Join isDefaultJoin, it will automatically map to a new Frame based on the same name<R,K>
SDFrameImpl<R>join(IFrame<K> other, JoinOn<T,K> on, Join<T,K,R> join)inner join Frame<R,K>
SDFrameImpl<R>leftJoin(IFrame<K> other, JoinOn<T,K> on)left join Frame such asIFrame.leftJoin(IFrame, JoinOn, Join), but the default Join isDefaultJoin,<R,K>
SDFrameImpl<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<R> SDFrameImpl<R>map(java.util.function.Function<T,R> map)convert to the new Frame<R extends Number>
SDFrame<T>mapPercent(java.util.function.Function<T,R> get, SetFunction<T,BigDecimal> set)Percentage convert such asIFrame.mapPercent(Function, SetFunction, int), but default scale is 2<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<F> SDFrameImpl<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<F> SDFrameImpl<FI2<T,BigDecimal>>overAvg(java.util.function.Function<T,F> field)avg window function calculate the avg value within the window range<F> SDFrameImpl<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<F> SDFrameImpl<T>overAvgS(SetFunction<T,BigDecimal> setFunction, java.util.function.Function<T,F> field)avg window function calculate the avg value within the window rangeSDFrameImpl<FI2<T,Integer>>overCount()count window function calculate the count within the window rangeSDFrameImpl<FI2<T,Integer>>overCount(Window<T> overParam)count window function calculate the count within the window rangeSDFrameImpl<T>overCountS(SetFunction<T,Integer> setFunction)count window function calculate the count within the window rangeSDFrameImpl<T>overCountS(SetFunction<T,Integer> setFunction, Window<T> overParam)count window function calculate the count within the window rangeSDFrameImpl<FI2<T,BigDecimal>>overCumeDist(Window<T> overParam)Cume Dist window functionSDFrameImpl<T>overCumeDistS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam)Cume Dist window function set the function result to the setFunctionSDFrameImpl<FI2<T,Integer>>overDenseRank(Window<T> overParam)dense rank window functionSDFrameImpl<T>overDenseRankS(SetFunction<T,Integer> setFunction, Window<T> overParam)dense rank window function set the function result to the setFunction<F> SDFrameImpl<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<F> SDFrameImpl<FI2<T,F>>overFirstValue(java.util.function.Function<T,F> field)FirstValue window function get the first row within the window range<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<F> SDFrameImpl<T>overFirstValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field)FirstValue window function get the first row within the window range<F> SDFrameImpl<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<F> SDFrameImpl<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<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<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<F> SDFrameImpl<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<F> SDFrameImpl<FI2<T,F>>overLastValue(java.util.function.Function<T,F> field)LastValue window function get the last row within the window range<F> SDFrameImpl<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<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<F> SDFrameImpl<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<F> SDFrameImpl<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<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<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<F extends Comparable<? super F>>
SDFrameImpl<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<F extends Comparable<? super F>>
SDFrameImpl<FI2<T,F>>overMaxValue(java.util.function.Function<T,F> field)max window function calculate the max value within the window range<F extends Comparable<? super F>>
SDFrameImpl<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<F extends Comparable<? super F>>
SDFrameImpl<T>overMaxValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field)max window function calculate the max value within the window range<F extends Comparable<? super F>>
SDFrameImpl<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<F extends Comparable<? super F>>
SDFrameImpl<FI2<T,F>>overMinValue(java.util.function.Function<T,F> field)min window function calculate the min value within the window range<F extends Comparable<? super F>>
SDFrameImpl<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<F extends Comparable<? super F>>
SDFrameImpl<T>overMinValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field)min window function calculate the min value within the window range<F> SDFrameImpl<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<F> SDFrameImpl<FI2<T,F>>overNthValue(java.util.function.Function<T,F> field, int n)NthValue window function get the Nth row within the window range<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<F> SDFrameImpl<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 rangeSDFrameImpl<FI2<T,Integer>>overNtile(int n)Ntile window function assign bucket numbers evenly to windows, starting from 1SDFrameImpl<FI2<T,Integer>>overNtile(Window<T> overParam, int n)Ntile window function assign bucket numbers evenly to windows, starting from 1SDFrameImpl<T>overNtileS(SetFunction<T,Integer> setFunction, int n)Ntile window function assign bucket numbers evenly to windows, starting from 1SDFrameImpl<T>overNtileS(SetFunction<T,Integer> setFunction, Window<T> overParam, int n)Ntile window function assign bucket numbers evenly to windows, starting from 1SDFrameImpl<FI2<T,BigDecimal>>overPercentRank(Window<T> overParam)Percent rank window functionSDFrameImpl<T>overPercentRankS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam)Percent rank window function set the function result to the setFunctionSDFrameImpl<FI2<T,Integer>>overRank(Window<T> overParam)rank window functionSDFrameImpl<T>overRankS(SetFunction<T,Integer> setFunction, Window<T> overParam)rank window function set the function result to the setFunctionSDFrame<FI2<T,Integer>>overRowNumber()rowNumber window functionSDFrameImpl<FI2<T,Integer>>overRowNumber(Window<T> overParam)rowNumber window functionSDFrame<T>overRowNumberS(SetFunction<T,Integer> setFunction)rowNumber window function set the function result to the setFunctionSDFrameImpl<T>overRowNumberS(SetFunction<T,Integer> setFunction, Window<T> overParam)rowNumber window function set the function result to the setFunction<F> SDFrameImpl<FI2<T,BigDecimal>>overSum(Window<T> overParam, java.util.function.Function<T,F> field)Sum window function calculate the sum within the window range<F> SDFrameImpl<FI2<T,BigDecimal>>overSum(java.util.function.Function<T,F> field)Sum window function calculate the sum within the window range<F> SDFrameImpl<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<F> SDFrameImpl<T>overSumS(SetFunction<T,BigDecimal> setFunction, java.util.function.Function<T,F> field)Sum window function calculate the sum within the window rangeSDFrameImpl<List<T>>partition(int n)partition cut the matrix into multiple small matrices, with each matrix size n<R> SDFrameImpl<R>read(List<R> list)<C> SDFrameImpl<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<G,C>
SDFrameImpl<T>replenish(java.util.function.Function<T,G> groupDim, java.util.function.Function<T,C> collectDim, ReplenishFunction<G,C,T> getEmptyObject)such asIFrame.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<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)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.protected <R> SDFrameImpl<R>returnDF(List<R> dataList)protected SDFrameImpl<T>returnThis(List<T> dataList)protected SDFrameImpl<T>returnThis(java.util.stream.Stream<T> stream)<R,K>
SDFrameImpl<R>rightJoin(IFrame<K> other, JoinOn<T,K> on)right join Frame such asIFrame.rightJoin(IFrame, JoinOn, Join), but the default Join isDefaultJoin,<R,K>
SDFrameImpl<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 KSDFrameImpl<T>sortAsc(Comparator<T> comparator)Ascending order<R extends Comparable<R>>
SDFrameImpl<T>sortAsc(java.util.function.Function<T,R> function)Ascending orderSDFrameImpl<T>sortDesc(Comparator<T> comparator)=========================== 排序相关 =====================================<R extends Comparable<? super R>>
SDFrameImpl<T>sortDesc(java.util.function.Function<T,R> function)Descending order by fieldjava.util.stream.Stream<T>stream()get streamList<T>toLists()Convert to listSDFrameImpl<T>union(IFrame<T> other)add other Frame to thisSDFrame<T>where(java.util.function.Predicate<? super T> predicate)=========================== 筛选相关 =====================================<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.<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)<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)<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]<R> SDFrame<T>whereEq(java.util.function.Function<T,R> function, R value)Filter equals<R extends Comparable<R>>
SDFrame<T>whereGe(java.util.function.Function<T,R> function, R value)Filter Greater than or equal to<R extends Comparable<R>>
SDFrame<T>whereGt(java.util.function.Function<T,R> function, R value)Filter Greater than value<R> SDFrame<T>whereIn(java.util.function.Function<T,R> function, List<R> list)The query value is within the specified range<R extends Comparable<R>>
SDFrame<T>whereLe(java.util.function.Function<T,R> function, R value)Filter less than or equal to<R> SDFrame<T>whereLike(java.util.function.Function<T,R> function, R value)Fuzzy query contains specified values<R> SDFrame<T>whereLikeLeft(java.util.function.Function<T,R> function, R value)prefix fuzzy query contains specified values<R> SDFrame<T>whereLikeRight(java.util.function.Function<T,R> function, R value)suffix fuzzy query contains specified values<R extends Comparable<R>>
SDFrame<T>whereLt(java.util.function.Function<T,R> function, R value)Filter LESS than value<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]<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)<R> SDFrame<T>whereNotEq(java.util.function.Function<T,R> function, R value)Filter not equals<R> SDFrame<T>whereNotIn(java.util.function.Function<T,R> function, List<R> list)The query value is outside the specified range<R> SDFrame<T>whereNotLike(java.util.function.Function<T,R> function, R value)Fuzzy query not contains specified values<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 '' situationsSDFrame<T>whereNotTrue(java.util.function.Predicate<T> predicate)filter not true by predicate<R> SDFrame<T>whereNull(java.util.function.Function<T,R> function)Filter field values that are null, If it is string compatible, null and '' situationsSDFrame<T>whereTrue(java.util.function.Predicate<T> predicate)filter true by predicateWindowSDFrame<T>window()open a empty windowWindowSDFrame<T>window(Window<T> window)open a window-
从类继承的方法 io.github.burukeyou.dataframe.iframe.AbstractDataFrameImpl
avg, buildFieldList, col, columns, getApplyValue, getListGroupMaxMinFunction, getListGroupMaxMinValueFunction, getListMaxFunction, getListMinFunction, groupKey, groupKey, groupKey, groupKey, groupToMap, head, head, iterator, joinList, leftJoinList, max, maxMin, maxMinValue, maxValue, mergeCollection, min, minValue, page, replenish, replenish, replenish, rightJoinList, show, show, streamFilterNull, subList, sum, tail, tail, whereBetweenLStream, whereBetweenNStream, whereBetweenRStream, whereBetweenStream, whereEqStream, whereGeStream, whereGtStream, whereInStream, whereLeStream, whereLikeLeftStream, whereLikeRightStream, whereLikeStream, whereLtStream, whereNotBetweenNStream, whereNotBetweenStream, whereNotEqStream, whereNotInStream, whereNotLikeStream, whereNotNullStream, whereNullStream
-
从类继承的方法 io.github.burukeyou.dataframe.iframe.AbstractWindowDataFrame
dfsFindWindow, getBigDecimalValue, getFirstSlidingWindow, getIndexRange, isAllRow, isInRange, overAbject, slidingWindowAvg, slidingWindowForMaxValue, slidingWindowForMinValue, slidingWindowSum, updateSlidingWindowMaxQueue, updateSlidingWindowMinQueue, windowFunctionForAvg, windowFunctionForCount, windowFunctionForCumeDist, windowFunctionForDenseRank, windowFunctionForLag, windowFunctionForLead, windowFunctionForMaxValue, windowFunctionForMinValue, windowFunctionForNthValue, windowFunctionForNtile, windowFunctionForPercentRank, windowFunctionForRank, windowFunctionForRowNumber, windowFunctionForSum
-
从类继承的方法 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
-
从接口继承的方法 java.lang.Iterable
forEach, iterator, spliterator
-
-
-
-
字段详细资料
-
data
protected java.util.stream.Stream<T> data
-
-
方法详细资料
-
read
public <R> SDFrameImpl<R> read(List<R> list)
-
from
public <R> SDFrame<R> from(java.util.stream.Stream<R> data)
从接口复制的说明:SDFrameConvert to other SDFrame
-
forEachDo
public SDFrameImpl<T> forEachDo(java.util.function.Consumer<? super T> action)
从接口复制的说明:SDFramePerforms the given action for each element of the Iterable until all elements have been processed or the action throws an exception.
-
defaultScale
public SDFrame<T> defaultScale(int scale)
从接口复制的说明:SDFrameSet default decimal places- 指定者:
defaultScale在接口中IFrame<T>- 指定者:
defaultScale在接口中SDFrame<T>
-
defaultScale
public SDFrame<T> defaultScale(int scale, RoundingMode roundingMode)
从接口复制的说明:SDFrameSet default decimal places- 指定者:
defaultScale在接口中IFrame<T>- 指定者:
defaultScale在接口中SDFrame<T>
-
map
public <R> SDFrameImpl<R> map(java.util.function.Function<T,R> map)
从接口复制的说明:SDFrameconvert to the new Frame
-
mapPercent
public <R extends Number> SDFrame<T> mapPercent(java.util.function.Function<T,R> get, SetFunction<T,BigDecimal> set)
从接口复制的说明:SDFramePercentage convert such asIFrame.mapPercent(Function, SetFunction, int), but default scale is 2- 指定者:
mapPercent在接口中IFrame<T>- 指定者:
mapPercent在接口中SDFrame<T>- 参数:
get- need percentage convert fieldset- field for storing percentage values
-
mapPercent
public <R extends Number> SDFrame<T> mapPercent(java.util.function.Function<T,R> get, SetFunction<T,BigDecimal> set, int scale)
从接口复制的说明:SDFramePercentage 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 fieldset- field for storing percentage valuesscale- percentage retain decimal places
-
partition
public SDFrameImpl<List<T>> partition(int n)
从接口复制的说明:SDFramepartition cut the matrix into multiple small matrices, with each matrix size n
-
append
public SDFrameImpl<T> append(T t)
从接口复制的说明:SDFrameadd element to Frame
-
union
public SDFrameImpl<T> union(IFrame<T> other)
从接口复制的说明:SDFrameadd other Frame to this
-
join
public <R,K> SDFrameImpl<R> join(IFrame<K> other, JoinOn<T,K> on, Join<T,K,R> join)
从接口复制的说明:SDFrameinner join Frame
-
join
public <R,K> SDFrameImpl<R> join(IFrame<K> other, JoinOn<T,K> on)
从接口复制的说明:SDFrameinner join Frame such asIFrame.join(IFrame, JoinOn, Join), but the default Join isDefaultJoin, it will automatically map to a new Frame based on the same name
-
leftJoin
public <R,K> SDFrameImpl<R> leftJoin(IFrame<K> other, JoinOn<T,K> on, Join<T,K,R> join)
从接口复制的说明:SDFrameleft join Frame if connection conditions false, The callback value K for Join will be null, always keep T
-
leftJoin
public <R,K> SDFrameImpl<R> leftJoin(IFrame<K> other, JoinOn<T,K> on)
从接口复制的说明:SDFrameleft join Frame such asIFrame.leftJoin(IFrame, JoinOn, Join), but the default Join isDefaultJoin,
-
rightJoin
public <R,K> SDFrameImpl<R> rightJoin(IFrame<K> other, JoinOn<T,K> on, Join<T,K,R> join)
从接口复制的说明:SDFrameright join Frame if connection conditions false, The callback value T for Join will be null, always keep K
-
rightJoin
public <R,K> SDFrameImpl<R> rightJoin(IFrame<K> other, JoinOn<T,K> on)
从接口复制的说明:SDFrameright join Frame such asIFrame.rightJoin(IFrame, JoinOn, Join), but the default Join isDefaultJoin,
-
addRowNumberCol
public SDFrameImpl<FI2<T,Integer>> addRowNumberCol()
从接口复制的说明:SDFrameddd ordinal column- 指定者:
addRowNumberCol在接口中IFrame<T>- 指定者:
addRowNumberCol在接口中SDFrame<T>- 返回:
- FI2(T,Number)
-
addRowNumberCol
public SDFrameImpl<FI2<T,Integer>> addRowNumberCol(Sorter<T> sorter)
从接口复制的说明:SDFrameSort by comparator first, then add ordinal columns- 指定者:
addRowNumberCol在接口中IFrame<T>- 指定者:
addRowNumberCol在接口中SDFrame<T>- 参数:
sorter- the sort
-
addRowNumberCol
public SDFrameImpl<T> addRowNumberCol(SetFunction<T,Integer> set)
从接口复制的说明:SDFrameAdd a numbered column to a specific column- 指定者:
addRowNumberCol在接口中IFrame<T>- 指定者:
addRowNumberCol在接口中SDFrame<T>- 参数:
set- specific column
-
addRowNumberCol
public SDFrameImpl<T> addRowNumberCol(Sorter<T> sorter, SetFunction<T,Integer> set)
从接口复制的说明:SDFrameAdd a numbered column to a specific column- 指定者:
addRowNumberCol在接口中IFrame<T>- 指定者:
addRowNumberCol在接口中SDFrame<T>- 参数:
sorter- the sorterset- specific column
-
addRankCol
public SDFrameImpl<FI2<T,Integer>> addRankCol(Sorter<T> sorter)
从接口复制的说明:SDFrameAdd ranking columns by comparator Ranking logic, the same value means the Ranking is the same. This is different fromSDFrame.addRowNumberCol()- 指定者:
addRankCol在接口中IFrame<T>- 指定者:
addRankCol在接口中SDFrame<T>- 参数:
sorter- the ranking sorter
-
addRankCol
public SDFrame<T> addRankCol(Sorter<T> sorter, SetFunction<T,Integer> set)
从接口复制的说明:SDFrameAdd ranking column to a certain column by Comparator- 指定者:
addRankCol在接口中IFrame<T>- 指定者:
addRankCol在接口中SDFrame<T>- 参数:
sorter- the ranking comparatorset- certain column
-
count
public long count()
从接口复制的说明:IFrameget row count
-
group
public <K> SDFrame<FI2<K,List<T>>> group(java.util.function.Function<T,K> key)
从接口复制的说明:SDFrameGroup list
-
sortDesc
public SDFrameImpl<T> sortDesc(Comparator<T> comparator)
=========================== 排序相关 =====================================
-
sortDesc
public <R extends Comparable<? super R>> SDFrameImpl<T> sortDesc(java.util.function.Function<T,R> function)
从接口复制的说明:SDFrameDescending order by field
-
sortAsc
public SDFrameImpl<T> sortAsc(Comparator<T> comparator)
从接口复制的说明:SDFrameAscending order
-
sortAsc
public <R extends Comparable<R>> SDFrameImpl<T> sortAsc(java.util.function.Function<T,R> function)
从接口复制的说明:SDFrameAscending order
-
cutFirstRank
public SDFrame<T> cutFirstRank(Sorter<T> sorter, int n)
从接口复制的说明:SDFrameCut the top N rankings data The same value is considered to have the same ranking- 指定者:
cutFirstRank在接口中IFrame<T>- 指定者:
cutFirstRank在接口中SDFrame<T>- 参数:
sorter- the ranking sortern- the top n
-
cutFirst
public SDFrame<T> cutFirst(int n)
=========================== 截取相关 =====================================
-
cut
public SDFrame<T> cut(Integer startIndex, Integer endIndex)
从接口复制的说明:SDFramecut elements within the scope
-
distinct
public <R extends Comparable<R>> SDFrame<T> distinct(java.util.function.Function<T,R> function)
从接口复制的说明:SDFramedistinct by field value
-
distinct
public <R extends Comparable<R>> SDFrame<T> distinct(Comparator<T> comparator)
从接口复制的说明:SDFramedistinct by comparator
-
countDistinct
public long countDistinct(Comparator<T> comparator)
从接口复制的说明:SDFrameCalculate the quantity after deduplication- 指定者:
countDistinct在接口中IFrame<T>- 指定者:
countDistinct在接口中SDFrame<T>
-
countDistinct
public <R extends Comparable<R>> long countDistinct(java.util.function.Function<T,R> function)
从接口复制的说明:SDFrameCalculate the quantity after deduplication- 指定者:
countDistinct在接口中IFrame<T>- 指定者:
countDistinct在接口中SDFrame<T>
-
where
public SDFrame<T> where(java.util.function.Predicate<? super T> predicate)
=========================== 筛选相关 =====================================
-
whereNull
public <R> SDFrame<T> whereNull(java.util.function.Function<T,R> function)
从接口复制的说明:SDFrameFilter field values that are null, If it is string compatible, null and '' situations
-
whereNotNull
public <R> SDFrame<T> whereNotNull(java.util.function.Function<T,R> function)
从接口复制的说明:SDFrameFilter 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)
从接口复制的说明:SDFrameScreening within the interval,front closed and back closed. [start,end] [start,end]- 指定者:
whereBetween在接口中IFrame<T>- 指定者:
whereBetween在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereBetweenN
public <R extends Comparable<R>> SDFrame<T> whereBetweenN(java.util.function.Function<T,R> function, R start, R end)
从接口复制的说明:SDFrameScreening within the interval , front open and back open (start,end)- 指定者:
whereBetweenN在接口中IFrame<T>- 指定者:
whereBetweenN在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereBetweenR
public <R extends Comparable<R>> SDFrame<T> whereBetweenR(java.util.function.Function<T,R> function, R start, R end)
从接口复制的说明:SDFrameScreening within the interval , front open and back close (start,end]- 指定者:
whereBetweenR在接口中IFrame<T>- 指定者:
whereBetweenR在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereBetweenL
public <R extends Comparable<R>> SDFrame<T> whereBetweenL(java.util.function.Function<T,R> function, R start, R end)
从接口复制的说明:SDFrameScreening within the interval , front close and back open [start,end)- 指定者:
whereBetweenL在接口中IFrame<T>- 指定者:
whereBetweenL在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereNotBetween
public <R extends Comparable<R>> SDFrame<T> whereNotBetween(java.util.function.Function<T,R> function, R start, R end)
从接口复制的说明:SDFrameOut of range screening, (front closed and back closed) [start,end]- 指定者:
whereNotBetween在接口中IFrame<T>- 指定者:
whereNotBetween在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereNotBetweenN
public <R extends Comparable<R>> SDFrame<T> whereNotBetweenN(java.util.function.Function<T,R> function, R start, R end)
从接口复制的说明:SDFrameOut of range screening, (front open and back open) (start,end)- 指定者:
whereNotBetweenN在接口中IFrame<T>- 指定者:
whereNotBetweenN在接口中SDFrame<T>- 参数:
function- the filter fieldstart- start valueend- end value
-
whereIn
public <R> SDFrame<T> whereIn(java.util.function.Function<T,R> function, List<R> list)
从接口复制的说明:SDFrameThe query value is within the specified range
-
whereNotIn
public <R> SDFrame<T> whereNotIn(java.util.function.Function<T,R> function, List<R> list)
从接口复制的说明:SDFrameThe query value is outside the specified range- 指定者:
whereNotIn在接口中IFrame<T>- 指定者:
whereNotIn在接口中SDFrame<T>- 参数:
function- the filter fieldlist- specified range
-
whereTrue
public SDFrame<T> whereTrue(java.util.function.Predicate<T> predicate)
从接口复制的说明:SDFramefilter true by predicate
-
whereNotTrue
public SDFrame<T> whereNotTrue(java.util.function.Predicate<T> predicate)
从接口复制的说明:SDFramefilter not true by predicate- 指定者:
whereNotTrue在接口中IFrame<T>- 指定者:
whereNotTrue在接口中SDFrame<T>
-
whereEq
public <R> SDFrame<T> whereEq(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter equals
-
whereNotEq
public <R> SDFrame<T> whereNotEq(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter not equals- 指定者:
whereNotEq在接口中IFrame<T>- 指定者:
whereNotEq在接口中SDFrame<T>- 参数:
function- the fieldvalue- not need value
-
whereGt
public <R extends Comparable<R>> SDFrame<T> whereGt(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter Greater than value
-
whereGe
public <R extends Comparable<R>> SDFrame<T> whereGe(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter Greater than or equal to
-
whereLt
public <R extends Comparable<R>> SDFrame<T> whereLt(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter LESS than value
-
whereLe
public <R extends Comparable<R>> SDFrame<T> whereLe(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFilter less than or equal to
-
whereLike
public <R> SDFrame<T> whereLike(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFuzzy query contains specified values
-
whereNotLike
public <R> SDFrame<T> whereNotLike(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameFuzzy query not contains specified values- 指定者:
whereNotLike在接口中IFrame<T>- 指定者:
whereNotLike在接口中SDFrame<T>- 参数:
function- the fieldvalue- query value
-
whereLikeLeft
public <R> SDFrame<T> whereLikeLeft(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFrameprefix fuzzy query contains specified values- 指定者:
whereLikeLeft在接口中IFrame<T>- 指定者:
whereLikeLeft在接口中SDFrame<T>- 参数:
function- the fieldvalue- query value
-
whereLikeRight
public <R> SDFrame<T> whereLikeRight(java.util.function.Function<T,R> function, R value)
从接口复制的说明:SDFramesuffix fuzzy query contains specified values- 指定者:
whereLikeRight在接口中IFrame<T>- 指定者:
whereLikeRight在接口中SDFrame<T>- 参数:
function- the fieldvalue- query value
-
groupBySum
public <K,R extends Number> SDFrame<FI2<K,BigDecimal>> groupBySum(java.util.function.Function<T,K> key, NumberFunction<T,R> value)
=========================== 分组相关 =====================================- 指定者:
groupBySum在接口中IFrame<T>- 指定者:
groupBySum在接口中SDFrame<T>- 参数:
key- group fieldvalue- Aggregated field
-
groupBySum
public <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)
从接口复制的说明:SDFrameGroup summation- 指定者:
groupBySum在接口中IFrame<T>- 指定者:
groupBySum在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- Aggregated field
-
groupBySum
public <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)
从接口复制的说明:SDFrameGroup summation- 指定者:
groupBySum在接口中IFrame<T>- 指定者:
groupBySum在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldkey3- third level group fieldvalue- Aggregated field
-
groupByCount
public <K> SDFrame<FI2<K,Long>> groupByCount(java.util.function.Function<T,K> key)
从接口复制的说明:SDFrameGroup count- 指定者:
groupByCount在接口中IFrame<T>- 指定者:
groupByCount在接口中SDFrame<T>- 参数:
key- group 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)
从接口复制的说明:SDFrameGroup count- 指定者:
groupByCount在接口中IFrame<T>- 指定者:
groupByCount在接口中SDFrame<T>- 参数:
key- group fieldkey2- 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)
从接口复制的说明:SDFrameGroup count- 指定者:
groupByCount在接口中IFrame<T>- 指定者:
groupByCount在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldkey3- third level group field
-
groupBySumCount
public <K,R extends Number> SDFrame<FI3<K,BigDecimal,Long>> groupBySumCount(java.util.function.Function<T,K> key, NumberFunction<T,R> value)
从接口复制的说明:SDFrameGroup sum and count together- 指定者:
groupBySumCount在接口中IFrame<T>- 指定者:
groupBySumCount在接口中SDFrame<T>- 参数:
key- group fieldvalue- Aggregated field- 返回:
- FItem3(key, Sum, Count)
-
groupBySumCount
public <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)
从接口复制的说明:SDFrameGroup sum and count together- 指定者:
groupBySumCount在接口中IFrame<T>- 指定者:
groupBySumCount在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- Aggregated field- 返回:
- FItem4(key, ke2,Sum, Count)
-
groupByAvg
public <K,R extends Number> SDFrame<FI2<K,BigDecimal>> groupByAvg(java.util.function.Function<T,K> key, NumberFunction<T,R> value)
从接口复制的说明:SDFrameGroup average- 指定者:
groupByAvg在接口中IFrame<T>- 指定者:
groupByAvg在接口中SDFrame<T>- 参数:
key- group fieldvalue- Aggregated field
-
groupByAvg
public <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)
从接口复制的说明:SDFrameGroup average- 指定者:
groupByAvg在接口中IFrame<T>- 指定者:
groupByAvg在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- Aggregated field
-
groupByAvg
public <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)
从接口复制的说明:SDFrameGroup average- 指定者:
groupByAvg在接口中IFrame<T>- 指定者:
groupByAvg在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldkey3- third level group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max- 指定者:
groupByMax在接口中IFrame<T>- 指定者:
groupByMax在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max- 指定者:
groupByMax在接口中IFrame<T>- 指定者:
groupByMax在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max value- 指定者:
groupByMaxValue在接口中IFrame<T>- 指定者:
groupByMaxValue在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max value- 指定者:
groupByMaxValue在接口中IFrame<T>- 指定者:
groupByMaxValue在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- 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)
从接口复制的说明:SDFrameGroup min- 指定者:
groupByMin在接口中IFrame<T>- 指定者:
groupByMin在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup min- 指定者:
groupByMin在接口中IFrame<T>- 指定者:
groupByMin在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- 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)
从接口复制的说明:SDFrameGroup min value- 指定者:
groupByMinValue在接口中IFrame<T>- 指定者:
groupByMinValue在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup min value- 指定者:
groupByMinValue在接口中IFrame<T>- 指定者:
groupByMinValue在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- Aggregated field
-
groupByMaxMinValue
public <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)
从接口复制的说明:SDFrameGroup max and min value- 指定者:
groupByMaxMinValue在接口中IFrame<T>- 指定者:
groupByMaxMinValue在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max and min value- 指定者:
groupByMaxMinValue在接口中IFrame<T>- 指定者:
groupByMaxMinValue在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max and min element- 指定者:
groupByMaxMin在接口中IFrame<T>- 指定者:
groupByMaxMin在接口中SDFrame<T>- 参数:
key- group fieldvalue- 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)
从接口复制的说明:SDFrameGroup max and min element- 指定者:
groupByMaxMin在接口中IFrame<T>- 指定者:
groupByMaxMin在接口中SDFrame<T>- 参数:
key- group fieldkey2- secondary level group fieldvalue- Aggregated field
-
window
public WindowSDFrame<T> window(Window<T> window)
从接口复制的说明:SDFrameopen a window
-
window
public WindowSDFrame<T> window()
从接口复制的说明:SDFrameopen a empty window
-
fi2Frame
public <F> SDFrameImpl<T> fi2Frame(SDFrameImpl<FI2<T,F>> frame, SetFunction<T,F> setFunction)
-
overRowNumber
public SDFrameImpl<FI2<T,Integer>> overRowNumber(Window<T> overParam)
从接口复制的说明:SDFramerowNumber window function- 指定者:
overRowNumber在接口中SDFrame<T>- 参数:
overParam- window param
-
overRowNumber
public SDFrame<FI2<T,Integer>> overRowNumber()
从接口复制的说明:SDFramerowNumber window function- 指定者:
overRowNumber在接口中SDFrame<T>
-
overRowNumberS
public SDFrameImpl<T> overRowNumberS(SetFunction<T,Integer> setFunction, Window<T> overParam)
从接口复制的说明:SDFramerowNumber window function set the function result to the setFunction- 指定者:
overRowNumberS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window param
-
overRowNumberS
public SDFrame<T> overRowNumberS(SetFunction<T,Integer> setFunction)
从接口复制的说明:SDFramerowNumber window function set the function result to the setFunction- 指定者:
overRowNumberS在接口中SDFrame<T>- 参数:
setFunction- function result accept
-
overRank
public SDFrameImpl<FI2<T,Integer>> overRank(Window<T> overParam)
从接口复制的说明:SDFramerank window function
-
overRankS
public SDFrameImpl<T> overRankS(SetFunction<T,Integer> setFunction, Window<T> overParam)
从接口复制的说明:SDFramerank window function set the function result to the setFunction
-
overDenseRank
public SDFrameImpl<FI2<T,Integer>> overDenseRank(Window<T> overParam)
从接口复制的说明:SDFramedense rank window function- 指定者:
overDenseRank在接口中SDFrame<T>- 参数:
overParam- window param
-
overDenseRankS
public SDFrameImpl<T> overDenseRankS(SetFunction<T,Integer> setFunction, Window<T> overParam)
从接口复制的说明:SDFramedense rank window function set the function result to the setFunction- 指定者:
overDenseRankS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window param
-
overPercentRank
public SDFrameImpl<FI2<T,BigDecimal>> overPercentRank(Window<T> overParam)
从接口复制的说明:SDFramePercent rank window function- 指定者:
overPercentRank在接口中SDFrame<T>- 参数:
overParam- window param
-
overPercentRankS
public SDFrameImpl<T> overPercentRankS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam)
从接口复制的说明:SDFramePercent rank window function set the function result to the setFunction- 指定者:
overPercentRankS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window param
-
overCumeDist
public SDFrameImpl<FI2<T,BigDecimal>> overCumeDist(Window<T> overParam)
从接口复制的说明:SDFrameCume Dist window function- 指定者:
overCumeDist在接口中SDFrame<T>- 参数:
overParam- window param
-
overCumeDistS
public SDFrameImpl<T> overCumeDistS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam)
从接口复制的说明:SDFrameCume Dist window function set the function result to the setFunction- 指定者:
overCumeDistS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window param
-
overLag
public <F> SDFrameImpl<FI2<T,F>> overLag(Window<T> overParam, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameLag window function get the value of the first n rows of the current row
-
overLagS
public <F> SDFrame<T> overLagS(SetFunction<T,F> setFunction, Window<T> overParam, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameLag window function get the value of the first n rows of the current row
-
overLag
public <F> SDFrameImpl<FI2<T,F>> overLag(java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameLag window function get the value of the first n rows of the current row
-
overLagS
public <F> SDFrame<T> overLagS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameLag window function get the value of the first n rows of the current row
-
overLeadS
public <F> SDFrame<T> overLeadS(SetFunction<T,F> setFunction, Window<T> overParam, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFramelead window function get the value of the last n rows of the current row
-
overLead
public <F> SDFrameImpl<FI2<T,F>> overLead(Window<T> overParam, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFramelead window function get the value of the last n rows of the current row
-
overLead
public <F> SDFrameImpl<FI2<T,F>> overLead(java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFramelead window function get the value of the last n rows of the current row
-
overLeadS
public <F> SDFrame<T> overLeadS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFramelead window function get the value of the last n rows of the current row
-
overNthValue
public <F> SDFrameImpl<FI2<T,F>> overNthValue(Window<T> overParam, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameNthValue window function get the Nth row within the window range- 指定者:
overNthValue在接口中SDFrame<T>field- field valuen- 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)
从接口复制的说明:SDFrameNthValue window function get the Nth row within the window range- 指定者:
overNthValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramfield- field valuen- last n rows
-
overNthValue
public <F> SDFrameImpl<FI2<T,F>> overNthValue(java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameNthValue window function get the Nth row within the window range- 指定者:
overNthValue在接口中SDFrame<T>- 参数:
field- field valuen- last n rows
-
overNthValueS
public <F> SDFrameImpl<T> overNthValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field, int n)
从接口复制的说明:SDFrameNthValue window function get the Nth row within the window range- 指定者:
overNthValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptfield- field valuen- last n rows
-
overFirstValue
public <F> SDFrameImpl<FI2<T,F>> overFirstValue(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameFirstValue 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)
从接口复制的说明:SDFrameFirstValue window function get the first row within the window range- 指定者:
overFirstValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramfield- field value
-
overFirstValue
public <F> SDFrameImpl<FI2<T,F>> overFirstValue(java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameFirstValue 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)
从接口复制的说明:SDFrameFirstValue window function get the first row within the window range- 指定者:
overFirstValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptfield- field value
-
overLastValue
public <F> SDFrameImpl<FI2<T,F>> overLastValue(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameLastValue window function get the last row within the window range- 指定者:
overLastValue在接口中SDFrame<T>- 参数:
overParam- window paramfield- field value
-
overLastValueS
public <F> SDFrameImpl<T> overLastValueS(SetFunction<T,F> setFunction, Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameLastValue window function get the last row within the window range- 指定者:
overLastValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramfield- field value
-
overLastValue
public <F> SDFrameImpl<FI2<T,F>> overLastValue(java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameLastValue 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)
从接口复制的说明:SDFrameLastValue window function get the last row within the window range- 指定者:
overLastValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptfield- field value
-
overSum
public <F> SDFrameImpl<FI2<T,BigDecimal>> overSum(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameSum window function calculate the sum within the window range
-
overSum
public <F> SDFrameImpl<FI2<T,BigDecimal>> overSum(java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameSum window function calculate the sum within the window range
-
overSumS
public <F> SDFrameImpl<T> overSumS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameSum window function calculate the sum within the window range
-
overSumS
public <F> SDFrameImpl<T> overSumS(SetFunction<T,BigDecimal> setFunction, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameSum window function calculate the sum within the window range
-
overAvg
public <F> SDFrameImpl<FI2<T,BigDecimal>> overAvg(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameavg window function calculate the avg value within the window range
-
overAvg
public <F> SDFrameImpl<FI2<T,BigDecimal>> overAvg(java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameavg window function calculate the avg value within the window range
-
overAvgS
public <F> SDFrameImpl<T> overAvgS(SetFunction<T,BigDecimal> setFunction, Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameavg window function calculate the avg value within the window range
-
overAvgS
public <F> SDFrameImpl<T> overAvgS(SetFunction<T,BigDecimal> setFunction, java.util.function.Function<T,F> field)
从接口复制的说明:SDFrameavg window function calculate the avg value within the window range
-
overMaxValue
public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,F>> overMaxValue(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemax window function calculate the max value within the window range- 指定者:
overMaxValue在接口中SDFrame<T>- 参数:
overParam- window paramfield- field value
-
overMaxValue
public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,F>> overMaxValue(java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemax 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)
从接口复制的说明:SDFramemax window function calculate the max value within the window range- 指定者:
overMaxValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramfield- field value
-
overMaxValueS
public <F extends Comparable<? super F>> SDFrameImpl<T> overMaxValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemax window function calculate the max value within the window range- 指定者:
overMaxValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptfield- field value
-
overMinValue
public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,F>> overMinValue(Window<T> overParam, java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemin window function calculate the min value within the window range- 指定者:
overMinValue在接口中SDFrame<T>- 参数:
overParam- window paramfield- field value
-
overMinValue
public <F extends Comparable<? super F>> SDFrameImpl<FI2<T,F>> overMinValue(java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemin 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)
从接口复制的说明:SDFramemin window function calculate the min value within the window range- 指定者:
overMinValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramfield- field value
-
overMinValueS
public <F extends Comparable<? super F>> SDFrameImpl<T> overMinValueS(SetFunction<T,F> setFunction, java.util.function.Function<T,F> field)
从接口复制的说明:SDFramemin window function calculate the min value within the window range- 指定者:
overMinValueS在接口中SDFrame<T>- 参数:
setFunction- function result acceptfield- field value
-
overCount
public SDFrameImpl<FI2<T,Integer>> overCount(Window<T> overParam)
从接口复制的说明:SDFramecount window function calculate the count within the window range
-
overCount
public SDFrameImpl<FI2<T,Integer>> overCount()
从接口复制的说明:SDFramecount window function calculate the count within the window range
-
overCountS
public SDFrameImpl<T> overCountS(SetFunction<T,Integer> setFunction, Window<T> overParam)
从接口复制的说明:SDFramecount window function calculate the count within the window range- 指定者:
overCountS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window param
-
overCountS
public SDFrameImpl<T> overCountS(SetFunction<T,Integer> setFunction)
从接口复制的说明:SDFramecount 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)
从接口复制的说明:SDFrameNtile window function assign bucket numbers evenly to windows, starting from 1
-
overNtile
public SDFrameImpl<FI2<T,Integer>> overNtile(Window<T> overParam, int n)
从接口复制的说明:SDFrameNtile window function assign bucket numbers evenly to windows, starting from 1
-
overNtileS
public SDFrameImpl<T> overNtileS(SetFunction<T,Integer> setFunction, Window<T> overParam, int n)
从接口复制的说明:SDFrameNtile window function assign bucket numbers evenly to windows, starting from 1- 指定者:
overNtileS在接口中SDFrame<T>- 参数:
setFunction- function result acceptoverParam- window paramn- size of buckets
-
overNtileS
public SDFrameImpl<T> overNtileS(SetFunction<T,Integer> setFunction, int n)
从接口复制的说明:SDFrameNtile window function assign bucket numbers evenly to windows, starting from 1- 指定者:
overNtileS在接口中SDFrame<T>- 参数:
setFunction- function result acceptn- 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)
从接口复制的说明:SDFrameCalculate 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 groupingC- type of collection within the group The set supplemented by @ return- 参数:
groupDim- Dimension fields for groupingcollectDim- Data fields collected within the groupallDim- All dimensions that need to be displayed within the groupgetEmptyObject- 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)
从接口复制的说明:SDFrameSummarize all collectDim values, calculate the difference between them, and then add the missing difference to the Frame through getEmptyObject
-
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)
从接口复制的说明:SDFramesuch asIFrame.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
-
returnThis
protected SDFrameImpl<T> returnThis(java.util.stream.Stream<T> stream)
-
returnThis
protected SDFrameImpl<T> returnThis(List<T> dataList)
-
returnDF
protected <R> SDFrameImpl<R> returnDF(List<R> dataList)
-
-