static <K,V> CombineFn<K,V> |
CombineFn.aggregatorFactory(CombineFn.AggregatorFactory<V> aggregator)
|
static <K,V1,V2> CombineFn<K,Pair<V1,V2>> |
CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1,
CombineFn.AggregatorFactory<V2> a2)
|
static <K,V1,V2> CombineFn<K,Pair<V1,V2>> |
CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1,
CombineFn.AggregatorFactory<V2> a2)
|
static <K,A,B,C,D> CombineFn<K,Tuple4<A,B,C,D>> |
CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3,
CombineFn.AggregatorFactory<D> a4)
|
static <K,A,B,C,D> CombineFn<K,Tuple4<A,B,C,D>> |
CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3,
CombineFn.AggregatorFactory<D> a4)
|
static <K,A,B,C,D> CombineFn<K,Tuple4<A,B,C,D>> |
CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3,
CombineFn.AggregatorFactory<D> a4)
|
static <K,A,B,C,D> CombineFn<K,Tuple4<A,B,C,D>> |
CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3,
CombineFn.AggregatorFactory<D> a4)
|
static <K,A,B,C> CombineFn<K,Tuple3<A,B,C>> |
CombineFn.tripAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3)
|
static <K,A,B,C> CombineFn<K,Tuple3<A,B,C>> |
CombineFn.tripAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3)
|
static <K,A,B,C> CombineFn<K,Tuple3<A,B,C>> |
CombineFn.tripAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3)
|
static <K> CombineFn<K,TupleN> |
CombineFn.tupleAggregator(CombineFn.AggregatorFactory<?>... factories)
|