Name | Description | Type | Package | Framework |
AggregatorEveryStage | Class | cascading.flow.stream.element | Cascading | |
AndElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
AnnotatedDecoratedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
AnnotatedGraph | Interface | cascading.flow.planner.graph | Cascading | |
AnnotateGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
AnnotationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
ApplyAssertionLevelTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
ApplyDebugLevelTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
AssemblyPlanner | This allows for new languages or frameworks that may require additional meta-data from the underlying platform or environment. | Interface | cascading.flow | Cascading |
AssemblyPlanner .Context | Interface | cascading.flow.AssemblyPlanner | Cascading | |
Asserted | Class | cascading.flow.planner.iso.assertion | Cascading | |
BaseAnnotatedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
BaseElementGraph | Class | cascading.flow.planner.graph | Cascading | |
BaseFlow | Class | cascading.flow | Cascading | |
BaseFlow .FlowHolder | Class | cascading.flow.BaseFlow | Cascading | |
BaseFlowNode | Class | cascading.flow.planner | Cascading | |
BaseFlowStep | Class FlowStep is an internal representation of a given Job to be executed on a remote cluster. | Class | cascading.flow.planner | Cascading |
BaseProcessGraph | Class | cascading.flow.planner.process | Cascading | |
BlockingHashJoinAnnotator | Class | cascading.flow.planner.rule.annotator | Cascading | |
BlockingMode | Class | cascading.flow.stream.annotations | Cascading | |
BoundariesElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
BoundaryElementFactory | Class | cascading.flow.planner.rule.transformer | Cascading | |
BoundaryStage | Class | cascading.flow.stream.element | Cascading | |
BoundedElementMultiGraph | Class | cascading.flow.planner.graph | Cascading | |
BufferAfterEveryAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
BufferAfterEveryExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
BufferEveryWindow | Class | cascading.flow.stream.element | Cascading | |
CloseReducingDuct | Class | cascading.flow.stream.duct | Cascading | |
ConsecutiveTapsExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
ContractedGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
ContractedTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
DecoratedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
DualStreamedAccumulatedExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
Duct | Class | cascading.flow.stream.duct | Cascading | |
DuctException | Class | cascading.flow.stream.duct | Cascading | |
DuctGraph | Class | cascading.flow.stream.duct | Cascading | |
DuctGraph .Ordinal | Class | cascading.flow.stream.duct.DuctGraph | Cascading | |
EachStage | Class | cascading.flow.stream.element | Cascading | |
ElementAnnotation | Class | cascading.flow.planner.iso | Cascading | |
ElementCapture | Class | cascading.flow.planner.iso.expression | Cascading | |
ElementDirectedGraph | Class | cascading.flow.planner.graph | Cascading | |
ElementDuct | Interface | cascading.flow.stream.element | Cascading | |
ElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
ElementFactory | Interface | cascading.flow.planner.iso.transformer | Cascading | |
ElementFlowProcess | Class | cascading.flow.stream.element | Cascading | |
ElementGraph | An element graph represents an assembly of Pipe instances bound to source and sink Typically an element graph is fed to a FlowPlanner which in return creates | Interface | cascading.flow.planner.graph | Cascading |
ElementGraphException | the Cascading internal "graph" representation. | Class | cascading.flow.planner | Cascading |
ElementGraphs | Class | cascading.flow.planner.graph | Cascading | |
ElementMaskSubGraph | Class | cascading.flow.planner.graph | Cascading | |
ElementMultiGraph | Class | cascading.flow.planner.graph | Cascading | |
ElementStage | Class | cascading.flow.stream.element | Cascading | |
ElementSubGraph | Class | cascading.flow.planner.graph | Cascading | |
EveryAfterBufferAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
EveryAfterBufferExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
EveryStage | Class | cascading.flow.stream.element | Cascading | |
ExecAction | Class | cascading.flow.planner.rule | Cascading | |
Expression | Interface | cascading.flow.planner.iso.expression | Cascading | |
ExpressionGraph | Class | cascading.flow.planner.iso.expression | Cascading | |
ExpressionGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
ExpressionRulePartitioner | sub-graphs as partitions. | Class | cascading.flow.planner.rule.partitioner | Cascading |
ExpressionSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
Extent | Enum Extent provides simple markers for the head and tail of an ElementGraph FlowElement graph. | Class | cascading.flow.planner.graph | Cascading |
FilterEachStage | Class | cascading.flow.stream.element | Cascading | |
Flow | A Flow is a logical unit of work declared by an assembly of Pipe instances connected to source and sink Tap instances. | Interface | cascading.flow | Cascading |
FlowConnector | See the FlowDef class for a fluent way to define a new Flow. | Class | cascading.flow | Cascading |
FlowConnectorProps | The class FlowConnectorProps is a fluent helper class for setting FlowConnector specific properties through the FlowConnector constructor. | Class | cascading.flow | Cascading |
FlowDef | This allows for ad-hoc building of Flow data and meta-data, like tags. | Class | cascading.flow | Cascading |
FlowDescriptors | Constants to be used as key in Flow#getFlowDescriptor. | Interface | cascading.flow | Cascading |
FlowElement | for users to interact with these methods directly. | Interface | cascading.flow | Cascading |
FlowElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
FlowElementGraph | Class ElementGraph represents the executable FlowElement graph. | Class | cascading.flow.planner.graph | Cascading |
FlowElements | Class | cascading.flow | Cascading | |
FlowException | FlowException instances are thrown on errors when executing a Flow. | Class | cascading.flow | Cascading |
FlowListener | Any RuntimeException thrown from any of the listener methods will force the given flow to stop by calling Flow. | Interface | cascading.flow | Cascading |
FlowNode | FlowStep and may have many siblings within the FlowStep. | Interface | cascading.flow | Cascading |
FlowNodeGraph | Class | cascading.flow.planner.process | Cascading | |
FlowNodeGraph .FlowNodeComparator | This should have no effect on submission and execution priority as all FlowNodes are submitted simultaneously. | Class | cascading.flow.planner.process.FlowNodeGraph | Cascading |
FlowPlanner | This planner support tracing execution of each rule. | Class | cascading.flow.planner | Cascading |
FlowProcess | FlowProcess implementations provide a call-back interface into the current computing system. | Class | cascading.flow | Cascading |
FlowProcess .NullFlowProcess | Class | cascading.flow.FlowProcess | Cascading | |
FlowProcessWrapper | Class | cascading.flow | Cascading | |
FlowProps | Class | cascading.flow | Cascading | |
FlowRuntimeProps | These properties apply to the cluster or remote side of the Flow execution. | Class | cascading.flow | Cascading |
Flows | Flows is a utility helper class. | Class | cascading.flow | Cascading |
FlowSession | FlowSession implementations provide a call-back interface into the current flow management system, if any. | Class | cascading.flow | Cascading |
FlowSkipIfSinkExists | true if the Flow sink exists, regardless if it is stale or not. | Class | cascading.flow | Cascading |
FlowSkipIfSinkNotStale | true if the Flow sink exists and is not stale in relation to the Flow sources. | Class | cascading.flow | Cascading |
FlowSkipStrategy | be skipped when executed in a Cascade. | Interface | cascading.flow | Cascading |
FlowStep | planning, pipe assemblies are broken down into "steps" and encapsulated in this class. | Interface | cascading.flow | Cascading |
FlowStepGraph | Class | cascading.flow.planner.process | Cascading | |
FlowStepJob | Class | cascading.flow.planner | Cascading | |
FlowStepListener | Interface | cascading.flow | Cascading | |
FlowStepStrategy | The FlowStepStrategy interface allows for on the fly customization of FlowStep configuration values before they are submitted to the underlying platform. | Interface | cascading.flow | Cascading |
Fork | Class | cascading.flow.stream.duct | Cascading | |
FunctionEachStage | Class | cascading.flow.stream.element | Cascading | |
Gate | Class | cascading.flow.stream.duct | Cascading | |
GraphAssert | Class | cascading.flow.planner.iso.assertion | Cascading | |
GraphAssert .AssertionType | Class | cascading.flow.planner.iso.assertion.GraphAssert | Cascading | |
GraphFinder | Class | cascading.flow.planner.iso.finder | Cascading | |
GraphFinderException | Class | cascading.flow.planner.iso.finder | Cascading | |
GraphPartitioner | Class | cascading.flow.planner.iso.subgraph | Cascading | |
GraphResult | Class | cascading.flow.planner.iso | Cascading | |
GraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
GroupAssertionEveryStage | Class | cascading.flow.stream.element | Cascading | |
Grouping | Class | cascading.flow.stream.duct | Cascading | |
GroupingSpliceGate | Class | cascading.flow.stream.element | Cascading | |
GroupOrMergeElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
GroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
HashJoinBlockingHashJoinAnnotator | Class | cascading.flow.planner.rule.annotator | Cascading | |
IgnoreAnnotationsHashSet | Class | cascading.flow.planner.graph | Cascading | |
IgnoresAnnotationsElementGraph | Class | cascading.flow.planner.graph | Cascading | |
IncludeRemainderSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
InsertionGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
InsertionGraphTransformer .Insertion | Class | cascading.flow.planner.iso.transformer.InsertionGraphTransformer | Cascading | |
IntermediateTapElementFactory | Class | cascading.flow.planner.rule.transformer | Cascading | |
IORole | Enum IORole specifies how a FlowElement will be used during streaming. | Class | cascading.flow.stream.graph | Cascading |
LoneGroupAssert | Verifies that there are not only GroupAssertions following any given Group instance. | Class | cascading.flow.planner.rule.assertion | Cascading |
LoneGroupExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
Match | Class | cascading.flow.planner.iso.finder | Cascading | |
MemoryCoGroupClosure | Class | cascading.flow.stream.element | Cascading | |
MemoryCoGroupGate | Class | cascading.flow.stream.element | Cascading | |
MemoryHashJoinGate | Class | cascading.flow.stream.element | Cascading | |
MemorySpliceGate | Class | cascading.flow.stream.element | Cascading | |
MergeStage | Class | cascading.flow.stream.element | Cascading | |
MissingGroupAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
MissingGroupExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
MultiTapGroupExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
MutateGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
NoCoGroupJoinTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NodeStreamGraph | Class | cascading.flow.stream.graph | Cascading | |
NoGroupJoinMergeBoundaryTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NoGroupJoinTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NoGroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NoMergeTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NonBlockedBlockedJoinAnnotatorExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
NonBlockedBlockedJoinExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NonBlockedBlockedJoinJoinAnnotatorExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
NonBlockedBlockedJoinJoinExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NonSafeAndSplitAndSyncPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NonSafeOperationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
NoOpPipeExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
NoOpPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
NotElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
OnlyPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
OpenDuct | Class | cascading.flow.stream.duct | Cascading | |
OpenReducingDuct | Class | cascading.flow.stream.duct | Cascading | |
OperationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
OperatorStage | Class | cascading.flow.stream.element | Cascading | |
OrdinalScopeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
OrElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
Partitions | Class | cascading.flow.planner.iso.subgraph | Cascading | |
PathScopeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
PathScopeExpression .Mode | Class | cascading.flow.planner.iso.expression.PathScopeExpression | Cascading | |
PlannerContext | Class | cascading.flow.planner | Cascading | |
PlannerException | For debugging purposes, the PlannerException holds a copy of the internal job representation which can be written out to disk and visualized with tools that support the | Class | cascading.flow.planner | Cascading |
PlannerInfo | Class | cascading.flow.planner | Cascading | |
PlannerLevelElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
PlannerLevelExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
PlannerLevelPipeExpressionGraph | Class | cascading.flow.planner.iso.expression | Cascading | |
PlanPhase | Class | cascading.flow.planner.rule | Cascading | |
PlatformInfo | Class | cascading.flow.planner | Cascading | |
ProcessEdge | Class | cascading.flow.planner.process | Cascading | |
ProcessFlow | Use this class to allow custom Riffle jobs to participate in the Cascade scheduler. | Class | cascading.flow.process | Cascading |
ProcessFlowStep | Class | cascading.flow.process | Cascading | |
ProcessGraph | Interface | cascading.flow.planner.process | Cascading | |
ProcessGraphs | Class | cascading.flow.planner.process | Cascading | |
ProcessLevel | Class | cascading.flow.planner.rule | Cascading | |
ProcessModel | Interface | cascading.flow.planner.process | Cascading | |
ProcessModels | Class | cascading.flow.planner.process | Cascading | |
RecursiveGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
Reducing | Interface | cascading.flow.stream.duct | Cascading | |
RemoveBranchGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
RemoveNoOpPipeTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
ReplaceGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
ResultTree | Class | cascading.flow.planner.rule.util | Cascading | |
ResultTree .Delegate | Class | cascading.flow.planner.rule.util.ResultTree | Cascading | |
ResultTree .Path | Class | cascading.flow.planner.rule.util.ResultTree | Cascading | |
Rule | Interface | cascading.flow.planner.rule | Cascading | |
RuleAnnotationTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
RuleAssert | The RuleAssert class is responsible for asserting the structure of a element graph. | Class | cascading.flow.planner.rule | Cascading |
RuleContractedTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
RuleExec | Class | cascading.flow.planner.rule | Cascading | |
RuleExpression | A RuleExpression describes where a Rule is applied in an element graph. | Class | cascading.flow.planner.rule | Cascading |
RuleInsertionTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
RuleMode | Class | cascading.flow.planner.rule | Cascading | |
RulePartitioner | The RulePartitioner class is responsible for partitioning an element graph into smaller sub-graphs. | Class | cascading.flow.planner.rule | Cascading |
RulePartitioner .PartitionSource | Partition a given child into more children, removing the original child. | Class | cascading.flow.planner.rule.RulePartitioner | Cascading |
RuleRegistry | RuleRegistry contains all planner rules for a given platform. | Class | cascading.flow.planner.rule | Cascading |
RuleRegistrySet | applied via the FlowPlanner to the given assembly. | Class | cascading.flow.planner.rule | Cascading |
RuleRegistrySet .Select | Class | cascading.flow.planner.rule.RuleRegistrySet | Cascading | |
RuleRemoveBranchTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
RuleReplaceTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
RuleResult | Class | cascading.flow.planner.rule | Cascading | |
RuleResult .ResultStatus | Class | cascading.flow.planner.rule.RuleResult | Cascading | |
RuleSetExec | Class | cascading.flow.planner.rule | Cascading | |
RuleTransformer | The RuleTransformer class is responsible for transforming an element graph into a new graph. | Class | cascading.flow.planner.rule | Cascading |
Scope | Class | cascading.flow.planner | Cascading | |
Scope .Kind | Class | cascading.flow.planner.Scope | Cascading | |
ScopeExpression | If ScopeExpression is the only edge, the ScopeExpression. | Class | cascading.flow.planner.iso.expression | Cascading |
ScopeExpression .Applies | Class | cascading.flow.planner.iso.expression.ScopeExpression | Cascading | |
SearchOrder | Class | cascading.flow.planner.iso.finder | Cascading | |
SinkStage | Class | cascading.flow.stream.element | Cascading | |
SliceCounters | Class | cascading.flow | Cascading | |
SourceStage | Class | cascading.flow.stream.element | Cascading | |
SparseTupleComparator | Class | cascading.flow.stream.util | Cascading | |
SpliceGate | Class | cascading.flow.stream.element | Cascading | |
SplicePipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
SplitBeforeEveryAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
SplitBeforeEveryExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
Stage | Class | cascading.flow.stream.duct | Cascading | |
StepCounters | Enum StepCounters lists all countersEnum Constant Summary | Class | cascading.flow | Cascading |
StreamGraph | Under some circumstances it may make sense to see the actual graph plan. | Class | cascading.flow.stream.graph | Cascading |
StreamMode | Class | cascading.flow.stream.annotations | Cascading | |
SubGraphIterator | Interface | cascading.flow.planner.iso.subgraph | Cascading | |
SubGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
SyncPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
TapGroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
TapOrBoundaryElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
TraceWriter | Class | cascading.flow.planner.rule.util | Cascading | |
Transformed | Class | cascading.flow.planner.iso.transformer | Cascading | |
TrapException | TrapException is a pass through exception allowing trap io failures to propagate past upstream traps. | Class | cascading.flow.stream | Cascading |
TrapHandler | Class | cascading.flow.stream.element | Cascading | |
TypeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
TypeExpression .Topo | Class | cascading.flow.planner.iso.expression.TypeExpression | Cascading | |
UniquePathGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
UniquePathRulePartitioner | sub-graphs as initial partitions, then will partition the resulting graph into a unique sub-graph for each unique path between the head and tail of the graph. | Class | cascading.flow.planner.rule.partitioner | Cascading |
UniquePathSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
UnsupportedPlanException | Class | cascading.flow.planner.rule | Cascading | |
ValueAssertionEachStage | Class | cascading.flow.stream.element | Cascading | |
WholeGraphNodePartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |
WholeGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
WholeGraphRulePartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |
WholeGraphStepPartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |