| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
Barrier<B>
A Barrier is any step that requires all left traversers to be processed prior to emitting result traversers to the right. 
 | 
interface  | 
LocalBarrier<S>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DedupGlobalStep<S>  | 
class  | 
RangeGlobalStep<S>  | 
class  | 
SampleGlobalStep<S>  | 
class  | 
TailGlobalStep<S>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CountGlobalStep<S>  | 
class  | 
FoldStep<S,E>  | 
class  | 
GroupCountStep<S,E>  | 
class  | 
GroupStep<S,K,V>  | 
class  | 
GroupStepV3d0<S,K,V,R>
Deprecated. 
 
As of release 3.1.0, replaced by  
GroupStep. | 
class  | 
LambdaCollectingBarrierStep<S>  | 
class  | 
MaxGlobalStep<S extends Number>  | 
class  | 
MeanGlobalStep<S extends Number,E extends Number>  | 
class  | 
MinGlobalStep<S extends Number>  | 
class  | 
NoOpBarrierStep<S>  | 
class  | 
OrderGlobalStep<S,C extends Comparable>  | 
class  | 
SumGlobalStep<S extends Number>  | 
class  | 
TreeStep<S>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AggregateStep<S>  | 
class  | 
SideEffectCapStep<S,E>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CollectingBarrierStep<S>  | 
class  | 
ProfileStep<S>  | 
class  | 
ReducingBarrierStep<S,E>  | 
class  | 
SupplyingBarrierStep<S,E>  | 
Copyright © 2013–2018 Apache Software Foundation. All rights reserved.