| 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 | 
|---|---|
static class  | 
ProfilingAware.ProfiledBarrier
A helper class which holds a  
Barrier and it's related ProfileStep so that the latter can have
 its timer started and stopped appropriately. | 
| 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  | 
LambdaCollectingBarrierStep<S>  | 
class  | 
MaxGlobalStep<S extends Comparable>  | 
class  | 
MeanGlobalStep<S extends Number,E extends Number>  | 
class  | 
MinGlobalStep<S extends Comparable>  | 
class  | 
NoOpBarrierStep<S>  | 
class  | 
OrderGlobalStep<S,C extends Comparable>  | 
class  | 
SumGlobalStep<S extends Number>  | 
class  | 
TreeStep<S>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AggregateGlobalStep<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–2021 Apache Software Foundation. All rights reserved.