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 |
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–2020 Apache Software Foundation. All rights reserved.