Search Java Classes and Packages
#Cascading.flow Classes and Interfaces - 233 results found.
| 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 | |