A B C D E F G H I J K L M N O P Q R S T U V W X Z 

A

acceptsAll() - Method in class cascading.flow.planner.iso.expression.PathScopeExpression
 
acceptsAll() - Method in class cascading.flow.planner.iso.expression.ScopeExpression
 
add(ElementGraph) - Method in class cascading.flow.planner.graph.IgnoreAnnotationsHashSet
 
add(Tuple) - Method in class cascading.tuple.collect.SpillableTupleList
Method add will add the given Tuple to this list.
add(Comparable) - Method in class cascading.tuple.Tuple
Method add adds a new element value to this instance.
add(Object) - Method in class cascading.tuple.Tuple
Method add adds a new element value to this instance.
add(TupleEntry) - Method in class cascading.tuple.TupleEntryCollector
Method add inserts the given TupleEntry into the outgoing stream.
add(Tuple) - Method in class cascading.tuple.TupleEntryCollector
Method add inserts the given Tuple into the outgoing stream.
add(TupleEntry) - Method in class cascading.tuple.TupleEntrySchemeCollector
 
add(Tuple) - Method in class cascading.tuple.TupleEntrySchemeCollector
 
addAll(Collection<? extends Tuple>) - Method in class cascading.tuple.collect.SpillableTupleList
 
addAll(Object...) - Method in class cascading.tuple.Tuple
Method addAll adds all given values to this instance.
addAll(Tuple) - Method in class cascading.tuple.Tuple
Method addAll adds all the element values of the given Tuple instance to this instance.
addAll(MultiMap<C, K, V>) - Method in class cascading.util.MultiMap
 
addAll(K, V...) - Method in class cascading.util.MultiMap
 
addAll(K, Collection<V>) - Method in class cascading.util.MultiMap
 
addAnnotation(ElementAnnotation) - Method in class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
addAnnotationExclude(Enum) - Method in class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
addApplicationFramework(Map<Object, Object>, String) - Static method in class cascading.property.AppProps
Adds a framework "name:version" string to the property set and to the System properties.
addApplicationTag(Map<Object, Object>, String) - Static method in class cascading.property.AppProps
 
addAssemblyPlanner(AssemblyPlanner) - Method in class cascading.flow.FlowDef
Method addAssemblyPlanner adds new AssemblyPlanner instances to be evaluated.
addBoolean(boolean) - Method in class cascading.tuple.Tuple
Method addBoolean adds a new element value to this instance.
addCheckpoint(String, Tap) - Method in class cascading.flow.FlowDef
Method addCheckpoint adds a new named checkpoint Tap for use in the resulting Flow.
addCheckpoint(Checkpoint, Tap) - Method in class cascading.flow.FlowDef
Method addCheckpoint adds a new checkpoint Tap named after the given Checkpoint for use in the resulting Flow.
addCheckpoints(Map<String, Tap>) - Method in class cascading.flow.FlowDef
Method addCheckpoints adds a Map of the names and Tap pairs.
addChildTransform(Transformed) - Method in class cascading.flow.planner.iso.assertion.Asserted
 
addChildTransform(Transformed) - Method in class cascading.flow.planner.iso.transformer.Transformed
 
addCodec(String) - Method in class cascading.tuple.collect.SpillableProps
Method addCodec adds a codec class names to use.
addCodecs(List<String>) - Method in class cascading.tuple.collect.SpillableProps
Method addCodecs adds a list of possible codec class names to use.
addDefaultElementFactory(String, ElementFactory) - Method in class cascading.flow.planner.rule.RuleRegistry
Adds the named elementFactory if it does not already exist.
addDescription(String) - Method in class cascading.flow.FlowDef
Method addDescription adds a user readable description to the flowDescriptor.
addDescription(String, String) - Method in class cascading.flow.FlowDef
Method addDescription adds a description to the flowDescriptor.
addDescriptions(Map<String, String>) - Method in class cascading.flow.FlowDef
Method addProperties adds all properties in the given map in order to the flowDescriptor.
addDouble(double) - Method in class cascading.tuple.Tuple
Method addDouble adds a new element value to this instance.
addEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
addEdge(FlowElement, FlowElement, Scope) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
addEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
addEdge(FlowElement, FlowElement, Scope) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
addEdge(FlowElement, FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
addEdge(FlowElement, FlowElement, Scope) - Method in interface cascading.flow.planner.graph.ElementGraph
 
addEdge(Process, Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
addEdge(Process, Process, ProcessEdge) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
addEdge(Process, Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
addEdge(Process, Process, ProcessEdge) - Method in interface cascading.flow.planner.process.ProcessGraph
 
addEdgeAnnotation(Enum) - Method in class cascading.flow.planner.process.ProcessEdge
 
addEdgeAnnotation(String, String) - Method in class cascading.flow.planner.process.ProcessEdge
 
addElementFactory(String, ElementFactory) - Method in class cascading.flow.planner.rule.RuleRegistry
 
addExclusions(ElementGraph) - Method in class cascading.flow.planner.iso.transformer.AnnotateGraphTransformer
 
addExclusions(E) - Method in class cascading.flow.planner.iso.transformer.RecursiveGraphTransformer
 
addFloat(float) - Method in class cascading.tuple.Tuple
Method addFloat adds a new element value to this instance.
addFlow(Flow) - Method in class cascading.cascade.CascadeDef
Method addFlow adds a new Flow instance that is intended to participate in a Cascade.
addFlows(Flow...) - Method in class cascading.cascade.CascadeDef
Method addFlows adds many new Flow instances intended to participate in a Cascade.
addFlows(Collection<Flow>) - Method in class cascading.cascade.CascadeDef
Method addFlows adds many new Flow instances intended to participate in a Cascade.
addFlowStats(FlowStats) - Method in class cascading.stats.CascadeStats
Method addFlowStats add a child Flow {2link FlowStats} instance.
addFramework(String) - Method in class cascading.property.AppProps
Method addFramework adds a new framework name to the list of frameworks used.
addFramework(String, String) - Method in class cascading.property.AppProps
Method addFramework adds a new framework name and its version to the list of frameworks used.
addFrameworks(String...) - Method in class cascading.property.AppProps
Method addFrameworks adds new framework names to the list of frameworks used.
addGroup(Group) - Method in class cascading.flow.planner.BaseFlowStep
 
addGroups(Collection<Group>) - Method in class cascading.flow.planner.BaseFlowStep
 
addHead(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
addHook(ShutdownUtil.Hook) - Static method in class cascading.util.ShutdownUtil
 
addInteger(int) - Method in class cascading.tuple.Tuple
Method addInteger adds a new element value to this instance.
addListener(CascadeListener) - Method in class cascading.cascade.BaseCascade
 
addListener(CascadeListener) - Method in interface cascading.cascade.Cascade
 
addListener(FlowListener) - Method in class cascading.flow.BaseFlow
 
addListener(FlowListener) - Method in interface cascading.flow.Flow
Method addListener registers the given flowListener with this instance.
addListener(FlowStepListener) - Method in interface cascading.flow.FlowStep
Method addListener registers the given FlowStepListener with this instance.
addListener(FlowStepListener) - Method in class cascading.flow.planner.BaseFlowStep
 
addListener(StatsListener) - Method in class cascading.stats.CascadingStats
 
addLogCounter(Enum) - Method in class cascading.flow.FlowRuntimeProps
Method addLogCounter adds a new counter to be logged when a cluster side slice completes.
addLogCounter(String, String) - Method in class cascading.flow.FlowRuntimeProps
Method addLogCounter adds a new counter to be logged when a cluster side slice completes.
addLong(long) - Method in class cascading.tuple.Tuple
Method addLong adds a new element value to this instance.
addNodeStats(FlowNodeStats) - Method in class cascading.stats.FlowStepStats
 
addParentAnnotations(ElementGraph) - Method in class cascading.flow.planner.graph.BaseAnnotatedElementGraph
 
addParentAnnotations(ElementGraph) - Method in class cascading.flow.planner.graph.BoundedElementMultiGraph
 
addPath(Duct, Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
addPath(Duct, int, Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
addPlannerProperties() - Method in class cascading.flow.BaseFlow
 
addPriorNames(Scope, Scope) - Method in class cascading.flow.planner.Scope
 
addProcessAnnotation(Enum) - Method in class cascading.flow.planner.BaseFlowNode
 
addProcessAnnotation(String, String) - Method in class cascading.flow.planner.BaseFlowNode
 
addProcessAnnotation(Enum) - Method in class cascading.flow.planner.BaseFlowStep
 
addProcessAnnotation(String, String) - Method in class cascading.flow.planner.BaseFlowStep
 
addProcessAnnotation(Enum) - Method in interface cascading.flow.planner.process.ProcessModel
 
addProcessAnnotation(String, String) - Method in interface cascading.flow.planner.process.ProcessModel
 
addPropertiesTo(Properties) - Method in class cascading.cascade.CascadeProps
 
addPropertiesTo(Properties) - Method in class cascading.flow.FlowConnectorProps
 
addPropertiesTo(Properties) - Method in class cascading.flow.FlowProps
 
addPropertiesTo(Properties) - Method in class cascading.flow.FlowRuntimeProps
 
addPropertiesTo(Properties) - Method in class cascading.pipe.assembly.AggregateByProps
 
addPropertiesTo(Properties) - Method in class cascading.pipe.assembly.UniqueProps
 
addPropertiesTo(Properties) - Method in class cascading.property.AppProps
 
addPropertiesTo(Properties) - Method in class cascading.property.Props
 
addPropertiesTo(Properties) - Method in class cascading.tap.partition.PartitionTapProps
 
addPropertiesTo(Properties) - Method in class cascading.tap.TrapProps
 
addPropertiesTo(Properties) - Method in class cascading.tuple.collect.SpillableProps
 
addPropertiesTo(Properties) - Method in class cascading.tuple.TupleEntrySchemeIteratorProps
 
addRule(Rule) - Method in class cascading.flow.planner.rule.RuleRegistry
 
addShort(short) - Method in class cascading.tuple.Tuple
Method addShort adds a new element value to this instance.
addSink(String, Tap) - Method in class cascading.flow.FlowDef
Method addSink adds a new named sink Tap for use in the resulting Flow.
addSink(Pipe, Tap) - Method in class cascading.flow.FlowDef
Method addSink adds a new sink Tap named after the given Pipe for use in the resulting Flow.
addSink(String, Tap) - Method in class cascading.flow.planner.BaseFlowStep
 
addSinks(Map<String, Tap>) - Method in class cascading.flow.FlowDef
Method addSinks adds a Map of the named and Tap pairs.
addSinks(BaseFlowStep, ElementGraph, Set<Tap>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
addSource(String, Tap) - Method in class cascading.flow.FlowDef
Method addSource adds a new named source Tap for use in the resulting Flow.
addSource(Pipe, Tap) - Method in class cascading.flow.FlowDef
Method addSource adds a new source Tap named after the given Pipe for use in the resulting Flow.
addSource(String, Tap) - Method in class cascading.flow.planner.BaseFlowStep
 
addSources(Map<String, Tap>) - Method in class cascading.flow.FlowDef
Method addSources adds a map of name and Tap pairs.
addSources(BaseFlowStep, ElementGraph, Set<Tap>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
addStepListener(FlowStepListener) - Method in class cascading.flow.BaseFlow
 
addStepListener(FlowStepListener) - Method in interface cascading.flow.Flow
Method addStepListener registers the given flowStepListener with this instance.
addStepStats(FlowStepStats) - Method in class cascading.stats.FlowStats
 
addString(String) - Method in class cascading.tuple.Tuple
Method addString adds a new element value to this instance.
addTag(String) - Method in class cascading.property.AppProps
Method addTag will associate a "tag" with this application.
addTag(String) - Method in class cascading.property.UnitOfWorkDef
Method addTag will associate a "tag" with this UnitOfWork.
addTags(String...) - Method in class cascading.property.AppProps
Method addTags will associate the given "tags" with this application.
addTags(String...) - Method in class cascading.property.UnitOfWorkDef
Method addTags will associate the given "tags" with this UnitOfWork.
addTail(Pipe) - Method in class cascading.flow.FlowDef
Method addTail adds a new Pipe to this FlowDef that represents a tail in a pipe assembly.
addTail(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
addTails(Collection<Pipe>) - Method in class cascading.flow.FlowDef
Method addTails adds a Collection of tails.
addTails(Pipe...) - Method in class cascading.flow.FlowDef
Method addTails adds an array of tails.
addTailSink(Pipe, Tap) - Method in class cascading.flow.FlowDef
Method addTailSink adds the tail Pipe and sink Tap to this FlowDef.
addToClassPath(String) - Method in class cascading.flow.FlowDef
Adds each given artifact to the classpath the assembly will execute under allowing Operators to dynamically load classes and resources from a ClassLoader.
addTrap(String, Tap) - Method in class cascading.flow.FlowDef
Method addTrap adds a new named trap Tap for use in the resulting Flow.
addTrap(Pipe, Tap) - Method in class cascading.flow.FlowDef
Method addTrap adds a new trap Tap named after the given Pipe for use in the resulting Flow.
addTraps(Map<String, Tap>) - Method in class cascading.flow.FlowDef
Method addTraps adds a Map of the names and Tap pairs.
addVertex(FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
addVertex(FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
addVertex(FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
addVertex(Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
addVertex(Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
aggregate(FlowProcess, AggregatorCall<Context>) - Method in interface cascading.operation.Aggregator
Method aggregate is called for each TupleEntry value in the current grouping.
aggregate(FlowProcess, AggregatorCall<Average.Context>) - Method in class cascading.operation.aggregator.Average
 
aggregate(FlowProcess, AggregatorCall<Pair<Long[], Tuple>>) - Method in class cascading.operation.aggregator.Count
 
aggregate(FlowProcess, AggregatorCall<Tuple[]>) - Method in class cascading.operation.aggregator.ExtentBase
 
aggregate(FlowProcess, AggregatorCall<ExtremaValueBase.Context>) - Method in class cascading.operation.aggregator.ExtremaValueBase
 
aggregate(FlowProcess, AggregatorCall<Pair<Double[], Tuple>>) - Method in class cascading.operation.aggregator.Sum
 
aggregate(FlowProcess, GroupAssertionCall<AssertGroupBase.Context>) - Method in class cascading.operation.assertion.AssertGroupBase
 
aggregate(FlowProcess, GroupAssertionCall<C>) - Method in interface cascading.operation.GroupAssertion
Method aggregate is called for each TupleEntry value in the current grouping.
aggregate(FlowProcess, TupleEntry, Tuple) - Method in interface cascading.pipe.assembly.AggregateBy.Functor
Method aggregate operates on the given args in tandem (optionally) with the given context values.
aggregate(FlowProcess, AggregatorCall<AverageBy.AverageFinal.Context>) - Method in class cascading.pipe.assembly.AverageBy.AverageFinal
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.AverageBy.AveragePartials
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.CountBy.CountPartials
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.FirstBy.FirstPartials
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.MaxBy.MaxPartials
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.MinBy.MinPartials
 
aggregate(FlowProcess, TupleEntry, Tuple) - Method in class cascading.pipe.assembly.SumBy.SumPartials
 
AGGREGATE_BY_CACHE_FACTORY - Static variable in class cascading.pipe.assembly.AggregateByProps
property to control the cache factory used in AggregateBy.
AGGREGATE_BY_CAPACITY - Static variable in class cascading.pipe.assembly.AggregateByProps
property to control the capacity of the cache to use.
AGGREGATE_BY_DEFAULT_CAPACITY - Static variable in class cascading.pipe.assembly.AggregateByProps
default capacity of caches used in AggregateBy.
AggregateBy - Class in cascading.pipe.assembly
Class AggregateBy is a SubAssembly that serves two roles for handling aggregate operations.
AggregateBy(String, int) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(Fields, AggregateBy.Functor, Aggregator) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(Pipe, Fields, AggregateBy...) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(Pipe, Fields, int, AggregateBy...) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(String, Pipe, Fields, int, AggregateBy...) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(String, Pipe[], Fields, AggregateBy...) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(String, Pipe[], Fields, int, AggregateBy...) - Constructor for class cascading.pipe.assembly.AggregateBy
Constructor CompositeAggregator creates a new CompositeAggregator instance.
AggregateBy(String, Pipe[], Fields, Fields, AggregateBy.Functor, Aggregator, int) - Constructor for class cascading.pipe.assembly.AggregateBy
 
AggregateBy.Cache - Enum in cascading.pipe.assembly
 
AggregateBy.CompositeFunction - Class in cascading.pipe.assembly
Class CompositeFunction takes multiple Functor instances and manages them as a single Function.
AggregateBy.CompositeFunction(Fields, Fields, AggregateBy.Functor, int) - Constructor for class cascading.pipe.assembly.AggregateBy.CompositeFunction
Constructor CompositeFunction creates a new CompositeFunction instance.
AggregateBy.CompositeFunction(Fields, Fields[], AggregateBy.Functor[], int) - Constructor for class cascading.pipe.assembly.AggregateBy.CompositeFunction
Constructor CompositeFunction creates a new CompositeFunction instance.
AggregateBy.CompositeFunction.Context - Class in cascading.pipe.assembly
 
AggregateBy.CompositeFunction.Context() - Constructor for class cascading.pipe.assembly.AggregateBy.CompositeFunction.Context
 
AggregateBy.Functor - Interface in cascading.pipe.assembly
Interface Functor provides a means to create a simple function for use with the AggregateBy.CompositeFunction class.
AggregateByProps - Class in cascading.pipe.assembly
Class AggregateByProps is a fluent helper for setting various properties related to the cache used in AggregateBy.
AggregateByProps() - Constructor for class cascading.pipe.assembly.AggregateByProps
 
aggregateByProps() - Static method in class cascading.pipe.assembly.AggregateByProps
 
Aggregator<Context> - Interface in cascading.operation
An Aggregator takes the set of all values associated with a unique grouping and returns zero or more values.
AggregatorCall<C> - Interface in cascading.operation
Interface AggregatorCall provides access to the current Aggregator invocation arguments.
AggregatorEveryStage - Class in cascading.flow.stream.element
 
AggregatorEveryStage(FlowProcess, Every) - Constructor for class cascading.flow.stream.element.AggregatorEveryStage
 
ALL - Static variable in class cascading.flow.planner.iso.expression.ScopeExpression
Where this expression applies between ALL edges between two nodes.
ALL - Static variable in class cascading.tuple.Fields
Field ALL represents a wildcard for all fields
ALL_BLOCKING - Static variable in class cascading.flow.planner.iso.expression.PathScopeExpression
 
ALL_NON_BLOCKING - Static variable in class cascading.flow.planner.iso.expression.PathScopeExpression
 
allNext - Variable in class cascading.flow.stream.duct.Fork
 
and(ElementExpression...) - Static method in class cascading.flow.planner.iso.expression.AndElementExpression
 
and(ElementCapture, ElementExpression...) - Static method in class cascading.flow.planner.iso.expression.AndElementExpression
 
And - Class in cascading.operation.filter
Class And is a Filter class that will logically 'and' the results of the constructor provided Filter instances.
And(Filter...) - Constructor for class cascading.operation.filter.And
Constructor And creates a new And instance where all Filter instances receive all arguments.
And(Fields, Filter, Fields, Filter) - Constructor for class cascading.operation.filter.And
Constructor And creates a new And instance.
And(Fields[], Filter[]) - Constructor for class cascading.operation.filter.And
Constructor And creates a new And instance.
AndElementExpression - Class in cascading.flow.planner.iso.expression
 
AndElementExpression(ElementExpression...) - Constructor for class cascading.flow.planner.iso.expression.AndElementExpression
 
AndElementExpression(ElementCapture, ElementExpression...) - Constructor for class cascading.flow.planner.iso.expression.AndElementExpression
 
AnnotatedDecoratedElementGraph - Class in cascading.flow.planner.graph
 
AnnotatedDecoratedElementGraph(ElementGraph, EnumMultiMap<FlowElement>) - Constructor for class cascading.flow.planner.graph.AnnotatedDecoratedElementGraph
 
AnnotatedGraph - Interface in cascading.flow.planner.graph
 
AnnotateGraphTransformer - Class in cascading.flow.planner.iso.transformer
 
AnnotateGraphTransformer(ExpressionGraph, ElementAnnotation) - Constructor for class cascading.flow.planner.iso.transformer.AnnotateGraphTransformer
 
AnnotateGraphTransformer(GraphTransformer, ExpressionGraph, ElementAnnotation) - Constructor for class cascading.flow.planner.iso.transformer.AnnotateGraphTransformer
 
AnnotationExpression - Class in cascading.flow.planner.iso.expression
 
AnnotationExpression(Enum) - Constructor for class cascading.flow.planner.iso.expression.AnnotationExpression
 
AnnotationExpression(ElementCapture, Enum) - Constructor for class cascading.flow.planner.iso.expression.AnnotationExpression
 
annotations - Variable in class cascading.flow.planner.graph.BaseAnnotatedElementGraph
 
annotations - Variable in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
ANY - Static variable in class cascading.flow.planner.iso.expression.ScopeExpression
Where this expression applies between ANY edge between two nodes.
ANY - Static variable in interface cascading.operation.Operation
Field ANY denotes that a given Operation will take any number of argument values
ANY_BLOCKING - Static variable in class cascading.flow.planner.iso.expression.PathScopeExpression
 
ANY_NON_BLOCKING - Static variable in class cascading.flow.planner.iso.expression.PathScopeExpression
 
APP_FRAMEWORKS - Static variable in class cascading.property.AppProps
 
APP_ID - Static variable in class cascading.property.AppProps
 
APP_JAR_CLASS - Static variable in class cascading.property.AppProps
 
APP_JAR_PATH - Static variable in class cascading.property.AppProps
 
APP_NAME - Static variable in class cascading.property.AppProps
 
APP_TAGS - Static variable in class cascading.property.AppProps
 
APP_VERSION - Static variable in class cascading.property.AppProps
 
append(Fields) - Method in class cascading.tuple.Fields
Method is used for appending the given Fields instance to this instance, into a new Fields instance suitable for use as a field declaration.
append(Tuple...) - Method in class cascading.tuple.Tuple
Method append appends all the values of the given Tuple instances to a copy of this instance.
appendNew(TupleEntry) - Method in class cascading.tuple.TupleEntry
Method appendNew appends the given TupleEntry instance to this instance.
appendSelector(Fields) - Method in class cascading.tuple.Fields
Method is used for appending the given Fields instance to this instance, into a new Fields instance suitable for use as a field selector.
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.AndElementExpression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.AnnotationExpression
 
applies(PlannerContext, ElementGraph, Type) - Method in interface cascading.flow.planner.iso.expression.Expression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.NonSafeOperationExpression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.NotElementExpression
 
applies(PlannerContext, ElementGraph, Scope) - Method in class cascading.flow.planner.iso.expression.OrdinalScopeExpression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.OrElementExpression
 
applies(PlannerContext, ElementGraph, Scope) - Method in class cascading.flow.planner.iso.expression.PathScopeExpression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.PlannerLevelElementExpression
 
applies - Variable in class cascading.flow.planner.iso.expression.ScopeExpression
 
applies(PlannerContext, ElementGraph, FlowElement) - Method in class cascading.flow.planner.iso.expression.TypeExpression
 
appliesToAllPaths() - Method in class cascading.flow.planner.iso.expression.ScopeExpression
 
appliesToAnyPath() - Method in class cascading.flow.planner.iso.expression.ScopeExpression
 
appliesToEachPath() - Method in class cascading.flow.planner.iso.expression.ScopeExpression
 
apply(Flow<Config>, List<FlowStep<Config>>, FlowStep<Config>) - Method in interface cascading.flow.FlowStepStrategy
 
apply(Visibility, Object) - Method in interface cascading.management.annotation.Sanitizer
Applies the custom sanitization to the given value for the given visibility.
apply(Visibility, Object) - Method in class cascading.management.annotation.URISanitizer
 
apply(String, ConfigDef.Getter) - Method in class cascading.property.ConfigDef
 
apply(ConfigDef.Mode, ConfigDef.Setter) - Method in class cascading.property.ConfigDef
 
ApplyAssertionLevelTransformer - Class in cascading.flow.planner.rule.transformer
 
ApplyAssertionLevelTransformer() - Constructor for class cascading.flow.planner.rule.transformer.ApplyAssertionLevelTransformer
 
ApplyDebugLevelTransformer - Class in cascading.flow.planner.rule.transformer
 
ApplyDebugLevelTransformer() - Constructor for class cascading.flow.planner.rule.transformer.ApplyDebugLevelTransformer
 
applyType(Comparable, Type) - Method in class cascading.tuple.Fields
Method applyType should be used to associate a Type with a given field name or position.
applyTypes(Fields) - Method in class cascading.tuple.Fields
Method applyType should be used to associate Type with a given field name or position as declared in the given Fields parameter.
applyTypes(Type...) - Method in class cascading.tuple.Fields
Method applyTypes returns a new Fields instance with the given types, replacing any existing type information within the new instance.
AppProps - Class in cascading.property
Class AppProps is a fluent helper for setting various application level properties that every Flow may or may not be required to have set.
AppProps() - Constructor for class cascading.property.AppProps
 
AppProps(String, String) - Constructor for class cascading.property.AppProps
Sets the name and version of this application.
appProps() - Static method in class cascading.property.AppProps
Creates a new AppProps instance.
arc(ElementExpression, ScopeExpression, ElementExpression) - Method in class cascading.flow.planner.iso.expression.ExpressionGraph
 
arcs(ElementExpression...) - Method in class cascading.flow.planner.iso.expression.ExpressionGraph
 
areSinksStale() - Method in class cascading.flow.BaseFlow
 
areSinksStale() - Method in interface cascading.flow.Flow
Method areSinksStale returns true if any of the sinks referenced are out of date in relation to the sources.
areSourcesNewer(long) - Method in class cascading.flow.BaseFlow
 
areSourcesNewer(long) - Method in interface cascading.flow.Flow
Method areSourcesNewer returns true if any source is newer than the given sinkModified date value.
ARGS - Static variable in class cascading.tuple.Fields
Field ARGS represents all fields used as the arguments for the current operation
argumentsBuilder - Variable in class cascading.flow.stream.element.OperatorStage
 
argumentSelector - Variable in class cascading.pipe.Operator
Field argumentSelector
argumentSelectors - Variable in class cascading.operation.filter.Logic
Field fields
argumentsEntry - Variable in class cascading.flow.stream.element.OperatorStage
 
argumentsSelector - Variable in class cascading.flow.stream.element.OperatorStage
 
asArray(Tuple, T[]) - Static method in class cascading.tuple.Tuples
Method asArray copies the elements of the given Tuple instance to the given Object array.
asArray(Tuple, CoercibleType[], Class[], Object[]) - Static method in class cascading.tuple.Tuples
 
asClass(Type) - Static method in class cascading.tuple.coerce.Coercions
Method asClass is a convenience method for casting the given type to a Class if an instance of Class or to Object if not.
asClasses(String, String) - Static method in class cascading.util.Util
Converts a given comma separated String of Exception names into a List of classes.
asCollection(Flow, Tap, C) - Static method in class cascading.CascadingTestCase
 
asCollection(Flow, Tap, Fields, C) - Static method in class cascading.CascadingTestCase
 
asCollection(TupleEntryIterator, C) - Static method in class cascading.CascadingTestCase
 
asCollection(TupleEntryIterator, Fields, C) - Static method in class cascading.CascadingTestCase
 
asCollection(Tuple) - Static method in class cascading.tuple.Tuples
 
asDeclaration(Fields) - Static method in class cascading.tuple.Fields
Method asDeclaration returns a new Fields instance for use as a declarator based on the given fields value.
asExtentMaskedSubGraph(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
Returns a new ElementGraph (a MaskedSubGraph) of the given ElementGraph that will not contain the Extent head or tail instances.
asFieldName(Comparable) - Static method in class cascading.tuple.Fields
 
asFlatMap(Map<Object, Object>) - Static method in class cascading.property.PropertyUtil
 
asIterableOf(Class<T>) - Method in class cascading.tuple.TupleEntry
Method asIterableOf returns an Iterable instance that will coerce all Tuple elements into the given type parameter.
asList(Flow, Tap) - Static method in class cascading.CascadingTestCase
 
asList(Flow, Tap, Fields) - Static method in class cascading.CascadingTestCase
 
asList() - Method in class cascading.flow.planner.graph.IgnoreAnnotationsHashSet
 
asModifiable(Tuple) - Static method in class cascading.tuple.Tuples
Method asModifiable marks the given Tuple instance as modifiable.
asNonPrimitive(Class) - Static method in class cascading.tuple.coerce.Coercions
Returns the primitive wrapper fo the given type, if the given type represents a primitive, otherwise the type is returned.
asNonPrimitive(Class[]) - Static method in class cascading.tuple.coerce.Coercions
 
asPathList(List<GraphPath<Duct, DuctGraph.Ordinal>>) - Static method in class cascading.flow.stream.graph.StreamGraph
 
AssemblyPlanner - Interface in cascading.flow
Interface AssemblyPlanner is used to allow for lazy evaluation of a pipe assembly during planning of a Flow.
AssemblyPlanner.Context - Interface in cascading.flow
 
assemblyPlanners - Variable in class cascading.flow.FlowDef
 
Asserted - Class in cascading.flow.planner.iso.assertion
 
Asserted(PlannerContext, GraphAssert, ElementGraph, String, GraphAssert.AssertionType, Match) - Constructor for class cascading.flow.planner.iso.assertion.Asserted
 
AssertEquals - Class in cascading.operation.assertion
Class AssertEquals asserts the number of constructor values is equal to the number of argument values Tuple and each constructor value is .equals() to its corresponding argument value.
AssertEquals(Object...) - Constructor for class cascading.operation.assertion.AssertEquals
Constructor AssertEquals creates a new AssertEquals instance.
AssertEqualsAll - Class in cascading.operation.assertion
Class AssertEqualsAll asserts that every value in the argument values Tuple is equal to the value provided on the constructor.
AssertEqualsAll(Object) - Constructor for class cascading.operation.assertion.AssertEqualsAll
Constructor AssertEqualsAll creates a new AssertEqualsAll instance.
AssertExpression - Class in cascading.operation.assertion
Class AssertExpression dynamically resolves a given expression using argument Tuple values.
AssertExpression(String, Class) - Constructor for class cascading.operation.assertion.AssertExpression
Constructor ExpressionFilter creates a new ExpressionFilter instance.
AssertExpression(Fields, String, String[], Class[]) - Constructor for class cascading.operation.assertion.AssertExpression
Constructor AssertExpression creates a new AssertExpression instance.
assertFails(Long) - Method in class cascading.operation.assertion.AssertGroupBase
 
assertFails(Long) - Method in class cascading.operation.assertion.AssertGroupSizeEquals
 
assertFails(Long) - Method in class cascading.operation.assertion.AssertGroupSizeLessThan
 
assertFails(Long) - Method in class cascading.operation.assertion.AssertGroupSizeMoreThan
 
AssertGroupBase - Class in cascading.operation.assertion
 
AssertGroupBase(String, long) - Constructor for class cascading.operation.assertion.AssertGroupBase
 
AssertGroupBase(String, String, long) - Constructor for class cascading.operation.assertion.AssertGroupBase
 
AssertGroupBase.Context - Class in cascading.operation.assertion
 
AssertGroupBase.Context() - Constructor for class cascading.operation.assertion.AssertGroupBase.Context
 
AssertGroupSizeEquals - Class in cascading.operation.assertion
Class AssertGroupSizeEquals is an GroupAssertion that asserts the number of items in the current group is equal the given size.
AssertGroupSizeEquals(long) - Constructor for class cascading.operation.assertion.AssertGroupSizeEquals
Constructor AssertGroupSizeEquals creates a new AssertGroupSizeEquals instance.
AssertGroupSizeEquals(String, long) - Constructor for class cascading.operation.assertion.AssertGroupSizeEquals
Constructor AssertGroupSizeEquals creates a new AssertGroupSizeEquals instance.
AssertGroupSizeLessThan - Class in cascading.operation.assertion
Class AssertGroupSizeEquals is an GroupAssertion that asserts the number of items in the current group is less than the given size.
AssertGroupSizeLessThan(long) - Constructor for class cascading.operation.assertion.AssertGroupSizeLessThan
Constructor AssertGroupSizeLessThan creates a new AssertGroupSizeLessThan instance.
AssertGroupSizeLessThan(String, long) - Constructor for class cascading.operation.assertion.AssertGroupSizeLessThan
Constructor AssertGroupSizeLessThan creates a new AssertGroupSizeLessThan instance.
AssertGroupSizeMoreThan - Class in cascading.operation.assertion
Class AssertGroupSizeEquals is an GroupAssertion that asserts the number of items in the current group is more than the given size.
AssertGroupSizeMoreThan(long) - Constructor for class cascading.operation.assertion.AssertGroupSizeMoreThan
Constructor AssertGroupSizeMoreThan creates a new AssertGroupSizeMoreThan instance.
AssertGroupSizeMoreThan(String, long) - Constructor for class cascading.operation.assertion.AssertGroupSizeMoreThan
Constructor AssertGroupSizeMoreThan creates a new AssertGroupSizeMoreThan instance.
assertion(PlannerContext, E) - Method in class cascading.flow.planner.iso.assertion.GraphAssert
 
Assertion<PC> - Interface in cascading.operation
Interface Assertion is the base interface for all stream assertions.
ASSERTION_LEVEL - Static variable in class cascading.flow.FlowConnectorProps
 
AssertionException - Exception in cascading.operation
Class AssertionException is the exception that must be thrown when an Assertion fails.
AssertionException() - Constructor for exception cascading.operation.AssertionException
 
AssertionException(String) - Constructor for exception cascading.operation.AssertionException
 
AssertionException(String, Throwable) - Constructor for exception cascading.operation.AssertionException
 
AssertionException(Throwable) - Constructor for exception cascading.operation.AssertionException
 
assertionLevel - Variable in class cascading.flow.FlowDef
 
AssertionLevel - Enum in cascading.operation
Enum AssertionLevel designates the level of a given Assertion instance.
AssertMatches - Class in cascading.operation.assertion
Class AssertMatches matches the given regular expression patternString against the whole argument Tuple by joining each individual element of the Tuple with a tab character (\t) unless otherwise specified.
AssertMatches(String) - Constructor for class cascading.operation.assertion.AssertMatches
Constructor AssertMatches creates a new AssertMatches instance.
AssertMatches(String, String) - Constructor for class cascading.operation.assertion.AssertMatches
Constructor AssertMatches creates a new AssertMatches instance.
AssertMatches(String, boolean) - Constructor for class cascading.operation.assertion.AssertMatches
Constructor AssertMatches creates a new AssertMatches instance.
AssertMatches(String, boolean, String) - Constructor for class cascading.operation.assertion.AssertMatches
Constructor AssertMatches creates a new AssertMatches instance.
AssertMatchesAll - Class in cascading.operation.assertion
Class AssertMatchesAll matches the given regular expression patternString against each argument Tuple element individually.
AssertMatchesAll(String) - Constructor for class cascading.operation.assertion.AssertMatchesAll
Constructor AssertMatchesAll creates a new AssertMatchesAll instance.
AssertMatchesAll(String, boolean) - Constructor for class cascading.operation.assertion.AssertMatchesAll
Constructor AssertMatchesAll creates a new AssertMatchesAll instance.
AssertNotEquals - Class in cascading.operation.assertion
Class AssertNotEquals asserts the number of constructor values is equal to the number of argument values Tuple and each constructor value is not .equals() to its corresponding argument value.
AssertNotEquals(Object...) - Constructor for class cascading.operation.assertion.AssertNotEquals
Constructor AssertEquals creates a new AssertEquals instance.
AssertNotNull - Class in cascading.operation.assertion
Class AssertNotNull asserts that every value in the argument values Tuple is not a null value.
AssertNotNull() - Constructor for class cascading.operation.assertion.AssertNotNull
Constructor AssertNotNull creates a new AssertNotNull instance.
AssertNull - Class in cascading.operation.assertion
Class AssertNull asserts that every value in the argument values Tuple is a null value.
AssertNull() - Constructor for class cascading.operation.assertion.AssertNull
Constructor AssertNull creates a new AssertNull instance.
AssertSizeEquals - Class in cascading.operation.assertion
Class AssertSizeEquals asserts that the current Tuple in the stream is exactly the given size.
AssertSizeEquals(int) - Constructor for class cascading.operation.assertion.AssertSizeEquals
Constructor AssertSizeEquals creates a new AssertSizeEquals instance.
AssertSizeLessThan - Class in cascading.operation.assertion
Class AssertSizeLessThan asserts that the current Tuple in the stream has a size less than (<) the given size.
AssertSizeLessThan(int) - Constructor for class cascading.operation.assertion.AssertSizeLessThan
Constructor AssertSizeLessThan creates a new AssertSizeLessThan instance.
AssertSizeMoreThan - Class in cascading.operation.assertion
Class AssertSizeMoreThan asserts that the current Tuple in the stream has a size more than (>) the given size.
AssertSizeMoreThan(int) - Constructor for class cascading.operation.assertion.AssertSizeMoreThan
Constructor AssertSizeMoreThan creates a new AssertSizeMoreThan instance.
asSet(Flow, Tap) - Static method in class cascading.CascadingTestCase
 
asSet(Flow, Tap, Fields) - Static method in class cascading.CascadingTestCase
 
asSubGraph(ElementGraph, ElementGraph, Set<FlowElement>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
asSubGraphOf(ElementGraph, ElementGraph) - Method in class cascading.flow.planner.iso.transformer.SubGraphTransformer
 
asType(String) - Static method in class cascading.tuple.coerce.Coercions
Method asType is a convenience method for looking up a type name (like "int" or "java.lang.String" to its corresponding Class or instance of CoercibleType.
asUnmodifiable(Tuple) - Static method in class cascading.tuple.Tuples
Method asUnmodifiable marks the given Tuple instance as unmodifiable.
Average - Class in cascading.operation.aggregator
Class Average is an Aggregator that returns the average of all numeric values in the current group.
Average() - Constructor for class cascading.operation.aggregator.Average
Constructs a new instance that returns the average of the values encountered in the field name "average".
Average(Fields) - Constructor for class cascading.operation.aggregator.Average
Constructs a new instance that returns the average of the values encountered in the given fieldDeclaration field name.
Average.Context - Class in cascading.operation.aggregator
Class Context is used to hold intermediate values.
Average.Context(CoercibleType) - Constructor for class cascading.operation.aggregator.Average.Context
 
AverageBy - Class in cascading.pipe.assembly
Class AverageBy is used to average values associated with duplicate keys in a tuple stream.
AverageBy(Fields, Fields) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Fields, Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe, Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe, Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe[], Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe[], Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe[], Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe[], Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe, Fields, Fields, Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe, Fields, Fields, Fields, AverageBy.Include, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe, Fields, Fields, Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe, Fields, Fields, Fields, AverageBy.Include, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe[], Fields, Fields, Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(Pipe[], Fields, Fields, Fields, AverageBy.Include, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe[], Fields, Fields, Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy(String, Pipe[], Fields, Fields, Fields, AverageBy.Include, int) - Constructor for class cascading.pipe.assembly.AverageBy
Constructor AverageBy creates a new AverageBy instance.
AverageBy.AverageFinal - Class in cascading.pipe.assembly
Class AverageFinal is used to finalize the average operation on the Reduce side of the process.
AverageBy.AverageFinal(Fields) - Constructor for class cascading.pipe.assembly.AverageBy.AverageFinal
Constructs a new instance that returns the average of the values encountered in the given fieldDeclaration field name.
AverageBy.AverageFinal.Context - Class in cascading.pipe.assembly
Class Context is used to hold intermediate values.
AverageBy.AverageFinal.Context(Fields) - Constructor for class cascading.pipe.assembly.AverageBy.AverageFinal.Context
 
AverageBy.AveragePartials - Class in cascading.pipe.assembly
Class AveragePartials is a AggregateBy.Functor that is used to count and sum observed duplicates from the tuple stream.
AverageBy.AveragePartials(Fields) - Constructor for class cascading.pipe.assembly.AverageBy.AveragePartials
Constructor AveragePartials creates a new AveragePartials instance.
AverageBy.AveragePartials(Fields, AverageBy.Include) - Constructor for class cascading.pipe.assembly.AverageBy.AveragePartials
 
AverageBy.Include - Enum in cascading.pipe.assembly
 

B

BaseAnnotatedElementGraph - Class in cascading.flow.planner.graph
 
BaseAnnotatedElementGraph() - Constructor for class cascading.flow.planner.graph.BaseAnnotatedElementGraph
 
BaseAssertion<C> - Class in cascading.operation.assertion
Class BaseAssertion is a convenience class for Assertion implementations.
BaseAssertion() - Constructor for class cascading.operation.assertion.BaseAssertion
 
BaseAssertion(String) - Constructor for class cascading.operation.assertion.BaseAssertion
 
BaseAssertion(int) - Constructor for class cascading.operation.assertion.BaseAssertion
 
BaseAssertion(int, String) - Constructor for class cascading.operation.assertion.BaseAssertion
 
BaseCacheFactory<Key,Value,Config> - Class in cascading.util.cache
Base class for all CacheFactories for creating CascadingCache instances.
BaseCacheFactory() - Constructor for class cascading.util.cache.BaseCacheFactory
 
BaseCascade - Class in cascading.cascade
 
BaseCascade() - Constructor for class cascading.cascade.BaseCascade
for testing
BaseCascade.CascadeJob - Class in cascading.cascade
Class CascadeJob manages Flow execution in the current Cascade instance.
BaseCascade.CascadeJob(Flow) - Constructor for class cascading.cascade.BaseCascade.CascadeJob
 
BaseElementGraph - Class in cascading.flow.planner.graph
 
BaseElementGraph() - Constructor for class cascading.flow.planner.graph.BaseElementGraph
 
BaseElementGraph(DirectedGraph<FlowElement, Scope>) - Constructor for class cascading.flow.planner.graph.BaseElementGraph
 
BaseFlow<Config> - Class in cascading.flow
 
BaseFlow() - Constructor for class cascading.flow.BaseFlow
Used for testing.
BaseFlow(PlatformInfo, Map<Object, Object>, Config, String) - Constructor for class cascading.flow.BaseFlow
 
BaseFlow(PlatformInfo, Map<Object, Object>, Config, String, Map<String, String>) - Constructor for class cascading.flow.BaseFlow
 
BaseFlow(PlatformInfo, Map<Object, Object>, Config, FlowDef) - Constructor for class cascading.flow.BaseFlow
 
BaseFlow.FlowHolder - Class in cascading.flow
Class FlowHolder is a helper class for wrapping Flow instances.
BaseFlow.FlowHolder() - Constructor for class cascading.flow.BaseFlow.FlowHolder
 
BaseFlow.FlowHolder(Flow) - Constructor for class cascading.flow.BaseFlow.FlowHolder
 
BaseFlowNode - Class in cascading.flow.planner
 
BaseFlowNode(String, int) - Constructor for class cascading.flow.planner.BaseFlowNode
 
BaseFlowNode(FlowElementGraph, ElementGraph, List<? extends ElementGraph>) - Constructor for class cascading.flow.planner.BaseFlowNode
 
BaseFlowStep<Config> - Class in cascading.flow.planner
Class FlowStep is an internal representation of a given Job to be executed on a remote cluster.
BaseFlowStep(String, int) - Constructor for class cascading.flow.planner.BaseFlowStep
 
BaseFlowStep(ElementGraph, FlowNodeGraph) - Constructor for class cascading.flow.planner.BaseFlowStep
 
BaseJoiner - Class in cascading.pipe.joiner
 
BaseJoiner() - Constructor for class cascading.pipe.joiner.BaseJoiner
 
BaseJoiner(Fields) - Constructor for class cascading.pipe.joiner.BaseJoiner
 
BaseOperation<Context> - Class in cascading.operation
Class BaseOperation is the base class of predicate types that are applied to Tuple streams via the Each or Every Pipe.
BaseOperation() - Constructor for class cascading.operation.BaseOperation
Constructs a new instance that returns an Fields.UNKNOWN Tuple and accepts any number of arguments.
BaseOperation(Fields) - Constructor for class cascading.operation.BaseOperation
Constructs a new instance that returns the fields declared in fieldDeclaration and accepts any number of arguments.
BaseOperation(int) - Constructor for class cascading.operation.BaseOperation
Constructs a new instance that returns an unknown field set and accepts the given numArgs number of arguments.
BaseOperation(int, Fields) - Constructor for class cascading.operation.BaseOperation
Constructs a new instance that returns the fields declared in fieldDeclaration and accepts numArgs number of arguments.
BasePartitionTap<Config,Input,Output> - Class in cascading.tap.partition
 
BasePartitionTap(Tap, Partition, int) - Constructor for class cascading.tap.partition.BasePartitionTap
 
BasePartitionTap(Tap, Partition, SinkMode) - Constructor for class cascading.tap.partition.BasePartitionTap
 
BasePartitionTap(Tap, Partition, SinkMode, boolean, int) - Constructor for class cascading.tap.partition.BasePartitionTap
 
BasePartitionTap.Counters - Enum in cascading.tap.partition
 
BasePartitionTap.PartitionCollector - Class in cascading.tap.partition
 
BasePartitionTap.PartitionCollector(FlowProcess<? extends Config>) - Constructor for class cascading.tap.partition.BasePartitionTap.PartitionCollector
 
BasePartitionTap.PartitionScheme<Config,Input,Output> - Class in cascading.tap.partition
 
BasePartitionTap.PartitionScheme(Scheme) - Constructor for class cascading.tap.partition.BasePartitionTap.PartitionScheme
 
BasePartitionTap.PartitionScheme(Scheme, Fields) - Constructor for class cascading.tap.partition.BasePartitionTap.PartitionScheme
 
BaseProcessGraph<Process extends ProcessModel> - Class in cascading.flow.planner.process
 
BaseProcessGraph() - Constructor for class cascading.flow.planner.process.BaseProcessGraph
 
BaseState - Class in cascading.management.state
 
BaseState() - Constructor for class cascading.management.state.BaseState
 
BIG_DECIMAL - Static variable in class cascading.tuple.coerce.Coercions
 
BigDecimalCoerce - Class in cascading.tuple.coerce
 
BigDecimalCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.BigDecimalCoerce
 
bind(StreamGraph) - Method in class cascading.flow.stream.duct.Duct
 
bind(StreamGraph) - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
bind(StreamGraph) - Method in class cascading.flow.stream.element.MemoryHashJoinGate
 
bind(StreamGraph) - Method in class cascading.flow.stream.element.MemorySpliceGate
 
bind(StreamGraph) - Method in class cascading.flow.stream.element.MergeStage
 
bind(StreamGraph) - Method in class cascading.flow.stream.element.SinkStage
 
bind() - Method in class cascading.flow.stream.graph.StreamGraph
 
bindEdges() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
bindHeadAndTail(ElementGraph, ElementGraph) - Method in class cascading.flow.planner.graph.BoundedElementMultiGraph
 
binResult(RuleResult) - Method in class cascading.flow.planner.rule.RuleSetExec
 
block - Variable in class cascading.operation.expression.ScriptOperation
Field expression
blockForCompletedChildDetailDuration - Variable in class cascading.flow.planner.FlowStepJob
Field waitTillCompletedChildStatsDuration
BLOCKING - Static variable in class cascading.flow.planner.iso.expression.PathScopeExpression
 
BlockingHashJoinAnnotator - Class in cascading.flow.planner.rule.annotator
 
BlockingHashJoinAnnotator() - Constructor for class cascading.flow.planner.rule.annotator.BlockingHashJoinAnnotator
 
BlockingMode - Enum in cascading.flow.stream.annotations
 
blockOnJob() - Method in class cascading.flow.planner.FlowStepJob
 
blockOnPredecessors() - Method in class cascading.flow.planner.FlowStepJob
 
blockTillCompleteOrStopped() - Method in class cascading.flow.planner.FlowStepJob
 
BOOLEAN - Static variable in class cascading.tuple.coerce.Coercions
 
BOOLEAN_OBJECT - Static variable in class cascading.tuple.coerce.Coercions
 
BooleanCoerce - Class in cascading.tuple.coerce
 
BooleanCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.BooleanCoerce
 
BooleanObjectCoerce - Class in cascading.tuple.coerce
 
BooleanObjectCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.BooleanObjectCoerce
 
BoundariesElementExpression - Class in cascading.flow.planner.rule.elementexpression
 
BoundariesElementExpression() - Constructor for class cascading.flow.planner.rule.elementexpression.BoundariesElementExpression
 
BoundariesElementExpression(ElementCapture) - Constructor for class cascading.flow.planner.rule.elementexpression.BoundariesElementExpression
 
BoundariesElementExpression(TypeExpression.Topo) - Constructor for class cascading.flow.planner.rule.elementexpression.BoundariesElementExpression
 
BoundariesElementExpression(ElementCapture, TypeExpression.Topo) - Constructor for class cascading.flow.planner.rule.elementexpression.BoundariesElementExpression
 
boundary - Variable in class cascading.flow.stream.element.BoundaryStage
 
Boundary - Class in cascading.pipe
The Boundary class is only used internally by the planner to mark the boundaries between partitions within the element graph.
Boundary() - Constructor for class cascading.pipe.Boundary
Intentionally does not provide a chaining constructor, as Boundary should not be inserted into an assembly by a user.
BOUNDARY_PIPE - Static variable in class cascading.flow.planner.rule.transformer.BoundaryElementFactory
 
BoundaryElementFactory - Class in cascading.flow.planner.rule.transformer
 
BoundaryElementFactory() - Constructor for class cascading.flow.planner.rule.transformer.BoundaryElementFactory
 
BoundaryStage<Incoming,Outgoing> - Class in cascading.flow.stream.element
 
BoundaryStage(FlowProcess, Boundary) - Constructor for class cascading.flow.stream.element.BoundaryStage
 
BoundaryStage(FlowProcess, Boundary, IORole) - Constructor for class cascading.flow.stream.element.BoundaryStage
 
BoundedElementMultiGraph - Class in cascading.flow.planner.graph
 
BoundedElementMultiGraph(ElementGraph, ElementGraph, EnumMultiMap) - Constructor for class cascading.flow.planner.graph.BoundedElementMultiGraph
 
branchNames - Variable in class cascading.flow.stream.element.ElementStage
 
Buffer<Context> - Interface in cascading.operation
A Buffer is similar to an Aggregator by the fact that it operates on unique groups of values.
BufferAfterEveryAssert - Class in cascading.flow.planner.rule.assertion
 
BufferAfterEveryAssert() - Constructor for class cascading.flow.planner.rule.assertion.BufferAfterEveryAssert
 
BufferAfterEveryExpression - Class in cascading.flow.planner.rule.expression
 
BufferAfterEveryExpression() - Constructor for class cascading.flow.planner.rule.expression.BufferAfterEveryExpression
 
BufferCall<C> - Interface in cascading.operation
Interface BufferCall provides access to the current Buffer invocation arguments.
BufferEveryWindow - Class in cascading.flow.stream.element
 
BufferEveryWindow(FlowProcess, Every) - Constructor for class cascading.flow.stream.element.BufferEveryWindow
 
BufferJoin - Class in cascading.pipe.joiner
Class BufferJoiner notifies the Cascading planner that the next Buffer instance will implement a custom join strategy.
BufferJoin() - Constructor for class cascading.pipe.joiner.BufferJoin
 
buildFlow(FlowDef, RuleRegistrySet) - Method in class cascading.flow.planner.FlowPlanner
 
buildGraph(FlowPlanner<?, ?>, FlowElementGraph, List<? extends ElementGraph>, Map<ElementGraph, List<? extends ElementGraph>>) - Method in class cascading.flow.planner.process.FlowNodeGraph
 
buildGraph(FlowPlanner<?, ?>, FlowElementGraph, Map<ElementGraph, List<? extends ElementGraph>>, Map<ElementGraph, List<? extends ElementGraph>>) - Method in class cascading.flow.planner.process.FlowStepGraph
 
buildProperties() - Method in class cascading.property.Props
Method buildProperties returns a new Properties instance with all property values for this type.
buildProperties(Map<Object, Object>) - Method in class cascading.property.Props
Method buildProperties returns a new Properties instance with all property values for this type using the given Map of property values as defaults.
buildProperties(Iterable<Map.Entry<String, String>>) - Method in class cascading.property.Props
Method buildProperties returns a new Properties instance with all property values for this type using the given Iterable> of property values as defaults.
buildProperties(Properties) - Method in class cascading.property.Props
Method buildProperties returns a new Properties instance with all property values for this type using the given Properties instance of property values as defaults.

C

CacheEvictionCallback<Key,Value> - Interface in cascading.util.cache
CacheEvictionCallBack is an interface to be used in conjunction with CascadingCache instances.
call() - Method in class cascading.cascade.BaseCascade.CascadeJob
 
call() - Method in class cascading.flow.planner.FlowStepJob
 
call() - Method in class cascading.flow.stream.element.SourceStage
 
canonical(Object) - Method in class cascading.tuple.coerce.Coercions.Coerce
 
canonical(Object) - Method in interface cascading.tuple.type.CoercibleType
 
canonical(Object) - Method in class cascading.tuple.type.DateType
 
canonicalHash(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
canonicalHash(Graph<FlowElement, Scope>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
captureDebugTrace(Object) - Static method in class cascading.util.TraceUtil
 
captureDetail(CascadingStats.Type) - Method in class cascading.stats.CascadeStats
 
captureDetail() - Method in class cascading.stats.CascadingStats
Method captureDetail will recursively capture details about nested systems.
captureDetail(CascadingStats.Type) - Method in class cascading.stats.CascadingStats
 
captureDetail(CascadingStats.Type) - Method in class cascading.stats.FlowStats
 
captureDetail() - Method in class cascading.stats.process.ProcessStepStats
 
captureDetail(CascadingStats.Type) - Method in class cascading.stats.process.ProcessStepStats
 
captureMap - Variable in class cascading.flow.planner.iso.finder.Match
 
Cascade - Interface in cascading.cascade
A Cascade is an assembly of Flow instances that share or depend on equivalent Tap instances and are executed as a single group.
CascadeConnector - Class in cascading.cascade
Class CascadeConnector is used to construct a new Cascade instance from a collection of Flow instance.
CascadeConnector() - Constructor for class cascading.cascade.CascadeConnector
Constructor CascadeConnector creates a new CascadeConnector instance.
CascadeConnector(Map<Object, Object>) - Constructor for class cascading.cascade.CascadeConnector
Constructor CascadeConnector creates a new CascadeConnector instance.
CascadeDef - Class in cascading.cascade
Class CascadeDef is a fluent interface for defining a Cascade.
CascadeDef() - Constructor for class cascading.cascade.CascadeDef
Constructor CascadeDef creates a new CascadeDef instance.
cascadeDef() - Static method in class cascading.cascade.CascadeDef
Creates a new instance of a CascadeDef.
CascadeException - Exception in cascading.cascade
Class CascadeException is thrown by the Cascade class.
CascadeException() - Constructor for exception cascading.cascade.CascadeException
Constructor CascadeException creates a new CascadeException instance.
CascadeException(String) - Constructor for exception cascading.cascade.CascadeException
Constructor CascadeException creates a new CascadeException instance.
CascadeException(String, Throwable) - Constructor for exception cascading.cascade.CascadeException
Constructor CascadeException creates a new CascadeException instance.
CascadeException(Throwable) - Constructor for exception cascading.cascade.CascadeException
Constructor CascadeException creates a new CascadeException instance.
CascadeListener - Interface in cascading.cascade
Interface CascadeListener provides hooks for receiving events on various stages of a Cascade execution.
CascadeProps - Class in cascading.cascade
Class CascadeProps is a fluent helper class for setting various Cascade level properties passed through a CascadeConnector.
CascadeProps() - Constructor for class cascading.cascade.CascadeProps
 
cascadeProps() - Static method in class cascading.cascade.CascadeProps
Creates a new CascadeProps instance.
Cascades - Class in cascading.cascade
Class Cascades provides useful utilities for use in constructing Cascade and Flow instances via the CascadeConnector and FlowConnector, respectively.
Cascades() - Constructor for class cascading.cascade.Cascades
 
CascadeStats - Class in cascading.stats
Class CascadeStats collects Cascade specific statistics.
CascadeStats(Cascade, ClientState) - Constructor for class cascading.stats.CascadeStats
 
cascading - package cascading
 
CASCADING - Static variable in class cascading.util.Version
 
cascading.cascade - package cascading.cascade
 
cascading.cascade.planner - package cascading.cascade.planner
 
cascading.flow - package cascading.flow
 
cascading.flow.planner - package cascading.flow.planner
 
cascading.flow.planner.graph - package cascading.flow.planner.graph
 
cascading.flow.planner.iso - package cascading.flow.planner.iso
 
cascading.flow.planner.iso.assertion - package cascading.flow.planner.iso.assertion
 
cascading.flow.planner.iso.expression - package cascading.flow.planner.iso.expression
 
cascading.flow.planner.iso.finder - package cascading.flow.planner.iso.finder
 
cascading.flow.planner.iso.subgraph - package cascading.flow.planner.iso.subgraph
 
cascading.flow.planner.iso.subgraph.iterator - package cascading.flow.planner.iso.subgraph.iterator
 
cascading.flow.planner.iso.subgraph.partitioner - package cascading.flow.planner.iso.subgraph.partitioner
 
cascading.flow.planner.iso.transformer - package cascading.flow.planner.iso.transformer
 
cascading.flow.planner.process - package cascading.flow.planner.process
 
cascading.flow.planner.rule - package cascading.flow.planner.rule
 
cascading.flow.planner.rule.annotator - package cascading.flow.planner.rule.annotator
 
cascading.flow.planner.rule.assertion - package cascading.flow.planner.rule.assertion
 
cascading.flow.planner.rule.elementexpression - package cascading.flow.planner.rule.elementexpression
 
cascading.flow.planner.rule.expression - package cascading.flow.planner.rule.expression
 
cascading.flow.planner.rule.expressiongraph - package cascading.flow.planner.rule.expressiongraph
 
cascading.flow.planner.rule.partitioner - package cascading.flow.planner.rule.partitioner
 
cascading.flow.planner.rule.transformer - package cascading.flow.planner.rule.transformer
 
cascading.flow.planner.rule.util - package cascading.flow.planner.rule.util
 
cascading.flow.process - package cascading.flow.process
 
cascading.flow.stream - package cascading.flow.stream
 
cascading.flow.stream.annotations - package cascading.flow.stream.annotations
 
cascading.flow.stream.duct - package cascading.flow.stream.duct
 
cascading.flow.stream.element - package cascading.flow.stream.element
 
cascading.flow.stream.graph - package cascading.flow.stream.graph
 
cascading.flow.stream.util - package cascading.flow.stream.util
 
cascading.management - package cascading.management
 
cascading.management.annotation - package cascading.management.annotation
 
cascading.management.state - package cascading.management.state
 
cascading.operation - package cascading.operation
 
cascading.operation.aggregator - package cascading.operation.aggregator
 
cascading.operation.assertion - package cascading.operation.assertion
 
cascading.operation.buffer - package cascading.operation.buffer
 
cascading.operation.expression - package cascading.operation.expression
 
cascading.operation.filter - package cascading.operation.filter
 
cascading.operation.function - package cascading.operation.function
 
cascading.operation.regex - package cascading.operation.regex
 
cascading.operation.state - package cascading.operation.state
 
cascading.operation.text - package cascading.operation.text
 
cascading.pipe - package cascading.pipe
 
cascading.pipe.assembly - package cascading.pipe.assembly
 
cascading.pipe.joiner - package cascading.pipe.joiner
 
cascading.property - package cascading.property
 
cascading.provider - package cascading.provider
 
cascading.scheme - package cascading.scheme
 
cascading.scheme.util - package cascading.scheme.util
 
cascading.stats - package cascading.stats
 
cascading.stats.process - package cascading.stats.process
 
cascading.tap - package cascading.tap
 
cascading.tap.partition - package cascading.tap.partition
 
cascading.tap.type - package cascading.tap.type
 
cascading.tuple - package cascading.tuple
 
cascading.tuple.coerce - package cascading.tuple.coerce
 
cascading.tuple.collect - package cascading.tuple.collect
 
cascading.tuple.io - package cascading.tuple.io
 
cascading.tuple.type - package cascading.tuple.type
 
cascading.tuple.util - package cascading.tuple.util
 
cascading.util - package cascading.util
 
cascading.util.cache - package cascading.util.cache
 
cascading.util.jgrapht - package cascading.util.jgrapht
 
CASCADING_BUILD_NUMBER - Static variable in class cascading.util.Version
 
CASCADING_FLOW_ID - Static variable in interface cascading.flow.Flow
 
CASCADING_FLOW_NODE - Static variable in interface cascading.flow.FlowNode
 
CASCADING_FLOW_STEP_ID - Static variable in interface cascading.flow.FlowStep
 
CASCADING_RELEASE_MAJOR - Static variable in class cascading.util.Version
 
CASCADING_RELEASE_MINOR - Static variable in class cascading.util.Version
 
CASCADING_SERVICES - Static variable in class cascading.management.CascadingServices
 
CASCADING_SERVICES_JAR - Static variable in class cascading.management.CascadingServices
 
CascadingCache<Key,Value> - Interface in cascading.util.cache
Interface that defines a Cache.
CascadingException - Exception in cascading
Class CascadingException is the base class of all Cascading exceptions.
CascadingException() - Constructor for exception cascading.CascadingException
Constructor CascadingException creates a new CascadingException instance.
CascadingException(String) - Constructor for exception cascading.CascadingException
Constructor CascadingException creates a new CascadingException instance.
CascadingException(String, Throwable) - Constructor for exception cascading.CascadingException
Constructor CascadingException creates a new CascadingException instance.
CascadingException(Throwable) - Constructor for exception cascading.CascadingException
Constructor CascadingException creates a new CascadingException instance.
CascadingFactory<Config,Instance> - Interface in cascading.provider
Interface CascadingFactory defines a pluggable "factory" class that can be loaded by the FactoryLoader utility.
CascadingService - Interface in cascading.provider
Interface CascadingService defines a pluggable "service" class that can be loaded by the ServiceLoader utility.
cascadingServices - Variable in class cascading.flow.FlowSession
 
CascadingServices - Class in cascading.management
Class CascadingServices is the root class for pluggable services Cascading can call out to for distributed monitoring and management systems.
CascadingServices(Map<Object, Object>) - Constructor for class cascading.management.CascadingServices
 
CascadingServices.NullDocumentService - Class in cascading.management
Class NullDocumentService provides a null implementation.
CascadingServices.NullDocumentService() - Constructor for class cascading.management.CascadingServices.NullDocumentService
 
CascadingServices.NullMetricsService - Class in cascading.management
Class NullMetricsService provides a null implementation.
CascadingServices.NullMetricsService() - Constructor for class cascading.management.CascadingServices.NullMetricsService
 
CascadingStats<Child> - Class in cascading.stats
Class CascadingStats is the base class for all Cascading statistics gathering.
CascadingStats(String, ClientState) - Constructor for class cascading.stats.CascadingStats
 
CascadingStats.Status - Enum in cascading.stats
 
CascadingStats.Type - Enum in cascading.stats
 
CascadingTestCase - Class in cascading
Class CascadingTestCase is the base class for all Cascading tests.
CascadingTestCase() - Constructor for class cascading.CascadingTestCase
 
CascadingTestCase(String) - Constructor for class cascading.CascadingTestCase
 
CHARACTER - Static variable in class cascading.tuple.coerce.Coercions
 
CHARACTER_OBJECT - Static variable in class cascading.tuple.coerce.Coercions
 
CharacterCoerce - Class in cascading.tuple.coerce
 
CharacterCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.CharacterCoerce
 
CharacterObjectCoerce - Class in cascading.tuple.coerce
 
CharacterObjectCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.CharacterObjectCoerce
 
checkForUpdate(PlatformInfo) - Static method in class cascading.util.Update
 
checkForUpdate() - Method in class cascading.util.Update
 
Checkpoint - Class in cascading.pipe
The Checkpoint pipe, if supported by the current planner, will force data to be persisted at the point in the tuple stream an instance of Checkpoint is inserted into the pipe assembly.
Checkpoint(Pipe) - Constructor for class cascading.pipe.Checkpoint
Constructor Checkpoint creates a new Checkpoint pipe which inherits the name of its previous pipe.
Checkpoint(String, Pipe) - Constructor for class cascading.pipe.Checkpoint
Constructor Checkpoint creates a new Checkpoint pipe with the given name.
CHECKPOINT_TAP_DECORATOR_CLASS - Static variable in class cascading.flow.FlowConnectorProps
 
checkpoints - Variable in class cascading.flow.FlowDef
 
checkpointTapRootPath - Variable in class cascading.flow.planner.FlowPlanner
 
classPath - Variable in class cascading.flow.FlowDef
 
clean() - Method in class cascading.flow.planner.BaseFlowStep
 
clean(Config) - Method in class cascading.flow.planner.BaseFlowStep
 
clean(Object) - Method in class cascading.flow.process.ProcessFlowStep
 
cleanField(int, String, Type) - Method in interface cascading.scheme.util.FieldTypeResolver
 
cleanFields(Object[]) - Method in class cascading.scheme.util.DelimitedParser
 
cleanParsedLine(Object[]) - Method in class cascading.scheme.util.DelimitedParser
 
cleanPattern - Variable in class cascading.scheme.util.DelimitedParser
Field cleanPattern
cleansePathName(String) - Static method in class cascading.util.Util
 
cleanSplit(Object[], Pattern, Pattern, String) - Method in class cascading.scheme.util.DelimitedParser
Method cleanSplit will return a quote free array of String values, the given split array will be updated in place.
cleanup() - Method in class cascading.cascade.BaseCascade
 
cleanup() - Method in class cascading.flow.BaseFlow
 
cleanup() - Method in interface cascading.flow.Flow
 
cleanup() - Method in class cascading.flow.process.ProcessFlow
 
cleanup() - Method in class cascading.flow.stream.duct.Duct
 
cleanup() - Method in class cascading.flow.stream.element.ElementStage
 
cleanup() - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
cleanup() - Method in class cascading.flow.stream.element.OperatorStage
 
cleanup() - Method in class cascading.flow.stream.element.SinkStage
 
cleanup() - Method in class cascading.flow.stream.graph.StreamGraph
Calls cleanup starting at the head and working forwards
cleanup() - Method in interface cascading.management.UnitOfWork
 
cleanup(FlowProcess, OperationCall<Context>) - Method in class cascading.operation.BaseOperation
Method cleanup does nothing, and may safely be overridden.
cleanup(FlowProcess, OperationCall<Long>) - Method in class cascading.operation.Debug
 
cleanup(FlowProcess, OperationCall) - Method in class cascading.operation.filter.Logic
 
cleanup(FlowProcess, OperationCall) - Method in class cascading.operation.filter.Not
 
cleanup(FlowProcess, OperationCall) - Method in class cascading.operation.function.SetValue
 
cleanup(FlowProcess, OperationCall<Context>) - Method in interface cascading.operation.Operation
The cleanup method is called immediately after the current Operation instance is taken out of play processing Tuples.
cleanup(FlowProcess, OperationCall<CascadingCache<Tuple, Object>>) - Method in class cascading.pipe.assembly.Unique.FilterPartialDuplicates
 
cleanup() - Method in class cascading.stats.CascadingStats
Method cleanup destroys any resources allocated by this instance.
clear() - Method in class cascading.tuple.collect.SpillableTupleList
 
clear() - Method in class cascading.tuple.Tuple
Method clear empties this Tuple instance.
clear() - Method in class cascading.tuple.TupleListCollector
Method clear clears all Tuple instances from this instance.
clear() - Method in class cascading.util.cache.DirectMappedCache
 
clear() - Method in class cascading.util.cache.LRUHashMapCache
 
clear() - Method in class cascading.util.cache.OrderedHashMapCache
 
clear() - Method in class cascading.util.jgrapht.IntegerNameProvider
 
ClientState - Class in cascading.management.state
 
ClientState() - Constructor for class cascading.management.state.ClientState
 
clientState - Variable in class cascading.stats.CascadingStats
 
close() - Method in class cascading.tap.partition.BasePartitionTap.PartitionCollector
 
close() - Method in class cascading.tuple.io.TupleInputStream
 
close() - Method in interface cascading.tuple.io.TupleInputStream.ElementReader
 
close() - Method in class cascading.tuple.io.TupleOutputStream
 
close() - Method in interface cascading.tuple.io.TupleOutputStream.ElementWriter
 
close() - Method in class cascading.tuple.TupleChainIterator
Method close closes all underlying resources.
close() - Method in class cascading.tuple.TupleEntryChainIterator
Method close closes all underlying resources.
close() - Method in class cascading.tuple.TupleEntryCollector
Method close closes the underlying resource being written to.
close() - Method in class cascading.tuple.TupleEntryIterableChainIterator
Method close closes all underlying resources.
close() - Method in class cascading.tuple.TupleEntrySchemeCollector
 
close() - Method in class cascading.tuple.TupleEntrySchemeIterator
 
close() - Method in class cascading.util.SingleCloseableInputIterator
 
close() - Method in class cascading.util.SingleValueCloseableIterator
 
CloseableIterator<V> - Interface in cascading.util
Interface CloseableIterator is a helper interface granting an Iterator a close method.
closeCollector(String) - Method in class cascading.tap.partition.BasePartitionTap.PartitionCollector
 
closeCurrent() - Method in class cascading.tuple.TupleChainIterator
 
closeCurrent() - Method in class cascading.tuple.TupleEntryChainIterator
 
closeCurrent() - Method in class cascading.tuple.TupleEntryIterableChainIterator
 
CloseReducingDuct<Group,Incoming,Outgoing> - Class in cascading.flow.stream.duct
 
CloseReducingDuct(Duct<Outgoing, ?>) - Constructor for class cascading.flow.stream.duct.CloseReducingDuct
 
closeTrapCollectors() - Method in class cascading.flow.FlowProcess
 
closeTrapCollectors() - Method in class cascading.flow.FlowProcessWrapper
 
CloseWindow - Interface in cascading.flow.stream.duct
 
closure - Variable in class cascading.flow.stream.element.MemorySpliceGate
 
Coerce - Class in cascading.pipe.assembly
Class Coerce is a SubAssembly that will coerce all incoming Tuple values to the given types.
Coerce(Pipe, Class...) - Constructor for class cascading.pipe.assembly.Coerce
Constructor Coerce creates a new Coerce instance that will coerce all input Tuple values.
Coerce(Pipe, Fields, Class...) - Constructor for class cascading.pipe.assembly.Coerce
Constructor Coerce creates a new Coerce instance that will only coerce the given coerceFields Tuple values.
Coerce(Pipe, Fields) - Constructor for class cascading.pipe.assembly.Coerce
Constructor Coerce creates a new Coerce instance that will only coerce the given coerceFields Tuple values.
coerce(Object) - Method in class cascading.tuple.coerce.BigDecimalCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.BooleanCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.BooleanObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.CharacterCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.CharacterObjectCoerce
 
coerce(Object, Type) - Static method in class cascading.tuple.coerce.Coercions
Method coerce will coerce the given value to the given type using any CoercibleType mapping available.
coerce(CoercibleType, Object, Type) - Static method in class cascading.tuple.coerce.Coercions
Method coerce will coerce the given value to the given type using the given CoercibleType.
coerce(Object, Type) - Method in class cascading.tuple.coerce.Coercions.Coerce
 
coerce(Object) - Method in class cascading.tuple.coerce.Coercions.Coerce
 
coerce(Object) - Method in class cascading.tuple.coerce.DoubleCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.DoubleObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.FloatCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.FloatObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.IntegerCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.IntegerObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.LongCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.LongObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.ObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.ShortCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.ShortObjectCoerce
 
coerce(Object) - Method in class cascading.tuple.coerce.StringCoerce
 
coerce(Object, Type) - Method in interface cascading.tuple.type.CoercibleType
 
coerce(Object, Type) - Method in class cascading.tuple.type.DateType
 
coerceParsedLine(String, Object[]) - Method in class cascading.scheme.util.DelimitedParser
 
coercibleArray(Fields) - Static method in class cascading.tuple.coerce.Coercions
Method coercibleArray will return an array of CoercibleType instances based on the given field type information.
coercibleArray(int, Type[]) - Static method in class cascading.tuple.coerce.Coercions
Method coercibleArray will return an array of CoercibleType instances based on the given type array.
coercibles - Variable in class cascading.scheme.util.DelimitedParser
Fields coercibles
CoercibleType<Canonical> - Interface in cascading.tuple.type
Interface CoercibleType allows Fields instances to be extended with custom type information.
coercibleTypeFor(Type) - Static method in class cascading.tuple.coerce.Coercions
Method coercibleTypeFor returns the CoercibleType for the given Type instance.
Coercions - Class in cascading.tuple.coerce
Coercions class is a helper class for managing primitive value coercions.
Coercions() - Constructor for class cascading.tuple.coerce.Coercions
 
coercions - Static variable in class cascading.tuple.coerce.Coercions
 
Coercions.Coerce<T> - Class in cascading.tuple.coerce
 
Coercions.Coerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.Coercions.Coerce
 
CoGroup - Class in cascading.pipe
The CoGroup pipe allows for two or more tuple streams to join into a single stream via an optional Joiner.
CoGroup(Pipe, Fields, Pipe, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, Pipe, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, Pipe, Fields, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, Pipe, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, Pipe, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe...) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe[], Fields[]) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe[], Fields[], Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe[], Fields[], Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe[], Fields[]) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe[], Fields[], Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe[], Fields[], Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe[], Fields[], Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe[], Fields[], Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, Pipe, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe...) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, int, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(Pipe, Fields, int, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, int, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(Pipe, Fields, int, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(Pipe, Fields, int, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(Pipe, Fields, int) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(String, Pipe, Fields, int, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(String, Pipe, Fields, int, Fields, Fields) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, int, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(String, Pipe, Fields, int, Fields, Fields, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance.
CoGroup(String, Pipe, Fields, int, Joiner) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroup(String, Pipe, Fields, int) - Constructor for class cascading.pipe.CoGroup
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
Collapsing - Interface in cascading.flow.stream.duct
Collapsing marks a Duct as collapsing start/complete events from multiple incoming paths
collect(TupleEntry) - Method in class cascading.tap.partition.BasePartitionTap.PartitionCollector
 
collect(TupleEntry) - Method in class cascading.tuple.TupleEntryCollector
 
collect(TupleEntry) - Method in class cascading.tuple.TupleEntrySchemeCollector
 
collect(TupleEntry) - Method in class cascading.tuple.TupleListCollector
 
commitResource(Config) - Method in class cascading.tap.DecoratorTap
 
commitResource(Config) - Method in class cascading.tap.MultiSinkTap
 
commitResource(Config) - Method in class cascading.tap.partition.BasePartitionTap
 
commitResource(Config) - Method in class cascading.tap.SourceTap
 
commitResource(Config) - Method in class cascading.tap.Tap
Method commitResource allows the underlying resource to be notified when all write processing is successful so that any additional cleanup or processing may be completed.
commitSinks() - Method in class cascading.flow.planner.BaseFlowStep
 
compare(FlowNode, FlowNode) - Method in class cascading.flow.planner.process.FlowNodeGraph.FlowNodeComparator
 
compare(Tuple, Tuple) - Method in class cascading.flow.stream.util.SparseTupleComparator
 
compare(Comparable, Comparable) - Method in class cascading.operation.aggregator.ExtremaValueBase
Allows subclasses to provide own comparison method.
compare(Comparable, Comparable) - Method in class cascading.operation.aggregator.MaxValue
 
compare(Comparable, Comparable) - Method in class cascading.operation.aggregator.MinValue
 
compare(Tuple, Tuple) - Method in class cascading.tuple.Fields
 
compare(T, T) - Method in interface cascading.tuple.StreamComparator
 
compare(Comparable, Comparable) - Method in class cascading.util.NullNotEquivalentComparator
 
compareSet(String[], String, String) - Method in class cascading.management.CascadingServices.NullMetricsService
 
compareSet(String[], int, int) - Method in class cascading.management.CascadingServices.NullMetricsService
 
compareSet(String[], long, long) - Method in class cascading.management.CascadingServices.NullMetricsService
 
compareSet(String[], String, String) - Method in interface cascading.management.MetricsService
 
compareSet(String[], int, int) - Method in interface cascading.management.MetricsService
 
compareSet(String[], long, long) - Method in interface cascading.management.MetricsService
 
compareTo(PlatformInfo) - Method in class cascading.flow.planner.PlatformInfo
 
compareTo(Object) - Method in class cascading.flow.stream.element.GroupingSpliceGate.DelegatedTuple
 
compareTo(Fields) - Method in class cascading.tuple.Fields
Method compareTo compares this instance to the given Fields instance.
compareTo(Object) - Method in class cascading.tuple.Fields
Method compareTo implements Comparable.compareTo(Object).
compareTo(Object) - Method in class cascading.tuple.io.IndexTuple
 
compareTo(IndexTuple) - Method in class cascading.tuple.io.IndexTuple
 
compareTo(Object) - Method in class cascading.tuple.io.TuplePair
 
compareTo(Tuple) - Method in class cascading.tuple.io.TuplePair
 
compareTo(TuplePair) - Method in class cascading.tuple.io.TuplePair
Method compareTo compares this instance to the given TuplePair.
compareTo(Tuple) - Method in class cascading.tuple.Tuple
Method compareTo compares this Tuple to the given Tuple instance.
compareTo(Comparator[], Tuple) - Method in class cascading.tuple.Tuple
 
compareTo(Object) - Method in class cascading.tuple.Tuple
Method compareTo implements the Comparable.compareTo(Object) method.
Comparison<T> - Interface in cascading.tuple
The Comparison interface allows specific underlying type mechanisms to additionally return relevant Comparator implementations when required internally.
complete() - Method in class cascading.cascade.BaseCascade
 
complete() - Method in interface cascading.cascade.Cascade
Method complete begins the current Cascade process if method Cascade.start() was not previously called.
complete() - Method in class cascading.flow.BaseFlow
 
complete() - Method in interface cascading.flow.Flow
Method complete starts the current Flow instance if it has not be previously started, then block until completion.
complete() - Method in class cascading.flow.process.ProcessFlow
 
complete(Duct) - Method in class cascading.flow.stream.duct.Duct
 
complete(Duct) - Method in class cascading.flow.stream.duct.Fork
 
complete(Duct) - Method in class cascading.flow.stream.duct.OpenDuct
 
complete(Duct) - Method in class cascading.flow.stream.element.MemoryCoGroupGate
 
complete(Duct) - Method in class cascading.flow.stream.element.MemoryHashJoinGate
 
complete(Duct) - Method in class cascading.flow.stream.element.MergeStage
 
complete(Duct) - Method in class cascading.flow.stream.element.OperatorStage
 
complete(Duct) - Method in class cascading.flow.stream.element.SinkStage
 
complete() - Method in interface cascading.management.UnitOfWork
 
complete(UnitOfWork, int, TimeUnit) - Method in class cascading.management.UnitOfWorkExecutorStrategy
 
complete(UnitOfWork, int, TimeUnit) - Method in interface cascading.management.UnitOfWorkSpawnStrategy
 
complete(FlowProcess, AggregatorCall<Average.Context>) - Method in class cascading.operation.aggregator.Average
 
complete(FlowProcess, AggregatorCall<Context>) - Method in interface cascading.operation.Aggregator
Method complete will be issued last after every TupleEntry has been passed to the Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall) method.
complete(FlowProcess, AggregatorCall<Pair<Long[], Tuple>>) - Method in class cascading.operation.aggregator.Count
 
complete(FlowProcess, AggregatorCall<Tuple[]>) - Method in class cascading.operation.aggregator.ExtentBase
 
complete(FlowProcess, AggregatorCall<ExtremaValueBase.Context>) - Method in class cascading.operation.aggregator.ExtremaValueBase
 
complete(FlowProcess, AggregatorCall<Tuple[]>) - Method in class cascading.operation.aggregator.First
 
complete(FlowProcess, AggregatorCall<Pair<Double[], Tuple>>) - Method in class cascading.operation.aggregator.Sum
 
complete(FlowProcess, Tuple) - Method in interface cascading.pipe.assembly.AggregateBy.Functor
Method complete allows the final aggregate computation to be performed before the return value is collected.
complete(FlowProcess, AggregatorCall<AverageBy.AverageFinal.Context>) - Method in class cascading.pipe.assembly.AverageBy.AverageFinal
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.AverageBy.AveragePartials
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.CountBy.CountPartials
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.FirstBy.FirstPartials
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.MaxBy.MaxPartials
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.MinBy.MinPartials
 
complete(FlowProcess, Tuple) - Method in class cascading.pipe.assembly.SumBy.SumPartials
 
completeCount - Variable in class cascading.flow.stream.element.MergeStage
 
completeGroup(Duct, Outgoing) - Method in class cascading.flow.stream.duct.CloseReducingDuct
 
completeGroup(Duct, Result) - Method in interface cascading.flow.stream.duct.Reducing
 
completeGroup(Duct, TupleEntry) - Method in class cascading.flow.stream.element.AggregatorEveryStage
 
completeGroup(Duct, TupleEntry) - Method in class cascading.flow.stream.element.GroupAssertionEveryStage
 
ComponentAttributeProvider<T> - Interface in cascading.util.jgrapht
 
CompositeTap<Child extends Tap> - Interface in cascading.tap
Interface CompositeTap marks Tap classes as having child Tap instances.
ConcreteCall<C> - Class in cascading.operation
Class OperationCall is the common base class for FunctionCall, FilterCall, AggregatorCall, ValueAssertionCall, and GroupAssertionCall.
ConcreteCall() - Constructor for class cascading.operation.ConcreteCall
Constructor OperationCall creates a new OperationCall instance.
ConcreteCall(Fields) - Constructor for class cascading.operation.ConcreteCall
Constructor ConcreteCall creates a new ConcreteCall instance.
ConcreteCall(Fields, Fields) - Constructor for class cascading.operation.ConcreteCall
Constructor ConcreteCall creates a new ConcreteCall instance.
ConcreteCall(TupleEntry, TupleEntryCollector) - Constructor for class cascading.operation.ConcreteCall
Constructor OperationCall creates a new OperationCall instance.
ConcreteCall(ConcreteCall<C>) - Constructor for class cascading.operation.ConcreteCall
 
ConcreteCall<Context,IO> - Class in cascading.scheme
The concrete base class for SourceCall and SinkCall.
ConcreteCall() - Constructor for class cascading.scheme.ConcreteCall
 
config - Variable in class cascading.property.ConfigDef
 
configDef - Variable in class cascading.pipe.Pipe
 
ConfigDef - Class in cascading.property
The ConfigDef class allows for the creation of a configuration properties template to be applied to an existing properties configuration set.
ConfigDef() - Constructor for class cascading.property.ConfigDef
 
ConfigDef.Getter - Interface in cascading.property
 
ConfigDef.Mode - Enum in cascading.property
 
ConfigDef.Setter - Interface in cascading.property
 
configRuleRegistryDefaults(RuleRegistry) - Method in class cascading.flow.planner.FlowPlanner
 
configure() - Method in class cascading.flow.planner.BaseFlowStep
 
connect(Collection<Flow>) - Method in class cascading.cascade.CascadeConnector
Given any number of Flow objects, it will connect them and return a new Cascade instance.
connect(String, Collection<Flow>) - Method in class cascading.cascade.CascadeConnector
Given any number of Flow objects, it will connect them and return a new Cascade instance.
connect(Flow...) - Method in class cascading.cascade.CascadeConnector
Given any number of Flow objects, it will connect them and return a new Cascade instance.
connect(String, Flow...) - Method in class cascading.cascade.CascadeConnector
Given any number of Flow objects, it will connect them and return a new Cascade instance.
connect(CascadeDef) - Method in class cascading.cascade.CascadeConnector
 
connect(Tap, Tap, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the given source and sink Taps to the given pipe assembly.
connect(String, Tap, Tap, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the given source and sink Taps to the given pipe assembly.
connect(String, Tap, Tap, Tap, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the given source, sink, and trap Taps to the given pipe assembly.
connect(Map<String, Tap>, Tap, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(String, Map<String, Tap>, Tap, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(String, Map<String, Tap>, Tap, Map<String, Tap>, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the named source and trap Taps and sink Tap to the given pipe assembly.
connect(String, Tap, Tap, Map<String, Tap>, Pipe) - Method in class cascading.flow.FlowConnector
Method connect links the named trap Taps, source and sink Tap to the given pipe assembly.
connect(Tap, Map<String, Tap>, Collection<Pipe>) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(String, Tap, Map<String, Tap>, Collection<Pipe>) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(Tap, Map<String, Tap>, Pipe...) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(String, Tap, Map<String, Tap>, Pipe...) - Method in class cascading.flow.FlowConnector
Method connect links the named source Taps and sink Tap to the given pipe assembly.
connect(Map<String, Tap>, Map<String, Tap>, Pipe...) - Method in class cascading.flow.FlowConnector
Method connect links the named sources and sinks to the given pipe assembly.
connect(String, Map<String, Tap>, Map<String, Tap>, Pipe...) - Method in class cascading.flow.FlowConnector
Method connect links the named sources and sinks to the given pipe assembly.
connect(String, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>, Pipe...) - Method in class cascading.flow.FlowConnector
Method connect links the named sources, sinks and traps to the given pipe assembly.
connect(FlowDef) - Method in class cascading.flow.FlowConnector
 
CONNECTOR - Static variable in class cascading.util.DOTProcessGraphWriter
 
ConsecutiveTapsExpressionGraph - Class in cascading.flow.planner.rule.expressiongraph
 
ConsecutiveTapsExpressionGraph() - Constructor for class cascading.flow.planner.rule.expressiongraph.ConsecutiveTapsExpressionGraph
 
CONTAINER_ENABLED - Static variable in class cascading.management.CascadingServices
 
CONTAINER_EXCLUDE - Static variable in class cascading.management.CascadingServices
 
contains(Object) - Method in class cascading.tuple.collect.SpillableTupleList
 
contains(Fields) - Method in class cascading.tuple.Fields
Method contains returns true if this instance contains the field names and positions specified in the given fields instance.
contains(Class<T>, Collection) - Static method in class cascading.util.Util
 
contains(Class<T>, Iterator) - Static method in class cascading.util.Util
 
containsAll(Collection<?>) - Method in class cascading.tuple.collect.SpillableTupleList
 
containsEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
containsEdge(Scope) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
containsEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
containsEdge(Scope) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
containsEdge(FlowElement, FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
containsEdge(Scope) - Method in interface cascading.flow.planner.graph.ElementGraph
 
containsEdge(Process, Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
containsEdge(ProcessEdge) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
containsEdge(Process, Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
containsEdge(ProcessEdge) - Method in interface cascading.flow.planner.process.ProcessGraph
 
containsKey(Object) - Method in class cascading.util.cache.DirectMappedCache
 
containsKey(Object) - Method in class cascading.util.cache.LRUHashMapCache
 
containsKey(Object) - Method in class cascading.util.cache.OrderedHashMapCache
 
containsKey(K) - Method in class cascading.util.MultiMap
 
containsNull(Object[]) - Static method in class cascading.util.Util
 
containsPipeNamed(String) - Method in interface cascading.flow.FlowStep
Returns true if this FlowStep contains a pipe/branch with the given name.
containsPipeNamed(String) - Method in class cascading.flow.planner.BaseFlowStep
 
containsValue(Object) - Method in class cascading.util.cache.DirectMappedCache
 
containsValue(Object) - Method in class cascading.util.cache.LRUHashMapCache
 
containsValue(Object) - Method in class cascading.util.cache.OrderedHashMapCache
 
containsVertex(FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
containsVertex(FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
containsVertex(FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
containsVertex(Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
containsVertex(Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
containsWhitespace(String) - Static method in class cascading.util.Util
 
ContractedGraphTransformer - Class in cascading.flow.planner.iso.transformer
 
ContractedGraphTransformer(ExpressionGraph) - Constructor for class cascading.flow.planner.iso.transformer.ContractedGraphTransformer
 
ContractedGraphTransformer(GraphTransformer, ExpressionGraph) - Constructor for class cascading.flow.planner.iso.transformer.ContractedGraphTransformer
 
contractedMatchExpression - Variable in class cascading.flow.planner.rule.RuleExpression
 
ContractedTransformer - Class in cascading.flow.planner.iso.transformer
 
ContractedTransformer(ExpressionGraph) - Constructor for class cascading.flow.planner.iso.transformer.ContractedTransformer
 
contractedTransformer - Variable in class cascading.flow.planner.rule.RuleTransformer
 
contractionExpression - Variable in class cascading.flow.planner.rule.RuleExpression
 
contractionGraph - Variable in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
CONVERT_DOT_TO_PDF - Static variable in class cascading.util.Util
On OS X only, and if the graphviz dot binary is installed, when true, dot will be invoked to convert the dot file to a pdf document.
copy(FlowDef, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>) - Static method in class cascading.flow.Flows
 
copy(T[]) - Static method in class cascading.util.Util
 
copyComparators(Fields, Fields...) - Static method in class cascading.tuple.Fields
 
copyConfig(C) - Method in class cascading.flow.FlowProcess
 
copyConfig(Object) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
copyConfig(C) - Method in class cascading.flow.FlowProcessWrapper
 
copyElementGraph() - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
copyElementGraph() - Method in class cascading.flow.planner.graph.ElementDirectedGraph
 
copyElementGraph() - Method in interface cascading.flow.planner.graph.ElementGraph
 
copyElementGraph() - Method in class cascading.flow.planner.graph.ElementMaskSubGraph
 
copyElementGraph() - Method in class cascading.flow.planner.graph.ElementMultiGraph
 
copyElementGraph() - Method in class cascading.flow.planner.graph.ElementSubGraph
 
copyElementGraph() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
copyFields(Scope) - Method in class cascading.flow.planner.Scope
Method copyFields copies the given Scope instance fields to this instance.
copyWith(Config) - Method in class cascading.flow.FlowProcess
 
copyWith(Object) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
copyWith(Config) - Method in class cascading.flow.FlowProcessWrapper
 
count - Variable in class cascading.flow.stream.element.MemorySpliceGate
 
Count - Class in cascading.operation.aggregator
Class Count is an Aggregator that calculates the number of items in the current group.
Count() - Constructor for class cascading.operation.aggregator.Count
Constructor Count creates a new Count instance using the default field declaration of name 'count'.
Count(Fields) - Constructor for class cascading.operation.aggregator.Count
Constructor Count creates a new Count instance and returns a field with the given fieldDeclaration name.
count - Variable in class cascading.operation.filter.Limit.Context
 
countAllEventingPathsTo(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
Returns all free paths to the current duct, usually a GroupGate.
CountBy - Class in cascading.pipe.assembly
Class CountBy is used to count duplicates in a tuple stream, where "duplicates" means all tuples with the same values for the groupingFields fields.
CountBy(Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, Fields) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe, Fields, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe, Fields, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(Pipe[], Fields, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy(String, Pipe[], Fields, Fields, Fields, CountBy.Include, int) - Constructor for class cascading.pipe.assembly.CountBy
Constructor CountBy creates a new CountBy instance.
CountBy.CountPartials - Class in cascading.pipe.assembly
Class CountPartials is a AggregateBy.Functor that is used to count observed duplicates from the tuple stream.
CountBy.CountPartials(Fields) - Constructor for class cascading.pipe.assembly.CountBy.CountPartials
Constructor CountPartials creates a new CountPartials instance.
CountBy.CountPartials(Fields, CountBy.Include) - Constructor for class cascading.pipe.assembly.CountBy.CountPartials
 
CountBy.Include - Enum in cascading.pipe.assembly
 
countDownLatch() - Method in class cascading.flow.stream.element.MemoryHashJoinGate
 
Counter - Class in cascading.operation.state
Class Counter is a Filter that increments a given Enum counter by 1 or by the given increment value.
Counter(Enum) - Constructor for class cascading.operation.state.Counter
Constructor Counter creates a new Counter instance.
Counter(Enum, int) - Constructor for class cascading.operation.state.Counter
Constructor Counter creates a new Counter instance.
Counter(String, String) - Constructor for class cascading.operation.state.Counter
 
Counter(String, String, int) - Constructor for class cascading.operation.state.Counter
 
create(ElementGraph, FlowElement) - Method in class cascading.flow.planner.FlowPlanner.TempTapElementFactory
 
create(ElementGraph, FlowElement) - Method in interface cascading.flow.planner.iso.transformer.ElementFactory
 
create(FlowProcess<? extends Config>) - Method in interface cascading.provider.CascadingFactory
Method create will return a new instance of the type create by this factory.
create(List<Object>) - Static method in class cascading.tuple.Tuples
 
create(FlowProcess<? extends Config>) - Method in class cascading.util.cache.BaseCacheFactory
 
create(FlowProcess) - Method in class cascading.util.cache.DirectMappedCacheFactory
 
create(FlowProcess) - Method in class cascading.util.cache.LRUHashMapCacheFactory
 
create(FlowProcess) - Method in class cascading.util.cache.OrderedHashMapCacheFactory
 
createArgumentsBuilder(Fields, Fields) - Method in class cascading.flow.stream.element.OperatorStage
 
createBlockingJoinGate(HashJoin) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createBoundaryStage(Boundary, IORole) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createCallable(RuleRegistry) - Method in class cascading.flow.planner.rule.RuleSetExec
 
createCallables() - Method in class cascading.flow.planner.rule.RuleSetExec
 
createCleanPatternFor(String) - Method in class cascading.scheme.util.DelimitedParser
Method createCleanPatternFor creates a regex Pattern for removing quote characters from a String.
createClientState(FlowProcess) - Method in class cascading.flow.planner.BaseFlowStep
 
createClientState(String) - Method in class cascading.management.CascadingServices
 
createCoGroupGate(CoGroup, IORole) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createCollection() - Method in class cascading.util.MultiMap
 
createCollection() - Method in class cascading.util.SetMultiMap
 
createCollection() - Method in class cascading.util.SortedListMultiMap
 
createComposite(Tuple...) - Static method in class cascading.tuple.util.TupleViews
 
createComposite(Fields...) - Static method in class cascading.tuple.util.TupleViews
 
createComposite(Fields[], Tuple[]) - Static method in class cascading.tuple.util.TupleViews
 
createConfig(Map<Object, Object>, Config) - Method in class cascading.flow.BaseFlow
 
createDefaultNarrowBuilder(Fields, Fields) - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
createDefaultNarrowBuilder(Fields, Fields) - Method in class cascading.flow.stream.element.MemorySpliceGate
 
createDefaultRuleRegistrySet() - Method in class cascading.flow.FlowConnector
 
createDirectedSpecifics() - Method in class cascading.flow.planner.graph.ElementMultiGraph.DirectedMultiGraph
 
createDocumentService() - Method in class cascading.management.CascadingServices
 
createEscapePatternFor(String) - Method in class cascading.scheme.util.DelimitedParser
Method createEscapePatternFor creates a regex Pattern cleaning quote escapes from a String.
createExpressionGraphPartitioner(ExpressionGraph, ExpressionGraph, ElementAnnotation[]) - Method in class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
createExpressionGraphPartitioner(ExpressionGraph, ExpressionGraph, ElementAnnotation[]) - Method in class cascading.flow.planner.rule.partitioner.UniquePathRulePartitioner
 
createFlow(FlowDef) - Method in class cascading.flow.planner.FlowPlanner
 
createFlowElementGraph(FlowDef, Pipe[]) - Method in class cascading.flow.planner.FlowPlanner
 
createFlowNode(FlowElementGraph, ElementGraph, List<? extends ElementGraph>) - Method in class cascading.flow.planner.FlowPlanner
 
createFlowNodeGraph(FlowPlanner<?, ?>, FlowElementGraph, Map<ElementGraph, List<? extends ElementGraph>>, List<? extends ElementGraph>) - Method in class cascading.flow.planner.process.FlowStepGraph
 
createFlowPlanner() - Method in class cascading.flow.FlowConnector
 
createFlowStep(ElementGraph, FlowNodeGraph) - Method in class cascading.flow.planner.FlowPlanner
 
createFlowStepJob(ClientState, FlowProcess<Config>, Config) - Method in class cascading.flow.planner.BaseFlowStep
 
createFlowStepJob(ClientState, FlowProcess, Object) - Method in class cascading.flow.process.ProcessFlowStep
 
createFlowThread(String) - Method in class cascading.flow.BaseFlow
 
createFork(Duct[]) - Method in class cascading.flow.stream.graph.StreamGraph
 
createGroupByGate(GroupBy, IORole) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createHashJoinGate(HashJoin) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createHashMap() - Static method in class cascading.util.Util
 
createID(String) - Static method in class cascading.util.Util
 
createID(byte[]) - Static method in class cascading.util.Util
Method CreateID returns a HEX hash of the given bytes with length 32 characters long.
createIdentitySet() - Static method in class cascading.util.Util
 
createIdentitySet(Collection<V>) - Static method in class cascading.util.Util
 
createInitializedConfig(FlowProcess<Config>, Config) - Method in class cascading.flow.planner.BaseFlowStep
Public for testing.
createInitializedConfig(FlowProcess, Object) - Method in class cascading.flow.process.ProcessFlowStep
 
createKeySet() - Method in class cascading.flow.stream.element.MemorySpliceGate
 
createKeyValuesArray() - Method in class cascading.flow.stream.element.MemorySpliceGate
This lets us just replace an old map and let the gc cleanup, vs clearing each map
createMap() - Method in class cascading.util.EnumMultiMap
 
createMap() - Method in class cascading.util.MultiMap
 
createMap() - Method in class cascading.util.SetMultiMap
 
createMap() - Method in class cascading.util.SortedListMultiMap
 
createMergeStage(Merge, IORole) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createMetricsService() - Method in class cascading.management.CascadingServices
 
createNarrow(int[]) - Static method in class cascading.tuple.util.TupleViews
 
createNarrow(int[], Tuple) - Static method in class cascading.tuple.util.TupleViews
 
createNarrowBuilder(Fields, Fields) - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
createNextFor(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
createNonBlockingJoinGate(HashJoin) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createNulledBuilder(Fields, Fields) - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
createObjectArray() - Static method in class cascading.tuple.util.TupleViews
 
createObjectArray(Object...) - Static method in class cascading.tuple.util.TupleViews
 
createOpenReducingWindow(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
createOpenWindow(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
createOutgoingBuilder(Operator, Fields, Fields, Fields, Fields, Fields) - Method in class cascading.flow.stream.element.OperatorStage
 
createOverride(Fields, Fields) - Static method in class cascading.tuple.util.TupleViews
 
createOverride(Fields, Tuple, Fields, Tuple) - Static method in class cascading.tuple.util.TupleViews
 
createOverride(int[], Tuple, int[], Tuple) - Static method in class cascading.tuple.util.TupleViews
 
createProperties(Iterable<Map.Entry<String, String>>) - Static method in class cascading.property.PropertyUtil
 
createProperties(Map<Object, Object>, Properties) - Static method in class cascading.property.PropertyUtil
 
createProtectedObject(Class, Object[], Class[]) - Static method in class cascading.util.Util
 
createProvider(String) - Method in class cascading.provider.ProviderLoader
 
createResource(FlowProcess<? extends Config>) - Method in class cascading.tap.DecoratorTap
 
createResource(Config) - Method in class cascading.tap.DecoratorTap
 
createResource(Config) - Method in class cascading.tap.MultiSinkTap
 
createResource(Config) - Method in class cascading.tap.partition.BasePartitionTap
 
createResource(Config) - Method in class cascading.tap.SourceTap
 
createResource(FlowProcess<? extends Config>) - Method in class cascading.tap.Tap
Method createResource creates the underlying resource.
createResource(Config) - Method in class cascading.tap.Tap
Method createResource creates the underlying resource.
createSinkStage(Tap) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
createSplit(String, Pattern, int) - Method in class cascading.scheme.util.DelimitedParser
Method createSplit will split the given value with the given splitPattern.
createSplitPatternFor(String, String) - Method in class cascading.scheme.util.DelimitedParser
Method createSplitPatternFor creates a regex Pattern for splitting a line of text into its component parts using the given delimiter and quote Strings.
createStepStats(ClientState) - Method in class cascading.flow.planner.FlowStepJob
 
createTupleCollection(Tuple) - Method in class cascading.tuple.collect.SpillableTupleMap
 
createTupleEntrySchemeCollector(FlowProcess<? extends Config>, Tap, String, long) - Method in class cascading.tap.partition.BasePartitionTap
 
createTupleEntrySchemeIterator(FlowProcess<? extends Config>, Tap, String, Input) - Method in class cascading.tap.partition.BasePartitionTap
 
createTupleInputStream(File) - Method in class cascading.tuple.collect.SpillableTupleList
 
createTupleMap() - Method in class cascading.flow.stream.element.MemorySpliceGate
 
createTupleOutputStream(File) - Method in class cascading.tuple.collect.SpillableTupleList
 
createUniqueID() - Static method in class cascading.util.Util
 
createUniqueIDWhichStartsWithAChar() - Static method in class cascading.util.Util
 

D

dateFormatString - Variable in class cascading.tuple.type.DateType
Field dateFormatString
DateFormatter - Class in cascading.operation.text
Class DateFormatter is used to convert a date timestamp to a formatted string, where a timestamp is the number of milliseconds since January 1, 1970, 00:00:00 GMT, using the SimpleDateFormat syntax.
DateFormatter(String) - Constructor for class cascading.operation.text.DateFormatter
Constructor DateParser creates a new DateParser instance that creates a simple long time stamp of the parsed date.
DateFormatter(Fields, String) - Constructor for class cascading.operation.text.DateFormatter
Constructor DateParser creates a new DateParser instance.
DateFormatter(Fields, String, TimeZone) - Constructor for class cascading.operation.text.DateFormatter
Constructor DateFormatter creates a new DateFormatter instance.
DateFormatter(Fields, String, TimeZone, Locale) - Constructor for class cascading.operation.text.DateFormatter
Constructor DateFormatter creates a new DateFormatter instance.
DateOperation - Class in cascading.operation.text
Class DateOperation is the base class for DateFormatter and DateParser.
DateOperation(int, Fields, String) - Constructor for class cascading.operation.text.DateOperation
Constructor DateOperation creates a new DateOperation instance.
DateOperation(int, Fields, String, TimeZone, Locale) - Constructor for class cascading.operation.text.DateOperation
Constructor DateOperation creates a new DateOperation instance.
DateParser - Class in cascading.operation.text
Class DateParser is used to convert a text date string to a timestamp, the number of milliseconds since January 1, 1970, 00:00:00 GMT, using the SimpleDateFormat syntax.
DateParser(String) - Constructor for class cascading.operation.text.DateParser
Constructor DateParser creates a new DateParser instance that creates a simple long time stamp of the parsed date.
DateParser(Fields, String) - Constructor for class cascading.operation.text.DateParser
Constructor DateParser creates a new DateParser instance.
DateParser(Fields, int[], String) - Constructor for class cascading.operation.text.DateParser
Constructor DateParser creates a new DateParser instance, where calendarFields is an int[] of Calendar field values.
DateParser(Fields, TimeZone, Locale, String) - Constructor for class cascading.operation.text.DateParser
Constructor DateParser creates a new DateParser instance, where zone and locale are passed to the internal SimpleDateFormat instance.
DateParser(Fields, int[], TimeZone, Locale, String) - Constructor for class cascading.operation.text.DateParser
Constructor DateParser creates a new DateParser instance, where calendarFields is an int[] of Calendar field values.
DateType - Class in cascading.tuple.type
Class DateCoercibleType is an implementation of CoercibleType.
DateType(String, TimeZone, Locale) - Constructor for class cascading.tuple.type.DateType
Create a new DateType instance.
DateType(String, TimeZone) - Constructor for class cascading.tuple.type.DateType
 
DateType(String) - Constructor for class cascading.tuple.type.DateType
Create a new DateType instance.
Debug - Class in cascading.operation
Class Debug is a Filter that will never remove an item from a stream, but will print the Tuple to either stdout or stderr.
Debug() - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to stderr by default, and does not print the Tuple instance field names.
Debug(String) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to stderr by default, and does not print the Tuple instance field names.
Debug(String, boolean) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to stderr and will print the current Tuple instance field names if printFields is true.
Debug(boolean) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to stderr and will print the current Tuple instance field names if printFields is true.
Debug(Debug.Output) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to the declared stream and does not print the Tuple field names.
Debug(Debug.Output, String) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to the declared stream and does not print the Tuple field names.
Debug(Debug.Output, String, boolean) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to the declared stream and will print the Tuple instances field names if printFields is true.
Debug(Debug.Output, boolean) - Constructor for class cascading.operation.Debug
Constructor Debug creates a new Debug instance that prints to the declared stream and will print the Tuple instances field names if printFields is true.
Debug.Output - Enum in cascading.operation
 
DEBUG_LEVEL - Static variable in class cascading.flow.FlowConnectorProps
 
debugLevel - Variable in class cascading.flow.FlowDef
 
DebugLevel - Enum in cascading.operation
Enum DebugLevel designates the level of a given Debug instance.
declaredFields - Variable in class cascading.pipe.Splice
Field declaredFields
DeclaresResults - Interface in cascading.flow.planner
 
DecoratedElementGraph - Class in cascading.flow.planner.graph
 
DecoratedElementGraph(ElementGraph) - Constructor for class cascading.flow.planner.graph.DecoratedElementGraph
 
DecoratorTap<MetaInfo,Config,Input,Output> - Class in cascading.tap
Class DecoratorTap wraps a given Tap instance, delegating all calls to the original.
DecoratorTap(MetaInfo, Tap<Config, Input, Output>) - Constructor for class cascading.tap.DecoratorTap
Creates a new Tap instance, wrapping the given Tap, and associates the given MetaInfo type with the wrapped Tap instance.
DecoratorTap(Tap<Config, Input, Output>) - Constructor for class cascading.tap.DecoratorTap
Creates a new Tap instance, wrapping the given Tap, and associates the given MetaInfo type with the wrapped Tap instance.
DEFAULT_CACHE_FACTORY_CLASS - Static variable in class cascading.pipe.assembly.AggregateByProps
default factory class for creating caches.
DEFAULT_CACHE_FACTORY_CLASS - Static variable in class cascading.pipe.assembly.UniqueProps
default factory class for creating caches.
DEFAULT_CAPACITY - Static variable in class cascading.util.cache.BaseCacheFactory
default capacity for all caches.
DEFAULT_DELIM - Static variable in class cascading.operation.regex.RegexMatcher
 
DEFAULT_ELEMENT_COMPARATOR - Static variable in class cascading.flow.FlowProps
 
DEFAULT_PLAN_COMPARATOR - Static variable in class cascading.flow.planner.rule.RuleSetExec
 
DEFAULT_PROPERTIES - Static variable in class cascading.management.CascadingServices
 
DEFAULT_THRESHOLD - Static variable in class cascading.pipe.assembly.MaxBy
Deprecated.
DEFAULT_TIMEOUT - Static variable in class cascading.flow.planner.rule.RuleSetExec
 
DEFAULT_TRANSFORM_RECURSION_DEPTH_MAX - Static variable in class cascading.flow.planner.iso.transformer.RecursiveGraphTransformer
 
defaultAssertionLevel - Variable in class cascading.flow.planner.FlowPlanner
Field assertionLevel
defaultDebugLevel - Variable in class cascading.flow.planner.FlowPlanner
Field debugLevel
defaultListThreshold - Static variable in class cascading.tuple.collect.SpillableProps
 
defaultMapInitialCapacity - Static variable in class cascading.tuple.collect.SpillableProps
 
defaultMapLoadFactor - Static variable in class cascading.tuple.collect.SpillableProps
 
defaultMapThreshold - Static variable in class cascading.tuple.collect.SpillableProps
 
defaultProperties - Variable in class cascading.flow.planner.FlowPlanner
Field properties
deleteCheckpointsIfNotUpdate() - Method in class cascading.flow.BaseFlow
 
deleteCheckpointsIfReplace() - Method in class cascading.flow.BaseFlow
 
deleteResource(FlowProcess<? extends Config>) - Method in class cascading.tap.DecoratorTap
 
deleteResource(Config) - Method in class cascading.tap.DecoratorTap
 
deleteResource(Config) - Method in class cascading.tap.MultiSinkTap
 
deleteResource(Config) - Method in class cascading.tap.partition.BasePartitionTap
 
deleteResource(Config) - Method in class cascading.tap.SourceTap
 
deleteResource(FlowProcess<? extends Config>) - Method in class cascading.tap.Tap
Method deleteResource deletes the resource represented by this instance.
deleteResource(Config) - Method in class cascading.tap.Tap
Method deleteResource deletes the resource represented by this instance.
deleteSinks() - Method in class cascading.flow.BaseFlow
Method deleteSinks deletes all sinks, whether or not they are configured for SinkMode.UPDATE.
deleteSinksIfNotUpdate() - Method in class cascading.flow.BaseFlow
Method deleteSinksIfNotUpdate deletes all sinks if they are not configured with the SinkMode.UPDATE flag.
deleteSinksIfReplace() - Method in class cascading.flow.BaseFlow
 
deleteTrapsIfNotUpdate() - Method in class cascading.flow.BaseFlow
 
deleteTrapsIfReplace() - Method in class cascading.flow.BaseFlow
 
DelimitedParser - Class in cascading.scheme.util
Class DelimitedParser is a base class for parsing text delimited files.
DelimitedParser(String, String, Class[]) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedParser(String, String, Class[], boolean, boolean) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedParser(String, String, FieldTypeResolver) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedParser(String, String, Class[], boolean, boolean, FieldTypeResolver) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedParser(String, String, Class[], boolean, boolean, Fields, Fields) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedParser(String, String, Class[], boolean, boolean, Fields, Fields, FieldTypeResolver) - Constructor for class cascading.scheme.util.DelimitedParser
 
DelimitedPartition - Class in cascading.tap.partition
DelimitedPartition is an implementation of the Partition interface that allows for simple text delimited paths as partitions.
DelimitedPartition(Fields, String) - Constructor for class cascading.tap.partition.DelimitedPartition
 
DelimitedPartition(Fields) - Constructor for class cascading.tap.partition.DelimitedPartition
 
delimiter - Variable in class cascading.operation.regex.RegexMatcher
 
delimiter - Variable in class cascading.scheme.util.DelimitedParser
Field delimiter *
deregisterShutdownHook() - Static method in class cascading.util.ShutdownUtil
 
DESCRIPTION - Static variable in interface cascading.flow.FlowDescriptors
Briefly describes the current Flow *
diffConfigIntoMap(C, C) - Method in class cascading.flow.FlowProcess
 
diffConfigIntoMap(Object, Object) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
diffConfigIntoMap(C, C) - Method in class cascading.flow.FlowProcessWrapper
 
differenceIdentity(Set<T>, Set<T>) - Static method in class cascading.util.Util
 
directed(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
DirectMappedCache<Key,Value> - Class in cascading.util.cache
DirectMappedCache is an implementation of the CascadingCache interface following the semantics of http://en.wikipedia.org/wiki/CPU_cache#Direct-mapped_cache.
DirectMappedCache() - Constructor for class cascading.util.cache.DirectMappedCache
 
DirectMappedCacheFactory - Class in cascading.util.cache
Concrete sub-class of BaseCacheFactory for creating DirectMappedCache instances.
DirectMappedCacheFactory() - Constructor for class cascading.util.cache.DirectMappedCacheFactory
 
Discard - Class in cascading.pipe.assembly
Class Discard is a SubAssembly that will retain all incoming fields except those given on the constructor.
Discard(Pipe, Fields) - Constructor for class cascading.pipe.assembly.Discard
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertEquals
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertEqualsAll
 
doAssert(FlowProcess, ValueAssertionCall<ScriptOperation.Context>) - Method in class cascading.operation.assertion.AssertExpression
 
doAssert(FlowProcess, GroupAssertionCall<AssertGroupBase.Context>) - Method in class cascading.operation.assertion.AssertGroupBase
 
doAssert(FlowProcess, ValueAssertionCall<Matcher>) - Method in class cascading.operation.assertion.AssertMatches
 
doAssert(FlowProcess, ValueAssertionCall<Matcher>) - Method in class cascading.operation.assertion.AssertMatchesAll
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertNotEquals
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertNotNull
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertNull
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertSizeEquals
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertSizeLessThan
 
doAssert(FlowProcess, ValueAssertionCall) - Method in class cascading.operation.assertion.AssertSizeMoreThan
 
doAssert(FlowProcess, GroupAssertionCall<C>) - Method in interface cascading.operation.GroupAssertion
Method doAssert performs the assertion.
doAssert(FlowProcess, ValueAssertionCall<C>) - Method in interface cascading.operation.ValueAssertion
Method doAssert performs the assertion.
DOCUMENT_SERVICE_CLASS_PROPERTY - Static variable in interface cascading.management.DocumentService
 
DocumentService - Interface in cascading.management
Interface DocumentService provides coarse grained hooks for managing various statistics.
DocumentServiceException - Exception in cascading.management
Exception DocumentServiceException is thrown from within a DocumentService instance.
DocumentServiceException() - Constructor for exception cascading.management.DocumentServiceException
 
DocumentServiceException(String) - Constructor for exception cascading.management.DocumentServiceException
 
DocumentServiceException(String, Throwable) - Constructor for exception cascading.management.DocumentServiceException
 
DocumentServiceException(Throwable) - Constructor for exception cascading.management.DocumentServiceException
 
doSpill(Spillable, int) - Method in interface cascading.tuple.collect.Spillable.SpillStrategy
 
DOT_FILE_PATH - Static variable in class cascading.flow.stream.graph.StreamGraph
Property denoting the path to write all stream graph dot files.
DOTExporter<V,E> - Class in cascading.util.jgrapht
 
DOTExporter() - Constructor for class cascading.util.jgrapht.DOTExporter
Constructs a new DOTExporter object with an integer name provider for the vertex IDs and null providers for the vertex and edge labels.
DOTExporter(VertexNameProvider<V>, VertexNameProvider<V>, EdgeNameProvider<E>) - Constructor for class cascading.util.jgrapht.DOTExporter
Constructs a new DOTExporter object with the given ID and label providers.
DOTExporter(VertexNameProvider<V>, VertexNameProvider<V>, EdgeNameProvider<E>, ComponentAttributeProvider<V>, ComponentAttributeProvider<E>) - Constructor for class cascading.util.jgrapht.DOTExporter
Constructs a new DOTExporter object with the given ID, label, and attribute providers.
DOTProcessGraphWriter - Class in cascading.util
This class is a derivative of the JGraphT DOTExporter, with numerous enhancements but with retained compatibility.
DOTProcessGraphWriter(VertexNameProvider<Pair<ElementGraph, FlowElement>>, VertexNameProvider<FlowElement>, EdgeNameProvider<Scope>, ComponentAttributeProvider<FlowElement>, ComponentAttributeProvider<Scope>, VertexNameProvider<ProcessModel>, VertexNameProvider<ProcessModel>) - Constructor for class cascading.util.DOTProcessGraphWriter
 
DOUBLE - Static variable in class cascading.tuple.coerce.Coercions
 
DOUBLE_OBJECT - Static variable in class cascading.tuple.coerce.Coercions
 
DoubleCoerce - Class in cascading.tuple.coerce
 
DoubleCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.DoubleCoerce
 
DoubleObjectCoerce - Class in cascading.tuple.coerce
 
DoubleObjectCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.DoubleObjectCoerce
 
DualStreamedAccumulatedExpressionGraph - Class in cascading.flow.planner.rule.expressiongraph
 
DualStreamedAccumulatedExpressionGraph() - Constructor for class cascading.flow.planner.rule.expressiongraph.DualStreamedAccumulatedExpressionGraph
 
Duct<Incoming,Outgoing> - Class in cascading.flow.stream.duct
 
DuctException - Exception in cascading.flow.stream.duct
 
DuctException(Throwable) - Constructor for exception cascading.flow.stream.duct.DuctException
 
DuctException(String, Throwable) - Constructor for exception cascading.flow.stream.duct.DuctException
 
DuctGraph - Class in cascading.flow.stream.duct
 
DuctGraph() - Constructor for class cascading.flow.stream.duct.DuctGraph
 
DuctGraph.Ordinal - Class in cascading.flow.stream.duct
 
DuctGraph.Ordinal(int, int) - Constructor for class cascading.flow.stream.duct.DuctGraph.Ordinal
 
dumpDebugInfo() - Method in class cascading.flow.planner.FlowStepJob
 

E

EACH - Static variable in class cascading.flow.planner.iso.expression.ScopeExpression
 
Each - Class in cascading.pipe
The Each operator applies either a Function or a Filter to each entry in the Tuple stream.
Each(String, Function) - Constructor for class cascading.pipe.Each
Pass all fields to the given function, only return fields declared by the function.
Each(String, Fields, Function) - Constructor for class cascading.pipe.Each
Only pass argumentFields to the given function, only return fields declared by the function.
Each(String, Fields, Function, Fields) - Constructor for class cascading.pipe.Each
Only pass argumentFields to the given function, only return fields selected by the outputSelector.
Each(String, Function, Fields) - Constructor for class cascading.pipe.Each
Only return fields selected by the outputSelector.
Each(Pipe, Function) - Constructor for class cascading.pipe.Each
Pass all fields to the given function, only return fields declared by the function.
Each(Pipe, Fields, Function) - Constructor for class cascading.pipe.Each
Only pass argumentFields to the given function, only return fields declared by the function.
Each(Pipe, Fields, Function, Fields) - Constructor for class cascading.pipe.Each
Only pass argumentFields to the given function, only return fields selected by the outputSelector.
Each(Pipe, Function, Fields) - Constructor for class cascading.pipe.Each
Only pass argumentFields to the given function, only return fields selected by the outputSelector.
Each(String, Filter) - Constructor for class cascading.pipe.Each
Constructor Each creates a new Each instance.
Each(String, Fields, Filter) - Constructor for class cascading.pipe.Each
Constructor Each creates a new Each instance.
Each(Pipe, Filter) - Constructor for class cascading.pipe.Each
Constructor Each creates a new Each instance.
Each(Pipe, Fields, Filter) - Constructor for class cascading.pipe.Each
Constructor Each creates a new Each instance.
Each(String, AssertionLevel, Assertion) - Constructor for class cascading.pipe.Each
Constructor Each creates a new Each instance.
Each(String, Fields, AssertionLevel, Assertion) - Constructor for class cascading.pipe.Each
 
Each(Pipe, AssertionLevel, Assertion) - Constructor for class cascading.pipe.Each
 
Each(Pipe, Fields, AssertionLevel, Assertion) - Constructor for class cascading.pipe.Each
 
Each(String, Fields, DebugLevel, Debug) - Constructor for class cascading.pipe.Each
 
Each(Pipe, DebugLevel, Debug) - Constructor for class cascading.pipe.Each
 
Each(Pipe, Fields, DebugLevel, Debug) - Constructor for class cascading.pipe.Each
 
EachStage - Class in cascading.flow.stream.element
 
EachStage(FlowProcess, Each) - Constructor for class cascading.flow.stream.element.EachStage
 
EdgeNameProvider<E> - Interface in cascading.util.jgrapht
 
edgeSet() - Method in class cascading.flow.planner.graph.BaseElementGraph
 
edgeSet() - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
edgeSet() - Method in interface cascading.flow.planner.graph.ElementGraph
 
edgeSet() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
edgeSet() - Method in interface cascading.flow.planner.process.ProcessGraph
 
edgesOf(FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
edgesOf(FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
edgesOf(FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
edgesOf(Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
edgesOf(Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
ElementAnnotation - Class in cascading.flow.planner.iso
 
ElementAnnotation(ElementCapture, Enum) - Constructor for class cascading.flow.planner.iso.ElementAnnotation
 
ElementCapture - Enum in cascading.flow.planner.iso.expression
 
ElementDirectedGraph - Class in cascading.flow.planner.graph
 
ElementDirectedGraph() - Constructor for class cascading.flow.planner.graph.ElementDirectedGraph
 
ElementDirectedGraph(ElementGraph) - Constructor for class cascading.flow.planner.graph.ElementDirectedGraph
 
ElementDirectedGraph(ElementGraph, EnumMultiMap) - Constructor for class cascading.flow.planner.graph.ElementDirectedGraph
 
ElementDuct - Interface in cascading.flow.stream.element
 
ElementExpression - Class in cascading.flow.planner.iso.expression
 
ElementExpression() - Constructor for class cascading.flow.planner.iso.expression.ElementExpression
 
ElementExpression(ElementCapture) - Constructor for class cascading.flow.planner.iso.expression.ElementExpression
 
ElementFactory - Interface in cascading.flow.planner.iso.transformer
 
ElementFlowProcess - Class in cascading.flow.stream.element
 
ElementFlowProcess(FlowProcess, ConfigDef) - Constructor for class cascading.flow.stream.element.ElementFlowProcess
 
ElementGraph - Interface in cascading.flow.planner.graph
Interface ElementGraph holds a directed acyclic graph of FlowElement instances.
elementGraph - Variable in class cascading.flow.planner.iso.finder.Match
 
elementGraph - Variable in class cascading.flow.stream.graph.NodeStreamGraph
 
ElementGraphException - Exception in cascading.flow.planner
Class ElementGraphException is thrown during rendering of a pipe assembly to the Cascading internal "graph" representation.
ElementGraphException() - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphException(Pipe, String) - Constructor for exception cascading.flow.planner.ElementGraphException
 
ElementGraphException(Tap, String) - Constructor for exception cascading.flow.planner.ElementGraphException
 
ElementGraphException(FlowElement, String) - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphException(FlowElement, String, Throwable) - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphException(String) - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphException(String, Throwable) - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphException(Throwable) - Constructor for exception cascading.flow.planner.ElementGraphException
Constructor ElementGraphException creates a new ElementGraphException instance.
ElementGraphs - Class in cascading.flow.planner.graph
Class ElementGraphs maintains a collection of operations that can be performed on an ElementGraph.
ElementMaskSubGraph - Class in cascading.flow.planner.graph
 
ElementMaskSubGraph(ElementGraph, FlowElement...) - Constructor for class cascading.flow.planner.graph.ElementMaskSubGraph
 
ElementMaskSubGraph(ElementGraph, Collection<FlowElement>) - Constructor for class cascading.flow.planner.graph.ElementMaskSubGraph
 
ElementMaskSubGraph(ElementGraph, Collection<FlowElement>, Collection<Scope>) - Constructor for class cascading.flow.planner.graph.ElementMaskSubGraph
 
ElementMaskSubGraph(ElementMaskSubGraph) - Constructor for class cascading.flow.planner.graph.ElementMaskSubGraph
 
ElementMaskSubGraph(ElementGraph, ElementMaskSubGraph.FlowElementMaskFunctor) - Constructor for class cascading.flow.planner.graph.ElementMaskSubGraph
 
ElementMultiGraph - Class in cascading.flow.planner.graph
 
ElementMultiGraph() - Constructor for class cascading.flow.planner.graph.ElementMultiGraph
 
ElementMultiGraph(ElementGraph) - Constructor for class cascading.flow.planner.graph.ElementMultiGraph
 
ElementMultiGraph.DirectedMultiGraph - Class in cascading.flow.planner.graph
 
ElementMultiGraph.DirectedMultiGraph() - Constructor for class cascading.flow.planner.graph.ElementMultiGraph.DirectedMultiGraph
 
ElementMultiGraph.DirectedMultiGraph(DirectedGraph<FlowElement, Scope>) - Constructor for class cascading.flow.planner.graph.ElementMultiGraph.DirectedMultiGraph
 
elementReader - Variable in class cascading.tuple.io.TupleInputStream
Field elementReader
elements - Variable in class cascading.tuple.Tuple
Field elements
elements(Tuple) - Static method in class cascading.tuple.Tuple
Returns a reference to the private elements of the given Tuple.
ElementStage<Incoming,Outgoing> - Class in cascading.flow.stream.element
 
ElementStage(FlowProcess, FlowElement) - Constructor for class cascading.flow.stream.element.ElementStage
 
ElementSubGraph - Class in cascading.flow.planner.graph
 
ElementSubGraph(ElementGraph, Collection<FlowElement>, Collection<Scope>) - Constructor for class cascading.flow.planner.graph.ElementSubGraph
 
ElementSubGraph(ElementSubGraph) - Constructor for class cascading.flow.planner.graph.ElementSubGraph
 
EMPTY - Static variable in class cascading.util.SingleValueIterator
 
emptyCollection() - Method in class cascading.util.MultiMap
 
emptyCollection() - Method in class cascading.util.SetMultiMap
 
emptyCollection() - Method in class cascading.util.SortedListMultiMap
 
enableDebugLogging() - Method in class cascading.flow.planner.rule.RuleRegistry
Method enableDebugLogging forces log4j to emit DEBUG level stats for the planner classes.
enabledResolveElements() - Method in class cascading.flow.planner.rule.RuleRegistry
 
enforceStrict - Variable in class cascading.scheme.util.DelimitedParser
Field enforceStrict
entryIterator() - Method in class cascading.tuple.TupleListCollector
Method entryIterator return a TupleEntry iterator for this collection.
entrySet() - Method in class cascading.util.cache.DirectMappedCache
 
entrySet() - Method in class cascading.util.cache.LRUHashMapCache
 
entrySet() - Method in class cascading.util.cache.OrderedHashMapCache
 
EnumMultiMap<V> - Class in cascading.util
 
EnumMultiMap() - Constructor for class cascading.util.EnumMultiMap
 
EnumMultiMap(EnumMultiMap) - Constructor for class cascading.util.EnumMultiMap
 
equals(Object) - Method in class cascading.flow.planner.BaseFlowNode
 
equals(Object) - Method in class cascading.flow.planner.BaseFlowStep
 
equals(Object) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
equals(Object) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
equals(ElementGraph, ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
equals(Object) - Method in class cascading.flow.planner.graph.IgnoresAnnotationsElementGraph
 
equals(Object) - Method in class cascading.flow.planner.PlannerInfo
 
equals(Object) - Method in class cascading.flow.planner.PlatformInfo
 
equals(Object) - Method in class cascading.flow.planner.rule.RuleRegistry
 
equals(Object) - Method in class cascading.flow.planner.rule.util.ResultTree.Delegate
 
equals(Object) - Method in class cascading.flow.stream.duct.DuctGraph.Ordinal
 
equals(Object) - Method in class cascading.flow.stream.element.ElementStage
 
equals(Object) - Method in class cascading.flow.stream.element.GroupingSpliceGate.DelegatedTuple
 
equals(Object) - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
equals(Object) - Method in class cascading.operation.aggregator.ExtentBase
 
equals(Object) - Method in class cascading.operation.aggregator.ExtremaValueBase
 
equals(Object) - Method in class cascading.operation.aggregator.Sum
 
equals(Object) - Method in class cascading.operation.assertion.AssertEquals
 
equals(Object) - Method in class cascading.operation.assertion.AssertEqualsAll
 
equals(Object) - Method in class cascading.operation.assertion.AssertGroupBase
 
equals(Object) - Method in class cascading.operation.assertion.AssertNotEquals
 
equals(Object) - Method in class cascading.operation.assertion.AssertSizeEquals
 
equals(Object) - Method in class cascading.operation.assertion.AssertSizeLessThan
 
equals(Object) - Method in class cascading.operation.assertion.AssertSizeMoreThan
 
equals(Object) - Method in class cascading.operation.assertion.BaseAssertion
 
equals(Object) - Method in class cascading.operation.BaseOperation
 
equals(Object) - Method in class cascading.operation.Debug
 
equals(Object) - Method in class cascading.operation.expression.ScriptOperation
 
equals(Object) - Method in class cascading.operation.filter.Limit
 
equals(Object) - Method in class cascading.operation.filter.Logic
 
equals(Object) - Method in class cascading.operation.filter.Not
 
equals(Object) - Method in class cascading.operation.filter.Sample
 
equals(Object) - Method in class cascading.operation.function.SetValue
 
equals(Object) - Method in class cascading.operation.function.UnGroup
 
equals(Object) - Method in class cascading.operation.Identity
 
equals(Object) - Method in class cascading.operation.Insert
 
equals(Object) - Method in class cascading.operation.regex.RegexFilter
 
equals(Object) - Method in class cascading.operation.regex.RegexMatcher
 
equals(Object) - Method in class cascading.operation.regex.RegexOperation
 
equals(Object) - Method in class cascading.operation.regex.RegexParser
 
equals(Object) - Method in class cascading.operation.regex.RegexReplace
 
equals(Object) - Method in class cascading.operation.state.Counter
 
equals(Object) - Method in class cascading.operation.state.Status
 
equals(Object) - Method in class cascading.operation.text.DateOperation
 
equals(Object) - Method in class cascading.operation.text.DateParser
 
equals(Object) - Method in class cascading.operation.text.FieldFormatter
 
equals(Object) - Method in class cascading.operation.text.FieldJoiner
 
equals(Object) - Method in class cascading.pipe.assembly.AggregateBy.CompositeFunction
 
equals(Object) - Method in class cascading.pipe.assembly.Unique.FilterPartialDuplicates
 
equals(Object) - Method in class cascading.pipe.Operator
 
equals(Object) - Method in class cascading.pipe.Pipe
 
equals(Object) - Method in class cascading.pipe.Splice
 
equals(Object) - Method in class cascading.scheme.Scheme
 
equals(Object) - Method in class cascading.stats.FlowStats
 
equals(Object) - Method in class cascading.tap.MultiSinkTap
 
equals(Object) - Method in class cascading.tap.MultiSourceTap
 
equals(Object) - Method in class cascading.tap.partition.BasePartitionTap
 
equals(Object) - Method in class cascading.tap.Tap
 
equals(Object) - Method in class cascading.tuple.coerce.Coercions.Coerce
 
equals(Object) - Method in class cascading.tuple.Fields
 
equals(Object) - Method in class cascading.tuple.io.IndexTuple
 
equals(Object) - Method in class cascading.tuple.io.TuplePair
 
equals(Object) - Method in class cascading.tuple.Tuple
 
equals(Object) - Method in class cascading.tuple.TupleEntry
 
equals(Object) - Method in class cascading.util.MultiMap
 
equals(Object) - Method in class cascading.util.Pair
 
equalsFields(Fields) - Method in class cascading.tuple.Fields
Method equalsFields compares only the internal field names and postions only between this and the given Fields instance.
equalsIgnoreAnnotations(ElementGraph, ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
equalsIgnoreAnnotations(Graph<V, E>, Graph<V, E>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
ERROR_DOT_FILE_NAME - Static variable in class cascading.flow.stream.graph.StreamGraph
Property denoting the path and filename to write the failed stream graph dot file.
escapePattern - Variable in class cascading.scheme.util.DelimitedParser
Field escapePattern
evaluate(ScriptOperation.Context, TupleEntry) - Method in class cascading.operation.expression.ScriptOperation
Performs the actual expression evaluation.
Every - Class in cascading.pipe
The Every operator applies an Aggregator or Buffer to every grouping.
Every(Pipe, Aggregator) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Fields, Aggregator) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Fields, Aggregator, Fields) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Aggregator, Fields) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Buffer) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Fields, Buffer) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Fields, Buffer, Fields) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Buffer, Fields) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, AssertionLevel, GroupAssertion) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
Every(Pipe, Fields, AssertionLevel, GroupAssertion) - Constructor for class cascading.pipe.Every
Constructor Every creates a new Every instance.
EveryAfterBufferAssert - Class in cascading.flow.planner.rule.assertion
 
EveryAfterBufferAssert() - Constructor for class cascading.flow.planner.rule.assertion.EveryAfterBufferAssert
 
EveryAfterBufferExpression - Class in cascading.flow.planner.rule.expression
 
EveryAfterBufferExpression() - Constructor for class cascading.flow.planner.rule.expression.EveryAfterBufferExpression
 
EveryStage<Incoming> - Class in cascading.flow.stream.element
 
EveryStage(FlowProcess, Every) - Constructor for class cascading.flow.stream.element.EveryStage
 
evict(Map.Entry<Key, Value>) - Method in interface cascading.util.cache.CacheEvictionCallback
Method will be called by the CascadingCache implementation whenever a key is evicted.
exec(PlannerContext, FlowElementGraph) - Method in class cascading.flow.planner.rule.RuleExec
 
exec() - Method in class cascading.flow.planner.rule.RuleSetExec
 
ExecAction - Enum in cascading.flow.planner.rule
 
execPlannerFor(RuleRegistry) - Method in class cascading.flow.planner.rule.RuleSetExec
 
execProcess(File, String...) - Static method in class cascading.util.Util
 
execute() - Method in class cascading.util.ShutdownUtil.Hook
 
executeRulePhase(PlanPhase, PlannerContext, RuleResult) - Method in class cascading.flow.planner.rule.RuleExec
 
export(Writer, Graph<V, E>) - Method in class cascading.util.jgrapht.DOTExporter
Exports a graph into a plain text file in DOT format.
Expression<Type> - Interface in cascading.flow.planner.iso.expression
 
ExpressionFilter - Class in cascading.operation.expression
Class ExpressionFilter dynamically resolves a given expression using argument Tuple values.
ExpressionFilter(String) - Constructor for class cascading.operation.expression.ExpressionFilter
Constructor ExpressionFilter creates a new ExpressionFilter instance.
ExpressionFilter(String, Class) - Constructor for class cascading.operation.expression.ExpressionFilter
Constructor ExpressionFilter creates a new ExpressionFilter instance.
ExpressionFilter(String, String[], Class[]) - Constructor for class cascading.operation.expression.ExpressionFilter
Constructor ExpressionFilter creates a new ExpressionFilter instance.
ExpressionFunction - Class in cascading.operation.expression
Class ExpressionFunction dynamically resolves a given expression using argument Tuple values.
ExpressionFunction(Fields, String) - Constructor for class cascading.operation.expression.ExpressionFunction
Constructor ExpressionFunction creates a new ExpressionFunction instance.
ExpressionFunction(Fields, String, Class) - Constructor for class cascading.operation.expression.ExpressionFunction
Constructor ExpressionFunction creates a new ExpressionFunction instance.
ExpressionFunction(Fields, String, String[], Class[]) - Constructor for class cascading.operation.expression.ExpressionFunction
Constructor ExpressionFunction creates a new ExpressionFunction instance.
ExpressionGraph - Class in cascading.flow.planner.iso.expression
 
ExpressionGraph() - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
ExpressionGraph(boolean) - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
ExpressionGraph(ElementExpression...) - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
ExpressionGraph(SearchOrder, ElementExpression...) - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
ExpressionGraph(SearchOrder) - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
ExpressionGraph(SearchOrder, boolean) - Constructor for class cascading.flow.planner.iso.expression.ExpressionGraph
 
expressionGraph - Variable in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
ExpressionGraphPartitioner - Class in cascading.flow.planner.iso.subgraph.partitioner
 
ExpressionGraphPartitioner(ExpressionGraph, ExpressionGraph, ElementAnnotation...) - Constructor for class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
ExpressionOperation - Class in cascading.operation.expression
Class ExpressionOperation is the base class for ExpressionFunction, ExpressionFilter, AssertExpression.
ExpressionOperation(String) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionOperation(Fields, String) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionOperation(Fields, String, Class) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionOperation(Fields, String, String[], Class[]) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionOperation(String, Class) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionOperation(String, String[], Class[]) - Constructor for class cascading.operation.expression.ExpressionOperation
 
ExpressionRulePartitioner - Class in cascading.flow.planner.rule.partitioner
Class ExpressionRulePartitioner relies on a RuleExpression to identify sub-graphs as partitions.
ExpressionRulePartitioner(PlanPhase, RuleExpression) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, RuleExpression, ElementAnnotation...) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, RuleExpression, Enum...) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, RulePartitioner.PartitionSource, RuleExpression) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, RulePartitioner.PartitionSource, RuleExpression, ElementAnnotation...) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, RulePartitioner.PartitionSource, RuleExpression, Enum...) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase, GraphPartitioner) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner(PlanPhase) - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionRulePartitioner() - Constructor for class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
ExpressionSubGraphIterator - Class in cascading.flow.planner.iso.subgraph.iterator
 
ExpressionSubGraphIterator(ExpressionGraph, ElementGraph) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
ExpressionSubGraphIterator(PlannerContext, ExpressionGraph, ElementGraph) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
ExpressionSubGraphIterator(PlannerContext, ExpressionGraph, ExpressionGraph, ElementGraph) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
ExpressionSubGraphIterator(PlannerContext, ExpressionGraph, ExpressionGraph, ElementGraph, Collection<FlowElement>) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
ExpressionSubGraphIterator(PlannerContext, ExpressionGraph, ExpressionGraph, boolean, ElementGraph) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
ExpressionSubGraphIterator(PlannerContext, ExpressionGraph, ExpressionGraph, boolean, ElementGraph, Collection<FlowElement>) - Constructor for class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
Extent - Enum in cascading.flow.planner.graph
Enum Extent provides simple markers for the head and tail of an ElementGraph FlowElement graph.
ExtentBase - Class in cascading.operation.aggregator
Class ExtentBase is the base class for First and Last.
ExtentBase(Fields) - Constructor for class cascading.operation.aggregator.ExtentBase
 
ExtentBase(int, Fields) - Constructor for class cascading.operation.aggregator.ExtentBase
 
ExtentBase(Fields, Tuple...) - Constructor for class cascading.operation.aggregator.ExtentBase
 
extract(TupleEntry, Fields) - Static method in class cascading.tuple.Tuples
Method extract creates a new Tuple from the given selector, but sets the values in the current tuple to null.
extractTuple(TupleEntry, Fields) - Static method in class cascading.tuple.Tuples
Method extractTuple returns a new Tuple based on the given selector.
ExtremaValueBase - Class in cascading.operation.aggregator
Class ExtremaValueBase is the base class for MaxValue and MinValue where the values are expected to by Comparable types and the Comparable.compareTo(Object) result is use for max/min comparison.
ExtremaValueBase(Fields) - Constructor for class cascading.operation.aggregator.ExtremaValueBase
 
ExtremaValueBase(int, Fields) - Constructor for class cascading.operation.aggregator.ExtremaValueBase
 
ExtremaValueBase(Fields, Object...) - Constructor for class cascading.operation.aggregator.ExtremaValueBase
 
ExtremaValueBase.Context - Class in cascading.operation.aggregator
 
ExtremaValueBase.Context() - Constructor for class cascading.operation.aggregator.ExtremaValueBase.Context
 

F

FactoryLoader - Class in cascading.provider
Class FactoryLoader is an implementation of a ProviderLoader and is used to load CascadingFactory instances used by internal frameworks.
FactoryLoader() - Constructor for class cascading.provider.FactoryLoader
 
fail() - Method in class cascading.operation.assertion.BaseAssertion
 
fail(Object...) - Method in class cascading.operation.assertion.BaseAssertion
 
FAIL_ON_CLOSE - Static variable in class cascading.tap.partition.PartitionTapProps
 
FAILURE_MODE_PASS_THROUGH - Static variable in class cascading.management.annotation.URISanitizer
System property to allow values to pass through a parse exception.
FIELD_NAME - Static variable in class cascading.operation.aggregator.Average
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.aggregator.Count
Field COUNT
FIELD_NAME - Static variable in class cascading.operation.aggregator.MaxValue
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.aggregator.MinValue
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.aggregator.Sum
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.text.DateFormatter
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.text.DateParser
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.text.FieldFormatter
Field FIELD_NAME
FIELD_NAME - Static variable in class cascading.operation.text.FieldJoiner
Field FIELD_NAME
fieldDeclaration - Variable in class cascading.operation.BaseOperation
Field fieldDeclaration
FieldFormatter - Class in cascading.operation.text
Class FieldFormatter formats the values in a Tuple with a given format and stuffs the result into a new field.
FieldFormatter(String) - Constructor for class cascading.operation.text.FieldFormatter
Constructor FieldJoiner creates a new FieldFormatter instance using the default field name "formatted".
FieldFormatter(Fields, String) - Constructor for class cascading.operation.text.FieldFormatter
Constructor FieldJoiner creates a new FieldFormatter instance.
FieldJoiner - Class in cascading.operation.text
Class FieldJoiner joins the values in a Tuple with a given delimiter and stuffs the result into a new field.
FieldJoiner(String) - Constructor for class cascading.operation.text.FieldJoiner
Constructor FieldJoiner creates a new FieldJoiner instance.
FieldJoiner(Fields) - Constructor for class cascading.operation.text.FieldJoiner
Constructor FieldJoiner creates a new FieldJoiner instance.
FieldJoiner(Fields, String) - Constructor for class cascading.operation.text.FieldJoiner
Constructor FieldJoiner creates a new FieldJoiner instance.
Fields - Class in cascading.tuple
Class Fields represents the field names in a Tuple.
Fields(Fields.Kind) - Constructor for class cascading.tuple.Fields
Constructor Fields creates a new Fields instance.
Fields(Comparable...) - Constructor for class cascading.tuple.Fields
Constructor Fields creates a new Fields instance.
Fields(Comparable, Type) - Constructor for class cascading.tuple.Fields
 
Fields(Comparable[], Type[]) - Constructor for class cascading.tuple.Fields
 
fields(Fields...) - Static method in class cascading.tuple.Fields
Method fields is a convenience method to create an array of Fields instances.
FieldsResolverException - Exception in cascading.tuple
Class FieldsResolverException is thrown when selectorFields cannot select from the sourceFields.
FieldsResolverException(Fields, Fields) - Constructor for exception cascading.tuple.FieldsResolverException
Constructor FieldsResolverException creates a new FieldsResolverException instance.
fieldTypeResolver - Variable in class cascading.scheme.util.DelimitedParser
fieldTypeResolver
FieldTypeResolver - Interface in cascading.scheme.util
 
FileType<Config> - Interface in cascading.tap.type
Interface FileType marks specific platform Tap classes as representing a file like interface.
Filter<Context> - Interface in cascading.operation
Interface Filter marks a given Operation as a filter, as opposed to being a Function.
FilterCall<C> - Interface in cascading.operation
Interface FilterCall provides access to the current Filter invocation arguments.
FilterEachStage - Class in cascading.flow.stream.element
 
FilterEachStage(FlowProcess, Each) - Constructor for class cascading.flow.stream.element.FilterEachStage
 
FilterNotNull - Class in cascading.operation.filter
Class FilterNotNull verifies that every value in the argument values Tuple is a null value.
FilterNotNull() - Constructor for class cascading.operation.filter.FilterNotNull
 
FilterNull - Class in cascading.operation.filter
Class FilterNull verifies that every value in the argument values Tuple is not a null value.
FilterNull() - Constructor for class cascading.operation.filter.FilterNull
 
filters - Variable in class cascading.operation.filter.Logic
Field filters
finalizeNodeSliceCapture() - Method in class cascading.flow.planner.FlowStepJob
 
find(String, String[]) - Method in class cascading.management.CascadingServices.NullDocumentService
 
find(String, String[]) - Method in interface cascading.management.DocumentService
 
findAllGroups(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findAllHashJoins(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findAllMatches(ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllMatches(PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllMatches(PlannerContext, ElementGraph, Set<FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllMatchesOnPrimary(ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllMatchesOnPrimary(PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllMatchesOnPrimary(PlannerContext, ElementGraph, Set<FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findAllNextFor(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
findAllPreviousFor(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
findClosureViaFloydWarshall(DirectedGraph<V, E>, DirectedGraph<V, E>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findClosureViaFloydWarshall(DirectedGraph<V, E>, DirectedGraph<V, E>, Set<V>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findContainingJar(Class<?>) - Static method in class cascading.util.Util
 
findExisting(Duct) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
findFirstMatch(ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findFirstMatch(PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findFirstMatch(PlannerContext, ElementGraph, Set<FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findFirstMatch(FinderContext, PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findFirstPipeNamed(ElementGraph, String) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findFlows(String) - Method in class cascading.cascade.BaseCascade
 
findFlows(String) - Method in interface cascading.cascade.Cascade
Method findFlows returns a List of flows whose names match the given regex pattern.
findFlowsSinkingTo(String) - Method in class cascading.cascade.BaseCascade
 
findFlowsSinkingTo(String) - Method in interface cascading.cascade.Cascade
Method findFlowsSinkingTo returns all Flow instances that writes to a sink with the given identifier.
findFlowsSourcingFrom(String) - Method in class cascading.cascade.BaseCascade
 
findFlowsSourcingFrom(String) - Method in interface cascading.cascade.Cascade
Method findFlowsSourcingFrom returns all Flow instances that reads from a source with the given identifier.
findLastPipeNamed(ElementGraph, String) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findMainClass(Class, String) - Static method in class cascading.util.Util
 
findMapping(PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findMapping(FinderContext, PlannerContext, ElementGraph) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findMatchesOnPrimary(PlannerContext, ElementGraph, boolean, Set<FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findMatchesOnPrimary(FinderContext, PlannerContext, ElementGraph, boolean) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
findName(String) - Static method in class cascading.util.Util
 
findOrdinal(Pipe, Pipe) - Static method in class cascading.flow.FlowElements
 
findRegistryWith(String) - Method in class cascading.flow.planner.rule.RuleRegistrySet
 
findSinks(ElementGraph, Class<F>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findSinks(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findSources(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findSources(ElementGraph, Class<F>) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
findVersion(String) - Static method in class cascading.util.Util
 
fireListeners(CascadingStats.Status, CascadingStats.Status) - Method in class cascading.stats.CascadingStats
 
fireOnCompleted() - Method in class cascading.flow.BaseFlow
 
fireOnCompleted(Flow) - Static method in class cascading.flow.Flows
 
fireOnCompleted() - Method in class cascading.flow.planner.BaseFlowStep
 
fireOnRunning() - Method in class cascading.flow.planner.BaseFlowStep
 
fireOnStarting() - Method in class cascading.cascade.BaseCascade
 
fireOnStarting() - Method in class cascading.flow.BaseFlow
 
fireOnStarting() - Method in class cascading.flow.planner.BaseFlowStep
 
fireOnStopping() - Method in class cascading.cascade.BaseCascade
 
fireOnStopping() - Method in class cascading.flow.BaseFlow
 
fireOnStopping() - Method in class cascading.flow.planner.BaseFlowStep
 
fireOnThrowable(Throwable) - Method in class cascading.flow.BaseFlow
 
fireOnThrowable() - Method in class cascading.flow.BaseFlow
 
fireOnThrowable(Throwable) - Method in class cascading.flow.planner.BaseFlowStep
 
First - Class in cascading.operation.aggregator
Class First is an Aggregator that returns the first Tuple encountered in a grouping.
First() - Constructor for class cascading.operation.aggregator.First
Selects and returns the first argument Tuple encountered.
First(int) - Constructor for class cascading.operation.aggregator.First
Selects and returns the first N argument Tuples encountered.
First(Fields) - Constructor for class cascading.operation.aggregator.First
Selects and returns the first argument Tuple encountered.
First(Fields, int) - Constructor for class cascading.operation.aggregator.First
Selects and returns the first N argument Tuples encountered.
First(Fields, Tuple...) - Constructor for class cascading.operation.aggregator.First
Selects and returns the first argument Tuple encountered, unless the Tuple is a member of the set ignoreTuples.
FIRST - Static variable in class cascading.tuple.Fields
Field FIRST represents the first field position, 0
FirstBy - Class in cascading.pipe.assembly
Class FirstBy is used to return the first encountered Tuple in a tuple stream grouping.
FirstBy(Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(Fields, Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(Pipe, Fields, Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(Pipe, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(String, Pipe, Fields, Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(String, Pipe, Fields, Fields, int) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(Pipe[], Fields, Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(Pipe[], Fields, Fields, int) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(String, Pipe[], Fields, Fields) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy(String, Pipe[], Fields, Fields, int) - Constructor for class cascading.pipe.assembly.FirstBy
Constructor FirstBy creates a new FirstBy instance.
FirstBy.FirstPartials - Class in cascading.pipe.assembly
Class CountPartials is a AggregateBy.Functor that is used to count observed duplicates from the tuple stream.
FirstBy.FirstPartials(Fields) - Constructor for class cascading.pipe.assembly.FirstBy.FirstPartials
Constructor FirstPartials creates a new FirstPartials instance.
firstEntry() - Method in class cascading.util.SortedListMultiMap
 
FirstNBuffer - Class in cascading.operation.buffer
Class FirstNBuffer will return the first N tuples seen in a given grouping.
FirstNBuffer() - Constructor for class cascading.operation.buffer.FirstNBuffer
Selects and returns the first argument Tuple encountered.
FirstNBuffer(int) - Constructor for class cascading.operation.buffer.FirstNBuffer
Selects and returns the first N argument Tuples encountered.
FirstNBuffer(Fields) - Constructor for class cascading.operation.buffer.FirstNBuffer
Selects and returns the first argument Tuple encountered.
FirstNBuffer(Fields, int) - Constructor for class cascading.operation.buffer.FirstNBuffer
Selects and returns the first N argument Tuples encountered.
FLOAT - Static variable in class cascading.tuple.coerce.Coercions
 
FLOAT_OBJECT - Static variable in class cascading.tuple.coerce.Coercions
 
FloatCoerce - Class in cascading.tuple.coerce
 
FloatCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.FloatCoerce
 
FloatObjectCoerce - Class in cascading.tuple.coerce
 
FloatObjectCoerce(Map<Type, Coercions.Coerce>) - Constructor for class cascading.tuple.coerce.FloatObjectCoerce
 
flow - Variable in class cascading.flow.BaseFlow.FlowHolder
Field flow
Flow<Config> - Interface in cascading.flow
A Flow is a logical unit of work declared by an assembly of Pipe instances connected to source and sink Tap instances.
FLOW_NODE_COMPARATOR - Static variable in class cascading.flow.planner.process.FlowNodeGraph
 
flowConfInit(Flow<Config>) - Method in class cascading.tap.DecoratorTap
 
flowConfInit(Flow<Config>) - Method in class cascading.tap.Tap
Method flowInit allows this Tap instance to initialize itself in context of the given Flow instance.
FlowConnector - Class in cascading.flow
Class FlowConnector is the base class for all platform planners.
FlowConnector() - Constructor for class cascading.flow.FlowConnector
 
FlowConnector(RuleRegistrySet) - Constructor for class cascading.flow.FlowConnector
 
FlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.FlowConnector
 
FlowConnector(Map<Object, Object>, RuleRegistrySet) - Constructor for class cascading.flow.FlowConnector
 
FlowConnectorProps - Class in cascading.flow
The class FlowConnectorProps is a fluent helper class for setting FlowConnector specific properties through the FlowConnector constructor.
FlowConnectorProps() - Constructor for class cascading.flow.FlowConnectorProps
 
flowConnectorProps() - Static method in class cascading.flow.FlowConnectorProps
Creates a new FlowConnectorProps instance.
FlowDef - Class in cascading.flow
Class FlowDef is a fluent interface for defining a Flow.
FlowDef() - Constructor for class cascading.flow.FlowDef
Constructor FlowDef creates a new FlowDef instance.
FlowDef(FlowDef, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>) - Constructor for class cascading.flow.FlowDef
 
flowDef() - Static method in class cascading.flow.FlowDef
Creates a new instance of a FlowDef.
flowDescriptor - Variable in class cascading.flow.FlowDef
 
FlowDescriptors - Interface in cascading.flow
Constants to be used as key in Flow#getFlowDescriptor.
FlowElement - Interface in cascading.flow
Interface FlowElement is a utility interface used internally to simplify DAG management.
flowElement - Variable in class cascading.flow.stream.element.ElementStage
 
FlowElementExpression - Class in cascading.flow.planner.iso.expression
 
FlowElementExpression(ElementCapture, boolean, Class<? extends FlowElement>, TypeExpression.Topo) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(ElementCapture, Class<? extends FlowElement>, TypeExpression.Topo) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(boolean, Class<? extends FlowElement>, TypeExpression.Topo) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(Class<? extends FlowElement>, TypeExpression.Topo) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(ElementCapture, boolean, Class<? extends FlowElement>) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(ElementCapture, Class<? extends FlowElement>) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(boolean, Class<? extends FlowElement>) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementExpression(Class<? extends FlowElement>) - Constructor for class cascading.flow.planner.iso.expression.FlowElementExpression
 
FlowElementGraph - Class in cascading.flow.planner.graph
Class ElementGraph represents the executable FlowElement graph.
FlowElementGraph() - Constructor for class cascading.flow.planner.graph.FlowElementGraph
 
FlowElementGraph(FlowElementGraph) - Constructor for class cascading.flow.planner.graph.FlowElementGraph
 
FlowElementGraph(Pipe[], Map<String, Tap>, Map<String, Tap>) - Constructor for class cascading.flow.planner.graph.FlowElementGraph
 
FlowElementGraph(PlatformInfo, Pipe[], Map<String, Tap>, Map<String, Tap>, Map<String, Tap>, Map<String, Tap>, boolean) - Constructor for class cascading.flow.planner.graph.FlowElementGraph
Constructor ElementGraph creates a new ElementGraph instance.
FlowElements - Class in cascading.flow
 
FlowElements() - Constructor for class cascading.flow.FlowElements
 
FlowException - Exception in cascading.flow
FlowException instances are thrown on errors when executing a Flow.
FlowException() - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowException(String) - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowException(String, Throwable) - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowException(String, String, Throwable) - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowException(String, String) - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowException(Throwable) - Constructor for exception cascading.flow.FlowException
Constructor FlowException creates a new FlowException instance.
FlowGraph - Class in cascading.cascade.planner
 
FlowGraph(IdentifierGraph) - Constructor for class cascading.cascade.planner.FlowGraph
 
FlowListener - Interface in cascading.flow
Interface FlowListener provides hooks for receiving events on various stages of a Flow execution.
FlowNode - Interface in cascading.flow
Class FlowNode represents the smallest parallelizable unit of work.
FlowNodeGraph - Class in cascading.flow.planner.process
 
FlowNodeGraph() - Constructor for class cascading.flow.planner.process.FlowNodeGraph
 
FlowNodeGraph(FlowPlanner<?, ?>, FlowElementGraph, List<? extends ElementGraph>) - Constructor for class cascading.flow.planner.process.FlowNodeGraph
 
FlowNodeGraph(FlowPlanner<?, ?>, FlowElementGraph, List<? extends ElementGraph>, Map<ElementGraph, List<? extends ElementGraph>>) - Constructor for class cascading.flow.planner.process.FlowNodeGraph
 
FlowNodeGraph.FlowNodeComparator - Class in cascading.flow.planner.process
Class FlowNodeComparator provides a consistent tie breaker when ordering nodes topologically.
FlowNodeGraph.FlowNodeComparator() - Constructor for class cascading.flow.planner.process.FlowNodeGraph.FlowNodeComparator
 
FlowNodeStats - Class in cascading.stats
Class FlowNodeStats collects FlowNode specific statistics.
FlowNodeStats(FlowNode, ClientState) - Constructor for class cascading.stats.FlowNodeStats
 
FlowPlanner<F extends BaseFlow,Config> - Class in cascading.flow.planner
Class FlowPlanner is the base class for all planner implementations.
FlowPlanner() - Constructor for class cascading.flow.planner.FlowPlanner
 
FlowPlanner.TempTapElementFactory - Class in cascading.flow.planner
 
FlowPlanner.TempTapElementFactory() - Constructor for class cascading.flow.planner.FlowPlanner.TempTapElementFactory
 
FlowProcess<Config> - Class in cascading.flow
FlowProcess implementations provide a call-back interface into the current computing system.
FlowProcess() - Constructor for class cascading.flow.FlowProcess
 
FlowProcess(FlowSession) - Constructor for class cascading.flow.FlowProcess
 
FlowProcess(FlowProcess<Config>) - Constructor for class cascading.flow.FlowProcess
Copy constructor.
flowProcess - Variable in class cascading.flow.stream.element.BoundaryStage
 
flowProcess - Variable in class cascading.flow.stream.element.ElementStage
 
flowProcess - Variable in class cascading.flow.stream.element.SpliceGate
 
flowProcess - Variable in class cascading.flow.stream.graph.NodeStreamGraph
 
flowProcess - Variable in class cascading.pipe.joiner.JoinerClosure
 
FlowProcess.NullFlowProcess - Class in cascading.flow
 
FlowProcess.NullFlowProcess() - Constructor for class cascading.flow.FlowProcess.NullFlowProcess
 
FlowProcessWrapper<Config> - Class in cascading.flow
 
FlowProcessWrapper(FlowProcess) - Constructor for class cascading.flow.FlowProcessWrapper
 
FlowProps - Class in cascading.flow
Class FlowProps is a fluent helper class for setting Flow specific properties through a FlowConnector.
FlowProps() - Constructor for class cascading.flow.FlowProps
 
flowProps() - Static method in class cascading.flow.FlowProps
Creates a new FlowProps instance.
FlowRuntimeProps - Class in cascading.flow
Class FlowRuntimeProps is a fluent helper class for setting Flow specific runtime properties through a FlowConnector.
FlowRuntimeProps() - Constructor for class cascading.flow.FlowRuntimeProps
 
flowRuntimeProps() - Static method in class cascading.flow.FlowRuntimeProps
 
Flows - Class in cascading.flow
Flows is a utility helper class.
FlowSession - Class in cascading.flow
FlowSession implementations provide a call-back interface into the current flow management system, if any.
FlowSession() - Constructor for class cascading.flow.FlowSession
 
FlowSession(CascadingServices) - Constructor for class cascading.flow.FlowSession
 
FlowSkipIfSinkExists - Class in cascading.flow
Class FlowSkipIfSinkExists is a FlowSkipStrategy implementation that returns true if the Flow sink exists, regardless if it is stale or not.
FlowSkipIfSinkExists() - Constructor for class cascading.flow.FlowSkipIfSinkExists
 
FlowSkipIfSinkNotStale - Class in cascading.flow
Class FlowSkipIfSinkNotStale is a FlowSkipStrategy implementation that returns true if the Flow sink exists and is not stale in relation to the Flow sources.
FlowSkipIfSinkNotStale() - Constructor for class cascading.flow.FlowSkipIfSinkNotStale
 
FlowSkipStrategy - Interface in cascading.flow
Interface FlowSkipStrategy is used to create new strategies that decide when a Flow should be skipped when executed in a Cascade.
FlowSliceStats<K extends Enum> - Class in cascading.stats
Typically CascadingStats objects have an internal state model with timings, the FlowSliceStats is a simplified Stats object and only reports what the underlying platform reports, not the client side observations.
FlowSliceStats() - Constructor for class cascading.stats.FlowSliceStats
 
FlowSliceStats.FlowSliceAttempt - Class in cascading.stats
 
FlowSliceStats.FlowSliceAttempt() - Constructor for class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
flowStats - Variable in class cascading.flow.BaseFlow
Field flowStats
FlowStats - Class in cascading.stats
Class FlowStats collects Flow specific statistics.
FlowStats(Flow, ClientState) - Constructor for class cascading.stats.FlowStats
 
FlowStep<Config> - Interface in cascading.flow
Class FlowStep is an internal representation of a given "job" possibly to be executed on a remote cluster.
flowStep - Variable in class cascading.flow.planner.FlowStepJob
Field flowStep
FlowStepGraph - Class in cascading.flow.planner.process
 
FlowStepGraph() - Constructor for class cascading.flow.planner.process.FlowStepGraph
 
FlowStepGraph(FlowPlanner<?, ?>, FlowElementGraph, Map<ElementGraph, List<? extends ElementGraph>>, Map<ElementGraph, List<? extends ElementGraph>>) - Constructor for class cascading.flow.planner.process.FlowStepGraph
 
FlowStepJob<Config> - Class in cascading.flow.planner
 
FlowStepJob(ClientState, Config, BaseFlowStep<Config>, long, long, long) - Constructor for class cascading.flow.planner.FlowStepJob
 
FlowStepListener - Interface in cascading.flow
Interface FlowStepListener provides hooks for receiving events on various stages of a FlowStep execution.
flowStepStats - Variable in class cascading.flow.planner.BaseFlowStep
 
flowStepStats - Variable in class cascading.flow.planner.FlowStepJob
Field stepStats
FlowStepStats - Class in cascading.stats
Class FlowStepStats collects FlowStep specific statistics.
FlowStepStats(FlowStep, ClientState) - Constructor for class cascading.stats.FlowStepStats
 
FlowStepStrategy<Config> - Interface in cascading.flow
The FlowStepStrategy interface allows for on the fly customization of FlowStep configuration values before they are submitted to the underlying platform.
flush(FlowProcess, OperationCall<Context>) - Method in class cascading.operation.BaseOperation
 
flush(FlowProcess, OperationCall<Context>) - Method in interface cascading.operation.Operation
The flush method is called when an Operation that is caching values must empty the cache.
flush(FlowProcess, OperationCall<AggregateBy.CompositeFunction.Context>) - Method in class cascading.pipe.assembly.AggregateBy.CompositeFunction
 
fmix(int, int) - Static method in class cascading.util.Murmur3
 
ForeverValueIterator<Value> - Class in cascading.util
The ForeverValueIterator class will iterate over a single value forever.
ForeverValueIterator(Value) - Constructor for class cascading.util.ForeverValueIterator
 
Fork<Incoming,Outgoing> - Class in cascading.flow.stream.duct
 
Fork(Duct[]) - Constructor for class cascading.flow.stream.duct.Fork
 
format(String) - Method in class cascading.tuple.Tuple
Method format uses the Formatter class for formatting this tuples values into a new string.
formatDurationDHMSms(long) - Static method in class cascading.util.Util
 
formatDurationFromMillis(long) - Static method in class cascading.util.Util
 
formatDurationHMSms(long) - Static method in class cascading.util.Util
 
formatDurationMSms(long) - Static method in class cascading.util.Util
 
formatRawTrace(Pipe, String) - Static method in class cascading.util.TraceUtil
Method formatRawTrace does not include the pipe name
formatTrace(Scheme, String) - Static method in class cascading.util.TraceUtil
 
formatTrace(FlowElement, String) - Static method in class cascading.util.TraceUtil
 
formatTrace(Pipe, String) - Static method in class cascading.util.TraceUtil
 
formatTrace(Tap, String) - Static method in class cascading.util.TraceUtil
 
formatTrace(Operation, String) - Static method in class cascading.util.TraceUtil
 
foundElements - Variable in class cascading.flow.planner.iso.finder.Match
 
foundMatch() - Method in class cascading.flow.planner.iso.finder.Match
 
foundScopes - Variable in class cascading.flow.planner.iso.finder.Match
 
frameworks - Variable in class cascading.property.AppProps
 
frequency(Tuple, Object) - Static method in class cascading.tuple.Tuples
Method frequency behaves the same as Collections.frequency(java.util.Collection, Object).
frequency(TupleEntry, Object) - Static method in class cascading.tuple.Tuples
Method frequency behaves the same as Collections.frequency(java.util.Collection, Object).
Function<Context> - Interface in cascading.operation
Interface Function marks a given Operation as a function, as opposed to being a Filter.
FunctionCall<C> - Interface in cascading.operation
Interface FunctionCall provides access to the current Function invocation arguments.
FunctionEachStage - Class in cascading.flow.stream.element
 
FunctionEachStage(FlowProcess, Each) - Constructor for class cascading.flow.stream.element.FunctionEachStage
 

G

Gate<Incoming,Outgoing> - Class in cascading.flow.stream.duct
Denotes there will be multiple input paths into this duct
Gate() - Constructor for class cascading.flow.stream.duct.Gate
 
GATHER_PARTITIONS - Static variable in class cascading.flow.FlowRuntimeProps
 
get(String, String) - Method in class cascading.management.CascadingServices.NullDocumentService
 
get(String, String) - Method in interface cascading.management.DocumentService
 
get(String) - Method in interface cascading.property.ConfigDef.Getter
 
get(String) - Method in interface cascading.property.ConfigDef.Setter
 
get(Object) - Method in class cascading.tuple.collect.SpillableTupleMap
 
get(int) - Method in class cascading.tuple.Fields
Method get returns the field name or position at the given index i.
get(int[]) - Method in class cascading.tuple.Tuple
Method get will return a new Tuple instance populated with element values from the given array of positions.
get(Fields, Fields) - Method in class cascading.tuple.Tuple
Method get returns a new Tuple populated with only those values whose field names are specified in the given selector.
get(Object) - Method in class cascading.util.cache.DirectMappedCache
 
get(Object) - Method in class cascading.util.cache.LRUHashMapCache
 
get(Object) - Method in class cascading.util.cache.OrderedHashMapCache
 
get(K, int) - Method in class cascading.util.SortedListMultiMap
 
getAction() - Method in enum cascading.flow.planner.rule.PlanPhase
 
getAggregator() - Method in class cascading.pipe.Every
 
getAggregators() - Method in class cascading.pipe.assembly.AggregateBy
 
getAllAccumulatedSources() - Method in class cascading.flow.planner.BaseFlowStep
 
getAllDucts() - Method in class cascading.flow.stream.graph.StreamGraph
 
getAllEdges(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
getAllEdges(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
getAllEdges(FlowElement, FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
getAllEdges(PlannerContext, ElementGraph, Map<ElementExpression, FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
getAllEdges(Process, Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getAllEdges(Process, Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getAllKeys() - Method in class cascading.property.ConfigDef
 
getAllOperations() - Method in class cascading.flow.planner.BaseFlowStep
 
getAllShortestPathsBetween(ElementGraph, FlowElement, FlowElement) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
getAllShortestPathsBetween(DirectedGraph<V, E>, V, V) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
getAllSinkElements() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getAllSinkElements() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getAllSourceElements() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getAllSourceElements() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getAllTaps() - Method in class cascading.cascade.BaseCascade
 
getAllTaps() - Method in interface cascading.cascade.Cascade
Method getAllTaps returns all source, sink, and checkpoint Tap instances associated with the managed Flow instances in this Cascade instance.
getAllValues(K...) - Method in class cascading.util.MultiMap
 
getAnchors() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getAnnotatedSubGraphs() - Method in class cascading.flow.planner.iso.subgraph.Partitions
 
getAnnotation() - Method in class cascading.flow.planner.iso.ElementAnnotation
 
getAnnotationExcludes() - Method in class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
 
getAnnotationExcludes() - Method in class cascading.flow.planner.rule.partitioner.WholeGraphRulePartitioner
 
getAnnotationExcludes() - Method in class cascading.flow.planner.rule.RulePartitioner
 
getAnnotationMap(ElementAnnotation[]) - Method in class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
getAnnotationMap(ElementAnnotation[]) - Method in class cascading.flow.planner.iso.subgraph.iterator.IncludeRemainderSubGraphIterator
 
getAnnotationMap(ElementAnnotation[]) - Method in class cascading.flow.planner.iso.subgraph.iterator.UniquePathSubGraphIterator
 
getAnnotationMap(ElementAnnotation[]) - Method in interface cascading.flow.planner.iso.subgraph.SubGraphIterator
 
getAnnotations() - Method in class cascading.flow.planner.BaseFlowStep
 
getAnnotations() - Method in class cascading.flow.planner.graph.AnnotatedDecoratedElementGraph
 
getAnnotations() - Method in interface cascading.flow.planner.graph.AnnotatedGraph
 
getAnnotations() - Method in class cascading.flow.planner.graph.BaseAnnotatedElementGraph
 
getAnnotations() - Method in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
getAnnotations() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getAnnotations() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getAppID() - Method in class cascading.stats.FlowStats
 
getApplicationFrameworks(Map<Object, Object>) - Static method in class cascading.property.AppProps
 
getApplicationID(Map<Object, Object>) - Static method in class cascading.property.AppProps
 
getApplicationID() - Static method in class cascading.property.AppProps
 
getApplicationJarClass(Map<Object, Object>) - Static method in class cascading.property.AppProps
Method getApplicationJarClass returns the Class set by the setApplicationJarClass method.
getApplicationJarPath(Map<Object, Object>) - Static method in class cascading.property.AppProps
Method getApplicationJarPath return the path set by the setApplicationJarPath method.
getApplicationName(Map<Object, Object>) - Static method in class cascading.property.AppProps
 
getApplicationTags(Map<Object, Object>) - Static method in class cascading.property.AppProps
 
getApplicationVersion(Map<Object, Object>) - Static method in class cascading.property.AppProps
 
getApplies() - Method in class cascading.flow.planner.iso.expression.ScopeExpression
 
getAppName() - Method in class cascading.stats.FlowStats
 
getArgumentFields() - Method in class cascading.operation.ConcreteCall
 
getArgumentFields() - Method in interface cascading.operation.OperationCall
Returns the Fields of the expected arguments TupleEntry.
getArgumentFields() - Method in class cascading.pipe.assembly.AggregateBy
 
getArguments() - Method in interface cascading.operation.AggregatorCall
Returns TupleEntry of argument values.
getArguments() - Method in class cascading.operation.ConcreteCall
 
getArguments() - Method in interface cascading.operation.FilterCall
Returns TupleEntry of argument values.
getArguments() - Method in interface cascading.operation.FunctionCall
Returns TupleEntry of argument values.
getArguments() - Method in interface cascading.operation.GroupAssertionCall
Returns TupleEntry of argument values.
getArguments() - Method in interface cascading.operation.ValueAssertionCall
Returns TupleEntry of argument values.
getArgumentsDeclarator() - Method in class cascading.flow.planner.Scope
Method getArguments returns the arguments of this Scope object.
getArgumentSelector() - Method in class cascading.pipe.Operator
Method getArgumentSelector returns the argumentSelector of this Operator object.
getArgumentSelector() - Method in exception cascading.pipe.OperatorException
Method getArgumentSelector returns the argumentSelector of this OperatorException object.
getArgumentSelectors() - Method in class cascading.operation.filter.Logic
 
getArgumentsIterator() - Method in interface cascading.operation.BufferCall
Returns an Iterator of TupleEntry instances representing the arguments for the called Buffer.operate(cascading.flow.FlowProcess, BufferCall) method.
getArgumentsIterator() - Method in class cascading.operation.ConcreteCall
 
getArgumentsSelector() - Method in class cascading.flow.planner.Scope
Method getArgumentSelector returns the argumentSelector of this Scope object.
getAssemblyGraph() - Method in class cascading.flow.planner.rule.RuleResult
 
getAssemblyPlanners() - Method in class cascading.flow.FlowDef
Method getAssemblyPlanners returns the current registered AssemblyPlanners.
getAssemblyToStepGraphMap() - Method in class cascading.flow.planner.rule.RuleResult
 
getAssertionLevel() - Method in class cascading.flow.FlowConnectorProps
 
getAssertionLevel() - Method in class cascading.flow.FlowDef
 
getAssertionLevel(FlowDef) - Method in class cascading.flow.planner.FlowPlanner
 
getAssertionType() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getAttempts() - Method in class cascading.stats.FlowSliceStats
 
getBeginGraph() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getBeginGraph() - Method in class cascading.flow.planner.iso.GraphResult
 
getBeginGraph() - Method in class cascading.flow.planner.iso.subgraph.Partitions
 
getBeginGraph() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getBlock() - Method in class cascading.operation.expression.ScriptOperation
 
getBoolean(int) - Method in class cascading.tuple.Tuple
Method getBoolean returns the element at the given position as a boolean.
getBoolean(Comparable) - Method in class cascading.tuple.TupleEntry
Method getBoolean returns the element for the given field name or position as a boolean.
getBooleanProperty(String) - Method in class cascading.flow.FlowProcess
Method getBooleanProperty should be used to return configuration parameters from the underlying system.
getBooleanProperty(String, boolean) - Method in class cascading.flow.FlowProcess
Method getBooleanProperty should be used to return configuration parameters from the underlying system.
getBoundary() - Method in class cascading.flow.stream.element.BoundaryStage
 
getBranchNames() - Method in class cascading.flow.stream.element.BoundaryStage
 
getBranchNames() - Method in interface cascading.flow.stream.element.ElementDuct
 
getBranchNames() - Method in class cascading.flow.stream.element.ElementStage
 
getBranchNames() - Method in class cascading.flow.stream.element.SpliceGate
 
getBuffer() - Method in class cascading.pipe.Every
 
getCacheFactoryClassName() - Method in class cascading.pipe.assembly.AggregateByProps
Returns the name of the cache factory.
getCacheFactoryClassName() - Method in class cascading.pipe.assembly.UniqueProps
Returns the name of the cache factory.
getCalendar() - Method in class cascading.operation.text.DateOperation
 
getCalendar() - Method in class cascading.tuple.type.DateType
 
getCanonicalType() - Method in class cascading.tuple.coerce.BigDecimalCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.BooleanCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.BooleanObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.CharacterCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.CharacterObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.DoubleCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.DoubleObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.FloatCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.FloatObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.IntegerCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.IntegerObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.LongCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.LongObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.ObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.ShortCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.ShortObjectCoerce
 
getCanonicalType() - Method in class cascading.tuple.coerce.StringCoerce
 
getCanonicalType() - Method in interface cascading.tuple.type.CoercibleType
 
getCanonicalType() - Method in class cascading.tuple.type.DateType
 
getCanonicalTypes(Type[]) - Static method in class cascading.tuple.coerce.Coercions
 
getCapacity() - Method in class cascading.pipe.assembly.AggregateBy
 
getCapacity() - Method in class cascading.pipe.assembly.AggregateByProps
Returns the capacity.
getCapacity() - Method in class cascading.pipe.assembly.UniqueProps
Returns the capacity.
getCapacity() - Method in interface cascading.util.cache.CascadingCache
Returns the capacity of this cache.
getCapacity() - Method in class cascading.util.cache.DirectMappedCache
 
getCapacity() - Method in class cascading.util.cache.LRUHashMapCache
 
getCapacity() - Method in class cascading.util.cache.OrderedHashMapCache
 
getCapture() - Method in class cascading.flow.planner.iso.ElementAnnotation
 
getCapture() - Method in class cascading.flow.planner.iso.expression.ElementExpression
 
getCapture() - Method in class cascading.flow.planner.iso.expression.NotElementExpression
 
getCapturedElements(ElementCapture...) - Method in class cascading.flow.planner.iso.finder.Match
 
getCaptureMap() - Method in class cascading.flow.planner.iso.finder.Match
 
getCascade() - Method in class cascading.stats.CascadeStats
 
getCascadeID() - Method in class cascading.flow.BaseFlow
 
getCascadeID() - Method in interface cascading.flow.Flow
Returns the parent Cascade ID that owns this Flow instance.
getCascadeStats() - Method in class cascading.cascade.BaseCascade
 
getCascadeStats() - Method in interface cascading.cascade.Cascade
Method getCascadeStats returns the cascadeStats of this Cascade object.
getCascadingServices() - Method in class cascading.flow.BaseFlow
 
getCascadingServices() - Method in class cascading.flow.FlowSession
 
getChar(int) - Method in class cascading.tuple.Tuple
Method getChar returns the element at the given position as a char.
getCheckpointNames() - Method in class cascading.flow.BaseFlow
 
getCheckpointNames() - Method in interface cascading.flow.Flow
 
getCheckpoints() - Method in class cascading.flow.BaseFlow
 
getCheckpoints() - Method in interface cascading.flow.Flow
Method getCheckpoints returns the checkpoint taps of this Flow object.
getCheckpoints() - Method in class cascading.flow.FlowDef
Method getCheckpoints returns the checkpoint taps of this FlowDef object.
getCheckpointsCollection() - Method in class cascading.flow.BaseFlow
 
getCheckpointsCollection() - Method in interface cascading.flow.Flow
Method getCheckpointsCollection returns a Collection of checkpoint Taps for this Flow object.
getCheckpointsCopy() - Method in class cascading.flow.FlowDef
Method getCheckpointsCopy returns a copy of the checkpoint tap Map.
getCheckpointsMap() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
getCheckpointsTaps() - Method in class cascading.cascade.BaseCascade
 
getCheckpointsTaps() - Method in interface cascading.cascade.Cascade
Method getCheckpointTaps returns all checkpoint Tap instances from all the Flow instances in this Cascade instance.
getCheckpointTapDecoratorClassName() - Method in class cascading.flow.FlowConnectorProps
 
getChildIdentifiers(FlowProcess<? extends Config>) - Method in interface cascading.tap.type.FileType
Method getChildIdentifiers returns an array of child identifiers if this resource is a directory.
getChildIdentifiers(Config) - Method in interface cascading.tap.type.FileType
Method getChildIdentifiers returns an array of child identifiers if this resource is a directory.
getChildIdentifiers(FlowProcess<? extends Config>, int, boolean) - Method in interface cascading.tap.type.FileType
 
getChildIdentifiers(Config, int, boolean) - Method in interface cascading.tap.type.FileType
 
getChildPartitionIdentifiers(FlowProcess<? extends Config>, boolean) - Method in class cascading.tap.partition.BasePartitionTap
Method getChildPartitionIdentifiers returns an array of all identifiers for all available partitions.
getChildren(ElementGraph) - Method in class cascading.flow.planner.rule.util.ResultTree
 
getChildren() - Method in class cascading.stats.CascadeStats
 
getChildren() - Method in class cascading.stats.CascadingStats
Method getChildren returns any relevant child statistics instances.
getChildren() - Method in class cascading.stats.FlowStats
 
getChildren() - Method in class cascading.stats.FlowStepStats
 
getChildren() - Method in class cascading.stats.process.ProcessFlowStats
 
getChildren() - Method in class cascading.stats.process.ProcessStepStats
 
getChildTaps() - Method in interface cascading.tap.CompositeTap
 
getChildTaps() - Method in class cascading.tap.MultiSinkTap
 
getChildTaps() - Method in class cascading.tap.MultiSourceTap
 
getChildTransforms() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getChildTransforms() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getChildWith(String) - Method in class cascading.stats.CascadeStats
 
getChildWith(String) - Method in class cascading.stats.CascadingStats
Method getChildWith returns a child stats instance with the given ID value.
getChildWith(String) - Method in class cascading.stats.FlowStats
 
getChildWith(String) - Method in class cascading.stats.FlowStepStats
 
getClassPath() - Method in class cascading.flow.BaseFlow
 
getClassPath() - Method in class cascading.flow.FlowDef
 
getCloseableInput() - Method in class cascading.util.SingleValueCloseableIterator
 
getCodecClass(FlowProcess, String, Class) - Static method in class cascading.tuple.collect.SpillableTupleList
 
getCodecs() - Method in class cascading.tuple.collect.SpillableProps
 
getCoercedTuple(Type[]) - Method in class cascading.tuple.TupleEntry
Method getCoercedTuple is a helper method for copying the current tuple elements into a new Tuple, of the same size, as the requested coerced types.
getCoercedTuple(Type[], Tuple) - Method in class cascading.tuple.TupleEntry
Method getCoercedTuple is a helper method for copying the current tuple elements into the new Tuple, of the same size, as the requested coerced types.
getComparator(Class<T>) - Method in interface cascading.tuple.Comparison
 
getComparator(Comparable) - Method in class cascading.tuple.Fields
 
getComparatorFor(int, DataInputStream) - Method in interface cascading.tuple.io.TupleInputStream.ElementReader
 
getComparatorFor(int) - Method in class cascading.tuple.io.TupleInputStream
 
getComparators() - Method in class cascading.flow.stream.util.SparseTupleComparator
 
getComparators() - Method in class cascading.tuple.Fields
Method getComparators returns the comparators of this Fields object.
getComponentAttributes(T) - Method in interface cascading.util.jgrapht.ComponentAttributeProvider
 
getConfig() - Method in interface cascading.flow.Flow
Method getConfig returns the internal configuration object.
getConfig() - Method in class cascading.flow.FlowProcess
Method getConfig returns the actual instance of the underlying configuration instance.
getConfig() - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getConfig() - Method in class cascading.flow.FlowProcessWrapper
 
getConfig() - Method in interface cascading.flow.FlowStep
Method getConfig returns the current initialized configuration.
getConfig() - Method in class cascading.flow.planner.BaseFlowStep
 
getConfig() - Method in class cascading.flow.planner.FlowStepJob
 
getConfig() - Method in class cascading.flow.process.ProcessFlow
 
getConfigAsProperties() - Method in interface cascading.flow.Flow
Method getConfigAsProperties converts the internal configuration object into a Map of key value pairs.
getConfigAsProperties() - Method in interface cascading.flow.FlowStep
Method getConfigAsProperties converts the internal configuration object into a Map of key value pairs.
getConfigAsProperties() - Method in class cascading.flow.planner.BaseFlowStep
 
getConfigAsProperties() - Method in class cascading.flow.process.ProcessFlow
 
getConfigAsProperties() - Method in class cascading.flow.process.ProcessFlowStep
 
getConfigCopy() - Method in interface cascading.flow.Flow
Method getConfigCopy returns a copy of the internal configuration object.
getConfigCopy() - Method in class cascading.flow.FlowProcess
 
getConfigCopy() - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getConfigCopy() - Method in class cascading.flow.FlowProcessWrapper
 
getConfigCopy() - Method in class cascading.flow.process.ProcessFlow
 
getConfigDef() - Method in interface cascading.flow.FlowElement
 
getConfigDef() - Method in enum cascading.flow.planner.graph.Extent
 
getConfigDef() - Method in class cascading.pipe.Pipe
Returns a ConfigDef instance that allows for local properties to be set and made available via a resulting FlowProcess instance when the pipe is invoked.
getConfigDef() - Method in class cascading.tap.DecoratorTap
 
getConfigDef() - Method in class cascading.tap.Tap
Returns a ConfigDef instance that allows for local properties to be set and made available via a resulting FlowProcess instance when the tap is invoked.
getContext() - Method in class cascading.operation.ConcreteCall
 
getContext() - Method in interface cascading.operation.OperationCall
Returns the user set context object, C.
getContext() - Method in class cascading.scheme.ConcreteCall
 
getContext() - Method in interface cascading.scheme.SinkCall
Method getContext returns the context of this SinkCall object.
getContext() - Method in interface cascading.scheme.SourceCall
Method getContext returns the context of this SourceCall object.
getContractedGraph() - Method in class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
getContractedMatchExpression() - Method in class cascading.flow.planner.rule.RuleExpression
 
getContractionExpression() - Method in class cascading.flow.planner.rule.RuleExpression
 
getContractionGraph() - Method in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
getCounterEnum() - Method in class cascading.operation.state.Counter
 
getCounterGroups() - Method in class cascading.stats.CascadeStats
 
getCounterGroups() - Method in class cascading.stats.FlowStats
 
getCounterGroups() - Method in class cascading.stats.process.ProcessStepStats
 
getCounterGroups() - Method in interface cascading.stats.ProvidesCounters
Method getCounterGroups returns all the available counter group names.
getCounterGroupsMatching(String) - Method in class cascading.stats.CascadeStats
 
getCounterGroupsMatching(String) - Method in class cascading.stats.CascadingStats
Method getCounterGroupsMatching returns all the available counter group names that match the given regular expression.
getCounterGroupsMatching(String) - Method in class cascading.stats.FlowStats
 
getCounterGroupsMatching(String) - Method in class cascading.stats.process.ProcessStepStats
 
getCounters() - Method in class cascading.stats.FlowSliceStats
 
getCountersFor(String) - Method in class cascading.stats.CascadeStats
 
getCountersFor(Class<? extends Enum>) - Method in class cascading.stats.CascadingStats
 
getCountersFor(String) - Method in class cascading.stats.FlowStats
 
getCountersFor(String) - Method in class cascading.stats.process.ProcessStepStats
 
getCountersFor(String) - Method in interface cascading.stats.ProvidesCounters
Method getCountersFor returns all the counter names for the give group name.
getCountersFor(Class<? extends Enum>) - Method in interface cascading.stats.ProvidesCounters
Method getCountersFor returns all the counter names for the counter Enum.
getCounterString() - Method in class cascading.operation.state.Counter
 
getCounterValue(Enum) - Method in class cascading.flow.FlowProcess
Method getCounterValue is used to retrieve a counter value.
getCounterValue(String, String) - Method in class cascading.flow.FlowProcess
Method getCounterValue is used to retrieve a counter value.
getCounterValue(Enum) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getCounterValue(String, String) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getCounterValue(Enum) - Method in class cascading.flow.FlowProcessWrapper
 
getCounterValue(String, String) - Method in class cascading.flow.FlowProcessWrapper
 
getCounterValue(Enum) - Method in class cascading.stats.CascadeStats
 
getCounterValue(String, String) - Method in class cascading.stats.CascadeStats
 
getCounterValue(Enum) - Method in class cascading.stats.FlowStats
 
getCounterValue(String, String) - Method in class cascading.stats.FlowStats
 
getCounterValue(Enum) - Method in class cascading.stats.process.ProcessStepStats
 
getCounterValue(String, String) - Method in class cascading.stats.process.ProcessStepStats
 
getCounterValue(Enum) - Method in interface cascading.stats.ProvidesCounters
Method getCounter returns the current value for the given counter Enum.
getCounterValue(String, String) - Method in interface cascading.stats.ProvidesCounters
Method getCounter returns the current value for the given group and counter.
getCreateFlowStepJob(FlowProcess<Config>, Config) - Method in class cascading.flow.planner.BaseFlowStep
 
getCurrentDuration() - Method in class cascading.stats.CascadingStats
Method getCurrentDuration returns the current duration of the current work whether or not the work is finished.
getCurrentIdentifier(FlowProcess<? extends Config>) - Method in class cascading.tap.partition.BasePartitionTap
 
getCurrentProcess() - Method in class cascading.flow.FlowSession
Method getCurrentProcess returns the currentProcess of this FlowSession object.
getCurrentSession() - Method in class cascading.flow.FlowProcess
Method getCurrentSession returns the currentSession of this FlowProcess object.
getCurrentSession() - Method in class cascading.flow.FlowProcessWrapper
 
getCurrentSliceNum() - Method in class cascading.flow.FlowProcess
Method getCurrentSliceNum returns an integer representing which slice instance currently running.
getCurrentSliceNum() - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getCurrentSliceNum() - Method in class cascading.flow.FlowProcessWrapper
 
getDateFormat() - Method in class cascading.operation.text.DateOperation
Method getDateFormat returns the dateFormat of this DateParser object.
getDateFormat() - Method in class cascading.tuple.type.DateType
 
getDateFormatString() - Method in class cascading.operation.text.DateOperation
 
getDebugLevel() - Method in class cascading.flow.FlowConnectorProps
 
getDebugLevel() - Method in class cascading.flow.FlowDef
 
getDebugLevel(FlowDef) - Method in class cascading.flow.planner.FlowPlanner
 
getDeclaredFields() - Method in interface cascading.operation.AggregatorCall
Return the resolved Fields declared by the current Operation.
getDeclaredFields() - Method in interface cascading.operation.BufferCall
Return the resolved Fields declared by the current Operation.
getDeclaredFields() - Method in class cascading.operation.ConcreteCall
 
getDeclaredFields() - Method in interface cascading.operation.FunctionCall
Return the resolved Fields declared by the current Operation.
getDeclaredFields() - Method in interface cascading.pipe.assembly.AggregateBy.Functor
Method getDeclaredFields returns the declaredFields of this Functor object.
getDeclaredFields() - Method in class cascading.pipe.assembly.AverageBy.AveragePartials
 
getDeclaredFields() - Method in class cascading.pipe.assembly.CountBy.CountPartials
 
getDeclaredFields() - Method in class cascading.pipe.assembly.FirstBy.FirstPartials
 
getDeclaredFields() - Method in class cascading.pipe.assembly.MaxBy.MaxPartials
 
getDeclaredFields() - Method in class cascading.pipe.assembly.MinBy.MinPartials
 
getDeclaredFields() - Method in class cascading.pipe.assembly.SumBy.SumPartials
 
getDeclaredFields() - Method in exception cascading.pipe.OperatorException
Method getDeclaredFields returns the declaredFields of this OperatorException object.
getDeclaredFields() - Method in class cascading.pipe.Splice
Method getDeclaredFields returns the declaredFields of this Splice object.
getDecorated() - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
getDefaultConfig() - Method in class cascading.flow.planner.FlowPlanner
 
getDefaultIntermediateSchemeClass() - Method in class cascading.flow.FlowConnector
 
getDefaultProperties() - Method in class cascading.flow.planner.FlowPlanner
 
getDefaultTupleElementComparator() - Method in class cascading.flow.FlowProps
 
getDelegate() - Method in class cascading.flow.FlowProcessWrapper
 
getDelegatedTuple(Tuple) - Method in class cascading.flow.stream.element.GroupingSpliceGate
This allows the tuple to honor the hasher and comparators, if any
getDelimiter() - Method in class cascading.operation.regex.RegexMatcher
 
getDelimiter() - Method in class cascading.operation.text.FieldJoiner
Method getFormat returns the delimiter of this FieldJoiner object.
getDelimiter() - Method in class cascading.scheme.util.DelimitedParser
 
getDepthFirstIterator() - Method in class cascading.flow.planner.graph.FlowElementGraph
Method getDepthFirstIterator returns the depthFirstIterator of this ElementGraph object.
getDiagnostics() - Method in class cascading.stats.FlowSliceStats
 
getDocumentService() - Method in class cascading.management.CascadingServices
 
getDouble(int) - Method in class cascading.tuple.Tuple
Method getDouble returns the element at the given position as a double.
getDouble(Comparable) - Method in class cascading.tuple.TupleEntry
Method getDouble returns the element for the given field name or position as a double.
getDuplicatedElements(ElementGraph) - Method in class cascading.flow.planner.process.BaseProcessGraph
All elements, from the given ElementGraph, that belong to two or more processes, that are not sink or source elements that connect processes.
getDuplicatedElements(ElementGraph) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getDuration() - Method in class cascading.flow.planner.rule.RuleResult
 
getDuration() - Method in class cascading.stats.CascadingStats
Method getDuration returns the duration the work executed before being finished.
getEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
getEdge(FlowElement, FlowElement) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
getEdge(FlowElement, FlowElement) - Method in interface cascading.flow.planner.graph.ElementGraph
 
getEdge(Process, Process) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getEdge(Process, Process) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getEdge(ElementGraph, ElementGraph) - Method in class cascading.flow.planner.rule.util.ResultTree
 
getEdgeAnnotations() - Method in class cascading.flow.planner.process.ProcessEdge
Returns any edge annotations, or an empty immutable Map.
getEdgeMapping(PlannerContext, ElementGraph, Map<ElementExpression, FlowElement>) - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
getEdgeName(E) - Method in interface cascading.util.jgrapht.EdgeNameProvider
 
getEdgeName(E) - Method in class cascading.util.jgrapht.StringEdgeNameProvider
 
getEdgeSource(Scope) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
getEdgeSource(Scope) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
getEdgeSource(Scope) - Method in interface cascading.flow.planner.graph.ElementGraph
 
getEdgeSource(ProcessEdge) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getEdgeSource(ProcessEdge) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getEdgeTarget(Scope) - Method in class cascading.flow.planner.graph.BaseElementGraph
 
getEdgeTarget(Scope) - Method in class cascading.flow.planner.graph.DecoratedElementGraph
 
getEdgeTarget(Scope) - Method in interface cascading.flow.planner.graph.ElementGraph
 
getEdgeTarget(ProcessEdge) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getEdgeTarget(ProcessEdge) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getEdgeWeight(ProcessEdge) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getEdgeWeight(ProcessEdge) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementFactory(String) - Method in class cascading.flow.planner.rule.RuleRegistry
 
getElementFactoryFor(String) - Method in class cascading.flow.planner.PlannerContext
 
getElementGraph() - Method in class cascading.flow.planner.BaseFlowNode
 
getElementGraph() - Method in class cascading.flow.planner.BaseFlowStep
 
getElementGraph() - Method in class cascading.flow.planner.iso.finder.Match
 
getElementGraph() - Method in class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
getElementGraph() - Method in class cascading.flow.planner.iso.subgraph.iterator.IncludeRemainderSubGraphIterator
 
getElementGraph() - Method in class cascading.flow.planner.iso.subgraph.iterator.UniquePathSubGraphIterator
 
getElementGraph() - Method in interface cascading.flow.planner.iso.subgraph.SubGraphIterator
 
getElementGraph() - Method in exception cascading.flow.planner.PlannerException
Method getElementGraph returns the elementGraph of this PlannerException object.
getElementGraph() - Method in interface cascading.flow.planner.process.ProcessModel
 
getElementGraphs(FlowElement) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementGraphs(Scope) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementGraphs(FlowElement) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementGraphs(Scope) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementProcesses(FlowElement) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementProcesses(Scope) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementProcesses(FlowElement) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementProcesses(Scope) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementSinkProcesses(FlowElement) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementSinkProcesses(FlowElement) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getElementSourceProcesses(FlowElement) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getElementSourceProcesses(FlowElement) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getEndGraph() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getEndGraph() - Method in class cascading.flow.planner.iso.GraphResult
 
getEndGraph() - Method in class cascading.flow.planner.iso.subgraph.Partitions
 
getEndGraph() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getEntries() - Method in class cascading.util.MultiMap
 
getEvaluator(Class, String[], Class[]) - Method in class cascading.operation.expression.ExpressionOperation
 
getEvaluator(Class, String[], Class[]) - Method in class cascading.operation.expression.ScriptOperation
 
getEventId() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getExpression() - Method in class cascading.operation.expression.ExpressionOperation
 
getExpressionGraph() - Method in class cascading.flow.planner.iso.subgraph.partitioner.ExpressionGraphPartitioner
 
getExpressionName() - Method in class cascading.flow.planner.rule.RuleExpression
 
getFieldDeclaration() - Method in interface cascading.flow.planner.DeclaresResults
 
getFieldDeclaration() - Method in class cascading.operation.BaseOperation
 
getFieldDeclaration() - Method in interface cascading.operation.Operation
Returns the fields created by this Operation instance.
getFieldDeclaration() - Method in class cascading.pipe.joiner.BaseJoiner
 
getFieldDeclaration() - Method in class cascading.pipe.Operator
Method getFieldDeclaration returns the fieldDeclaration of this Operator object.
getFieldDeclarations() - Method in class cascading.pipe.assembly.AggregateBy
Method getFieldDeclarations returns an array of Fields where each Field element in the array corresponds to the field declaration of the given Aggregator operations.
getFields() - Method in class cascading.tuple.TupleEntry
Method getFields returns the fields of this TupleEntry object.
getFields() - Method in class cascading.tuple.TupleEntryIterator
Method getFields returns the fields of this TupleEntryIterator object.
getFieldsFor(FlowElementGraph, Tap) - Method in class cascading.flow.BaseFlow
 
getFieldsSize() - Method in class cascading.operation.filter.Logic
 
getFilter() - Method in class cascading.operation.filter.Not
 
getFilter() - Method in class cascading.pipe.Each
 
getFilters() - Method in class cascading.operation.filter.Logic
 
getFinishedTime() - Method in class cascading.stats.CascadingStats
Method getFinishedTime returns the finishedTime of this CascadingStats object.
getFirst(Collection<V>) - Static method in class cascading.util.Util
 
getFirstAnchor() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getFirstN() - Method in class cascading.operation.aggregator.First
 
getFirstN() - Method in class cascading.operation.buffer.FirstNBuffer
 
getFirstValue() - Method in class cascading.operation.function.SetValue
 
getFloat(int) - Method in class cascading.tuple.Tuple
Method getFloat returns the element at the given position as a float.
getFloat(Comparable) - Method in class cascading.tuple.TupleEntry
Method getFloat returns the element for the given field name or position as a float.
getFlow() - Method in interface cascading.flow.AssemblyPlanner.Context
 
getFlow() - Method in interface cascading.flow.FlowStep
 
getFlow() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlow() - Method in class cascading.flow.planner.PlannerContext
 
getFlow() - Method in class cascading.stats.FlowStats
 
getFlowCount() - Method in class cascading.stats.CascadeStats
Method getFlowCount returns the number of Flows executed by the Cascade.
getFlowDef() - Method in interface cascading.flow.AssemblyPlanner.Context
 
getFlowDef() - Method in class cascading.flow.planner.PlannerContext
 
getFlowDescriptor() - Method in interface cascading.flow.AssemblyPlanner
Returns a map of properties giving more details about the Flow object.
getFlowDescriptor() - Method in class cascading.flow.BaseFlow
 
getFlowDescriptor() - Method in interface cascading.flow.Flow
Returns an immutable map of properties giving more details about the Flow object.
getFlowDescriptor() - Method in class cascading.flow.FlowDef
Method getFlowDescriptor returns the flowDescriptor of this FlowDef.
getFlowElement() - Method in exception cascading.flow.planner.ElementGraphException
Method getFlowElement returns the flowElement of this ElementGraphException object.
getFlowElement() - Method in class cascading.flow.planner.process.ProcessEdge
 
getFlowElement() - Method in class cascading.flow.stream.element.BoundaryStage
 
getFlowElement() - Method in interface cascading.flow.stream.element.ElementDuct
 
getFlowElement() - Method in class cascading.flow.stream.element.ElementStage
 
getFlowElement() - Method in class cascading.flow.stream.element.SpliceGate
 
getFlowElementForID(Set<FlowElement>, String) - Static method in class cascading.flow.Flows
 
getFlowElementGraphFrom(Flow) - Static method in class cascading.flow.Flows
 
getFlowElementID() - Method in class cascading.flow.planner.process.ProcessEdge
 
getFlowElementsFor(Enum) - Method in interface cascading.flow.FlowNode
 
getFlowElementsFor(Enum) - Method in class cascading.flow.planner.BaseFlowNode
 
getFlowElementsFor(Enum) - Method in class cascading.flow.planner.process.FlowNodeGraph
 
getFlowGraph() - Method in class cascading.cascade.BaseCascade
 
getFlowGraphFrom(Cascade) - Static method in class cascading.cascade.Cascades
 
getFlowID() - Method in interface cascading.flow.FlowStep
 
getFlowID() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlowLogger() - Method in class cascading.flow.planner.rule.RuleSetExec
 
getFlowName() - Method in exception cascading.flow.FlowException
Method getFlowName returns the name of the parent Flow instance.
getFlowName() - Method in interface cascading.flow.FlowStep
Method getParentFlowName returns the parentFlowName of this FlowStep object.
getFlowName() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlowNode() - Method in class cascading.stats.FlowNodeStats
 
getFlowNodeGraph() - Method in interface cascading.flow.FlowStep
 
getFlowNodeGraph() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlowNodeIDs() - Method in class cascading.stats.FlowStepStats
 
getFlowNodeStats() - Method in class cascading.stats.FlowStepStats
 
getFlowNodeStatsMap() - Method in class cascading.stats.FlowStepStats
 
getFlowPlanner() - Method in class cascading.flow.planner.PlannerContext
 
getFlowProcess() - Method in interface cascading.flow.Flow
 
getFlowProcess() - Method in class cascading.flow.process.ProcessFlow
 
getFlowProcess() - Method in class cascading.pipe.joiner.JoinerClosure
 
getFlowProcess() - Method in class cascading.tuple.TupleEntrySchemeCollector
 
getFlowProcess() - Method in class cascading.tuple.TupleEntrySchemeIterator
 
getFlowProperties() - Method in class cascading.stats.FlowStats
 
getFlows() - Method in class cascading.cascade.BaseCascade
 
getFlows() - Method in interface cascading.cascade.Cascade
Method getFlows returns the flows managed by this Cascade object.
getFlows() - Method in class cascading.cascade.CascadeDef
Method getFlows returns the flows of this CascadeDef object.
getFlowsArray() - Method in class cascading.cascade.CascadeDef
Method getFlowsArray returns the flows as an array of this CascadeDef object.
getFlowSession() - Method in class cascading.flow.BaseFlow
 
getFlowSkipStrategy() - Method in class cascading.cascade.BaseCascade
 
getFlowSkipStrategy() - Method in interface cascading.cascade.Cascade
Method getFlowSkipStrategy returns the current FlowSkipStrategy used by this Flow.
getFlowSkipStrategy() - Method in class cascading.flow.BaseFlow
 
getFlowSkipStrategy() - Method in interface cascading.flow.Flow
Method getFlowSkipStrategy returns the current FlowSkipStrategy used by this Flow.
getFlowStats() - Method in class cascading.flow.BaseFlow
 
getFlowStats() - Method in interface cascading.flow.Flow
Method getFlowStats returns the flowStats of this Flow object.
getFlowStep() - Method in interface cascading.flow.FlowNode
 
getFlowStep() - Method in class cascading.flow.planner.BaseFlowNode
 
getFlowStep() - Method in class cascading.stats.FlowStepStats
 
getFlowStepJob() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlowSteps() - Method in class cascading.flow.BaseFlow
 
getFlowSteps() - Method in interface cascading.flow.Flow
Method getFlowSteps returns the flowSteps of this Flow object.
getFlowStepStats() - Method in interface cascading.flow.FlowStep
 
getFlowStepStats() - Method in class cascading.flow.planner.BaseFlowStep
 
getFlowStepStats() - Method in class cascading.stats.FlowStats
Method getStepStats returns the stepStats owned by this FlowStats.
getFlowStepStats() - Method in class cascading.stats.process.ProcessFlowStats
 
getFlowStepStrategy() - Method in class cascading.flow.BaseFlow
 
getFlowStepStrategy() - Method in interface cascading.flow.Flow
Returns the current FlowStepStrategy instance.
getFormat() - Method in class cascading.operation.text.FieldFormatter
Method getFormat returns the format of this FieldFormatter object.
getFoundElements() - Method in class cascading.flow.planner.iso.finder.Match
 
getFraction() - Method in class cascading.operation.filter.Sample
 
getFrameworks() - Method in class cascading.property.AppProps
Method getFrameworks returns a list of frameworks used to build this App.
getFullIdentifier(FlowProcess<? extends Config>) - Method in class cascading.tap.DecoratorTap
 
getFullIdentifier(Config) - Method in class cascading.tap.DecoratorTap
 
getFullIdentifier(FlowProcess<? extends Config>) - Method in class cascading.tap.Tap
Method getFullIdentifier returns a fully qualified resource identifier.
getFullIdentifier(Config) - Method in class cascading.tap.Tap
Method getFullIdentifier returns a fully qualified resource identifier.
getFullTransformTracePath(String) - Method in class cascading.flow.planner.rule.util.TraceWriter
 
getFunction() - Method in class cascading.pipe.Each
 
getFunctors() - Method in class cascading.pipe.assembly.AggregateBy
 
getGatherPartitions() - Method in class cascading.flow.FlowRuntimeProps
Method getGatherPartitions returns the number of gather partitions
getGraph() - Method in class cascading.flow.planner.iso.expression.ExpressionGraph
 
getGraph() - Method in exception cascading.flow.planner.iso.finder.GraphFinderException
 
getGraphAssert() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getGraphPartitioner() - Method in class cascading.flow.planner.rule.RulePartitioner
 
getGraphTransform() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getGroup() - Method in interface cascading.flow.FlowStep
 
getGroup() - Method in class cascading.flow.planner.BaseFlowStep
 
getGroup() - Method in interface cascading.operation.AggregatorCall
Returns the current grouping TupleEntry.
getGroup() - Method in interface cascading.operation.BufferCall
Returns the current grouping TupleEntry.
getGroup() - Method in class cascading.operation.ConcreteCall
 
getGroup() - Method in interface cascading.operation.GroupAssertionCall
Returns the current grouping TupleEntry.
getGroupAssertion() - Method in class cascading.pipe.Every
 
getGroupBy() - Method in class cascading.pipe.assembly.AggregateBy
Method getGroupBy returns the internal GroupBy instance so that any custom properties can be set on it via Pipe.getStepConfigDef().
getGroupFieldSelector() - Method in class cascading.operation.function.UnGroup
 
getGrouping() - Method in interface cascading.tuple.collect.Spillable
 
getGrouping() - Method in class cascading.tuple.collect.SpillableTupleList
 
getGrouping() - Method in class cascading.tuple.collect.SpillableTupleMap
 
getGroupingFields() - Method in class cascading.pipe.assembly.AggregateBy
Method getGroupingFields returns the Fields this instances will be grouping against.
getGroupingSelector() - Method in exception cascading.pipe.OperatorException
Method getGroupingSelector returns the groupingSelector of this OperatorException object.
getGroups() - Method in class cascading.flow.planner.BaseFlowNode
 
getGroups() - Method in class cascading.flow.planner.BaseFlowStep
 
getGroups() - Method in interface cascading.flow.planner.process.ProcessModel
 
getGroups() - Method in class cascading.operation.regex.RegexParser
 
getGroupString() - Method in class cascading.operation.state.Counter
 
getGroupTuple(Tuple) - Method in class cascading.flow.stream.element.MemoryCoGroupClosure
 
getGroupTuple(Tuple) - Method in class cascading.pipe.joiner.JoinerClosure
 
getHashFunction() - Method in class cascading.tuple.util.TupleHasher
 
getHeadFlows() - Method in class cascading.cascade.BaseCascade
 
getHeadFlows() - Method in interface cascading.cascade.Cascade
Method getHeadFlows returns all Flow instances that are at the "head" of the flow graph.
getHeads() - Method in class cascading.flow.stream.graph.StreamGraph
 
getHeads() - Method in class cascading.pipe.Pipe
Method getHeads returns the first Pipe instances in this pipe assembly.
getHex(byte[]) - Static method in class cascading.util.Util
 
getHolder() - Method in class cascading.flow.BaseFlow
Used to return a simple wrapper for use as an edge in a graph where there can only be one instance of every edge.
getID() - Method in class cascading.cascade.BaseCascade
Method getID returns the ID of this Cascade object.
getID() - Method in class cascading.flow.BaseFlow
 
getID() - Method in interface cascading.flow.Flow
Method getID returns the ID of this Flow object.
getID() - Method in interface cascading.flow.FlowNode
 
getID() - Method in class cascading.flow.FlowProcess
Method getID() returns the current
getID() - Method in class cascading.flow.FlowProcessWrapper
 
getID() - Method in class cascading.flow.FlowSession
Method getID returns the parent Flow ID value.
getID() - Method in interface cascading.flow.FlowStep
Method getId returns the id of this FlowStep object.
getID() - Method in class cascading.flow.planner.BaseFlowNode
 
getID() - Method in class cascading.flow.planner.BaseFlowStep
 
getID() - Method in class cascading.flow.planner.process.ProcessEdge
 
getID() - Method in interface cascading.flow.planner.process.ProcessModel
 
getID() - Method in class cascading.management.state.BaseState
 
getID() - Method in interface cascading.management.UnitOfWork
 
getID() - Method in class cascading.stats.CascadeStats
 
getID() - Method in class cascading.stats.CascadingStats
Method getID returns the ID of this CascadingStats object.
getID() - Method in class cascading.stats.FlowNodeStats
 
getID() - Method in class cascading.stats.FlowSliceStats
 
getID() - Method in class cascading.stats.FlowStats
 
getID() - Method in class cascading.stats.FlowStepStats
 
getIdentifier() - Method in class cascading.tap.DecoratorTap
 
getIdentifier() - Method in class cascading.tap.MultiSinkTap
 
getIdentifier() - Method in class cascading.tap.MultiSourceTap
 
getIdentifier() - Method in class cascading.tap.partition.BasePartitionTap
 
getIdentifier() - Method in class cascading.tap.Tap
Method getIdentifier returns a String representing the resource this Tap instance represents.
getIdentifierGraph() - Method in class cascading.cascade.BaseCascade
 
getIdentityElementGraphs() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getIdentityElementGraphs() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getIdentityElements(ProcessGraph<? extends ProcessModel>) - Method in class cascading.util.DOTProcessGraphWriter
 
getIdentityProcesses() - Method in class cascading.flow.planner.process.BaseProcessGraph
Returns a set of processes that perform no internal operations.
getIdentityProcesses() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getIgnoreTuples() - Method in class cascading.operation.aggregator.ExtentBase
 
getIgnoreValues() - Method in class cascading.operation.aggregator.ExtremaValueBase
 
getIncludedElements() - Method in class cascading.flow.planner.iso.finder.Match
 
getIncomingAggregatorArgumentFields() - Method in class cascading.flow.planner.Scope
 
getIncomingAggregatorPassThroughFields() - Method in class cascading.flow.planner.Scope
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.AggregatorEveryStage
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.BufferEveryWindow
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.FilterEachStage
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.FunctionEachStage
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.GroupAssertionEveryStage
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.OperatorStage
 
getIncomingArgumentsFields() - Method in class cascading.flow.stream.element.ValueAssertionEachStage
 
getIncomingBufferArgumentFields() - Method in class cascading.flow.planner.Scope
 
getIncomingBufferPassThroughFields() - Method in class cascading.flow.planner.Scope
 
getIncomingEdge(ElementGraph) - Method in class cascading.flow.planner.rule.util.ResultTree
 
getIncomingEntry() - Method in class cascading.scheme.ConcreteCall
 
getIncomingEntry() - Method in interface cascading.scheme.SourceCall
Method getIncomingEntry returns a pre-prepared TupleEntry to be populated with the input values from SourceCall.getInput().
getIncomingFields() - Method in exception cascading.pipe.OperatorException
Method getIncomingFields returns the incomingFields of this OperatorException object.
getIncomingFunctionArgumentFields() - Method in class cascading.flow.planner.Scope
 
getIncomingFunctionPassThroughFields() - Method in class cascading.flow.planner.Scope
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.AggregatorEveryStage
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.BufferEveryWindow
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.FilterEachStage
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.FunctionEachStage
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.GroupAssertionEveryStage
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.OperatorStage
 
getIncomingPassThroughFields() - Method in class cascading.flow.stream.element.ValueAssertionEachStage
 
getIncomingScopes() - Method in class cascading.flow.stream.element.BoundaryStage
 
getIncomingScopes() - Method in interface cascading.flow.stream.element.ElementDuct
 
getIncomingScopes() - Method in class cascading.flow.stream.element.ElementStage
 
getIncomingScopes() - Method in class cascading.flow.stream.element.SpliceGate
 
getIncomingSpliceFields() - Method in class cascading.flow.planner.Scope
 
getIncomingTapFields() - Method in class cascading.flow.planner.Scope
 
getIncrement() - Method in class cascading.operation.state.Counter
 
getIndex() - Method in class cascading.tuple.io.IndexTuple
 
getInitialAssembly() - Method in class cascading.flow.planner.rule.RuleResult
 
getInitListThreshold() - Method in class cascading.tuple.collect.SpillableTupleMap
 
getInput() - Method in class cascading.scheme.ConcreteCall
 
getInput() - Method in interface cascading.scheme.SourceCall
Method getInput returns the input mechanism for the underlying platform used to retrieve new values (records, lines, etc).
getInputStream() - Method in class cascading.tuple.io.TupleInputStream
 
getInstance() - Static method in class cascading.provider.FactoryLoader
 
getInstance(URL, String[]) - Static method in class cascading.provider.ServiceLoader
 
getInt(String[]) - Method in class cascading.management.CascadingServices.NullMetricsService
 
getInt(String[]) - Method in interface cascading.management.MetricsService
 
getInteger(int) - Method in class cascading.tuple.Tuple
Method getInteger returns the element at the given position as an int.
getInteger(Comparable) - Method in class cascading.tuple.TupleEntry
Method getInteger returns the element for the given field name or position as an int.
getIntegerProperty(String) - Method in class cascading.flow.FlowProcess
Method getIntegerProperty should be used to return configuration parameters from the underlying system.
getIntegerProperty(String, int) - Method in class cascading.flow.FlowProcess
Method getIntegerProperty should be used to return configuration parameters from the underlying system.
getIntermediateFlows() - Method in class cascading.cascade.BaseCascade
 
getIntermediateFlows() - Method in interface cascading.cascade.Cascade
Method getIntermediateFlows returns all Flow instances that are neither at the "tail" or "tail" of the flow graph.
getIntermediateSchemeClass(Map<Object, Object>) - Method in class cascading.flow.FlowConnector
Method getIntermediateSchemeClass is used for debugging.
getIntermediateSchemeClassName() - Method in class cascading.flow.FlowConnectorProps
 
getIntermediateTaps() - Method in class cascading.cascade.BaseCascade
 
getIntermediateTaps() - Method in interface cascading.cascade.Cascade
Method getIntermediateTaps returns all Tap instances that are neither at the source or sink of the flow graph.
getIntProperty(String, int) - Method in class cascading.flow.planner.PlannerContext
 
getIntProperty(Map<Object, Object>, String, int) - Static method in class cascading.property.PropertyUtil
 
getIntProperty(Properties, Map<Object, Object>, String, int) - Static method in class cascading.property.PropertyUtil
 
getIterator(int) - Method in class cascading.flow.stream.element.MemoryCoGroupClosure
 
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.BufferJoin
 
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.InnerJoin
 
getIterator(int) - Method in class cascading.pipe.joiner.InnerJoin.JoinIterator
 
getIterator(JoinerClosure) - Method in interface cascading.pipe.joiner.Joiner
Returns an iterator that joins the given CoGroupClosure co-groups.
getIterator(int) - Method in class cascading.pipe.joiner.JoinerClosure
Returns a Tuple Iterator for the given pipe position.
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.LeftJoin
 
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.MixedJoin
 
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.OuterJoin
 
getIterator(int) - Method in class cascading.pipe.joiner.OuterJoin.JoinIterator
 
getIterator(JoinerClosure) - Method in class cascading.pipe.joiner.RightJoin
 
getJobPollingInterval() - Method in class cascading.flow.FlowProps
 
getJobsMap(Flow) - Static method in class cascading.flow.Flows
 
getJoinDeclaredFields() - Method in class cascading.pipe.Splice
 
getJoiner() - Method in class cascading.pipe.Splice
 
getJoinerClosure() - Method in interface cascading.operation.BufferCall
Returns the current instance of a JoinerClosure, if any.
getJoinerClosure() - Method in class cascading.operation.ConcreteCall
 
getJoinFields() - Method in class cascading.pipe.joiner.JoinerClosure
Returns an array of Fields denoting the join fields or keys uses for each incoming pipe.
getKeyComparator() - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
getKeys() - Method in class cascading.util.MultiMap
 
getKeySelectors() - Method in class cascading.flow.planner.Scope
Method getGroupingSelectors returns the groupingSelectors of this Scope object.
getKeySelectors() - Method in interface cascading.pipe.Group
 
getKeySelectors() - Method in class cascading.pipe.Splice
Method getGroupingSelectors returns the groupingSelectors of this Splice object.
getKeysFor(V) - Method in class cascading.util.MultiMap
 
getKind() - Method in class cascading.stats.FlowNodeStats
 
getKind() - Method in class cascading.stats.FlowSliceStats
 
getLastMatch() - Method in class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.CascadeStats
 
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.FlowStats
 
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.process.ProcessStepStats
 
getLastSuccessfulCounterFetchTime() - Method in interface cascading.stats.ProvidesCounters
Method getLastSuccessfulCounterFetchTime returns the time, in millis, the last moment counters were successfully retrieved.
getLevel() - Method in enum cascading.flow.planner.rule.PlanPhase
 
getLevelResults(ProcessLevel) - Method in class cascading.flow.planner.rule.RuleResult
 
getLhs() - Method in class cascading.tuple.io.TuplePair
Method getLhs returns the lhs of this TuplePair object.
getLhs() - Method in class cascading.util.Pair
 
getLimit() - Method in class cascading.operation.filter.Limit
 
getListSpillThreshold() - Method in class cascading.tuple.collect.SpillableProps
 
getLogger() - Method in class cascading.flow.planner.PlannerContext
 
getLong(String[]) - Method in class cascading.management.CascadingServices.NullMetricsService
 
getLong(String[]) - Method in interface cascading.management.MetricsService
 
getLong(int) - Method in class cascading.tuple.Tuple
Method getLong returns the element at the given position as an long.
getLong(Comparable) - Method in class cascading.tuple.TupleEntry
Method getLong returns the element for the given field name or position as a long.
getMap() - Method in class cascading.util.MultiMap
 
getMapCapacity(FlowProcess, int) - Static method in class cascading.tuple.collect.SpillableTupleMap
 
getMapInitialCapacity() - Method in class cascading.tuple.collect.SpillableProps
 
getMapLoadFactor() - Method in class cascading.tuple.collect.SpillableProps
 
getMapLoadFactor(FlowProcess, float) - Static method in class cascading.tuple.collect.SpillableTupleMap
 
getMapSpillThreshold() - Method in class cascading.tuple.collect.SpillableProps
 
getMapThreshold(FlowProcess, int) - Static method in class cascading.tuple.collect.SpillableTupleMap
 
getMapThreshold() - Method in class cascading.tuple.collect.SpillableTupleMap
 
getMatched() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getMatchedGraph() - Method in class cascading.flow.planner.iso.finder.Match
 
getMatches() - Method in class cascading.flow.planner.iso.subgraph.iterator.ExpressionSubGraphIterator
 
getMatchExpression() - Method in class cascading.flow.planner.iso.finder.GraphFinder
 
getMatchExpression() - Method in class cascading.flow.planner.rule.RuleExpression
 
getMatchGraph() - Method in class cascading.flow.planner.iso.finder.Match
 
getMaxConcurrentFlows() - Method in class cascading.cascade.CascadeDef
 
getMaxConcurrentFlows() - Method in class cascading.cascade.CascadeProps
 
getMaxConcurrentSteps() - Method in class cascading.flow.FlowProps
 
getMaxNumParallelSteps() - Method in class cascading.flow.BaseFlow
 
getMaxNumParallelSteps() - Method in class cascading.flow.process.ProcessFlow
 
getMessage() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getMessage() - Method in class cascading.operation.assertion.BaseAssertion
 
getMetaInfo() - Method in class cascading.tap.DecoratorTap
 
getMetricsService() - Method in class cascading.management.CascadingServices
 
getMode() - Method in class cascading.flow.planner.iso.expression.PathScopeExpression
 
getMode() - Method in enum cascading.flow.planner.rule.PlanPhase
 
getMode(ConfigDef.Mode) - Method in class cascading.property.ConfigDef
 
getModeSafe(ConfigDef.Mode) - Method in class cascading.property.ConfigDef
 
getModifiedTime(FlowProcess<? extends Config>) - Method in class cascading.tap.DecoratorTap
 
getModifiedTime(Config) - Method in class cascading.tap.DecoratorTap
 
getModifiedTime(Config) - Method in class cascading.tap.MultiSinkTap
 
getModifiedTime(Config) - Method in class cascading.tap.MultiSourceTap
Returns the most current modified time.
getModifiedTime(Config) - Method in class cascading.tap.partition.BasePartitionTap
 
getModifiedTime(FlowProcess<? extends Config>) - Method in class cascading.tap.Tap
Method getModifiedTime returns the date this resource was last modified.
getModifiedTime(Config) - Method in class cascading.tap.Tap
Method getModifiedTime returns the date this resource was last modified.
getMultiValues(K) - Method in class cascading.util.MultiMap
 
getName() - Method in class cascading.cascade.BaseCascade.CascadeJob
 
getName() - Method in class cascading.cascade.BaseCascade
Method getName returns the name of this Cascade object.
getName() - Method in class cascading.flow.BaseFlow
 
getName() - Method in interface cascading.flow.Flow
Method getName returns the name of this Flow object.
getName() - Method in interface cascading.flow.FlowStep
Method getName returns the name of this FlowStep object.
getName() - Method in class cascading.flow.planner.BaseFlowNode
 
getName() - Method in class cascading.flow.planner.BaseFlowStep
 
getName() - Method in interface cascading.flow.planner.process.ProcessModel
 
getName() - Method in class cascading.flow.planner.rule.RuleRegistry
 
getName() - Method in class cascading.flow.planner.Scope
Method getName returns the name of this Scope object.
getName() - Method in interface cascading.management.UnitOfWork
 
getName() - Method in class cascading.pipe.Boundary
 
getName() - Method in interface cascading.pipe.Group
 
getName() - Method in class cascading.pipe.Pipe
Get the name of this pipe.
getName() - Method in class cascading.pipe.Splice
 
getName() - Method in class cascading.pipe.SubAssembly
 
getName() - Method in class cascading.property.UnitOfWorkDef
 
getName() - Method in class cascading.stats.CascadingStats
Method getName returns the name of this CascadingStats object.
getNameOrID(Flow) - Static method in class cascading.flow.Flows
 
getNext() - Method in class cascading.flow.stream.duct.Duct
 
getNext() - Method in class cascading.flow.stream.duct.Fork
 
getNextElement() - Method in class cascading.tuple.io.TupleInputStream
 
getNextFlowElement(Scope) - Method in class cascading.flow.planner.BaseFlowStep
 
getNextFor(StreamGraph) - Method in class cascading.flow.stream.duct.Duct
 
getNextScope(FlowElement) - Method in class cascading.flow.planner.BaseFlowStep
Method getNextScope returns the next Scope instance in the graph.
getNextScopes(FlowElement) - Method in interface cascading.flow.FlowNode
 
getNextScopes(FlowElement) - Method in class cascading.flow.planner.BaseFlowNode
 
getNodeConfigDef() - Method in interface cascading.flow.FlowElement
 
getNodeConfigDef() - Method in enum cascading.flow.planner.graph.Extent
 
getNodeConfigDef() - Method in class cascading.pipe.Pipe
Returns a ConfigDef instance that allows for process level properties to be set and made available via a resulting FlowProcess instance when the pipe is invoked.
getNodeConfigDef() - Method in class cascading.tap.DecoratorTap
 
getNodeConfigDef() - Method in class cascading.tap.Tap
Returns a ConfigDef instance that allows for process level properties to be set and made available via a resulting FlowProcess instance when the tap is invoked.
getNodeDisplayName(FlowNode, int) - Method in class cascading.flow.planner.BaseFlowStep
 
getNodeIterator(SearchOrder, Graph) - Static method in enum cascading.flow.planner.iso.finder.SearchOrder
 
getNodesCount() - Method in class cascading.stats.FlowStepStats
 
getNodeToPipelineGraphMap() - Method in class cascading.flow.planner.rule.RuleResult
 
getNumArgs() - Method in class cascading.operation.BaseOperation
 
getNumArgs() - Method in interface cascading.operation.Operation
The minimum number of arguments this Operation expects from the calling Each or Every Operator.
getNumChildTaps() - Method in interface cascading.tap.CompositeTap
 
getNumChildTaps() - Method in class cascading.tap.MultiSinkTap
 
getNumChildTaps() - Method in class cascading.tap.MultiSourceTap
 
getNumDeclaredIncomingBranches() - Method in class cascading.flow.stream.element.GroupingSpliceGate
 
getNumElements() - Method in class cascading.tuple.io.TupleInputStream
 
getNumFlowNodes() - Method in interface cascading.flow.FlowStep
 
getNumFlowNodes() - Method in class cascading.flow.planner.BaseFlowStep
 
getNumNodes() - Method in class cascading.flow.planner.rule.RuleResult
 
getNumProcessSlices() - Method in class cascading.flow.FlowProcess
Method getNumProcessSlices returns the number of parallel slices or tasks allocated for this process execution.
getNumProcessSlices() - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getNumProcessSlices() - Method in class cascading.flow.FlowProcessWrapper
 
getNumRecursions() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getNumSelfJoins() - Method in class cascading.pipe.Splice
 
getNumSinkParts() - Method in class cascading.scheme.Scheme
Method getNumSinkParts returns the numSinkParts of this Scheme object.
getNumSinkParts() - Method in class cascading.tap.partition.BasePartitionTap.PartitionScheme
 
getNumSteps() - Method in class cascading.flow.planner.rule.RuleResult
 
getObject(int) - Method in class cascading.tuple.Tuple
Method get returns the element at the given position.
getObject(int) - Method in class cascading.tuple.TupleEntry
Method getObject returns the value in the given position pos.
getObject(int, Type) - Method in class cascading.tuple.TupleEntry
Method getObject returns the value in the given field or position as the requested type.
getObject(Comparable) - Method in class cascading.tuple.TupleEntry
Method getObject returns the value in the given field or position.
getObject(Comparable, Type) - Method in class cascading.tuple.TupleEntry
Method getObject returns the value in the given field or position as the requested type.
getOpenWritesThreshold() - Method in class cascading.tap.partition.BasePartitionTap
Method getOpenWritesThreshold returns the openTapsThreshold of this PartitionTap object.
getOperation() - Method in class cascading.pipe.Operator
Method getOperation returns the operation managed by this Operator object.
getOperationDeclaredFields() - Method in class cascading.flow.planner.Scope
Method getDeclaredFields returns the declaredFields of this Scope object.
getOperationDeclaredFields() - Method in class cascading.flow.stream.element.OperatorStage
 
getOperator() - Method in class cascading.flow.stream.element.EachStage
 
getOperator() - Method in class cascading.flow.stream.element.EveryStage
 
getOperator() - Method in class cascading.flow.stream.element.OperatorStage
 
getOrderComparator() - Method in class cascading.flow.planner.rule.RuleSetExec
 
getOrderedTopologicalIterator(Comparator<Process>) - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getOrderedTopologicalIterator() - Method in class cascading.flow.planner.process.FlowNodeGraph
 
getOrderedTopologicalIterator(Comparator<Process>) - Method in interface cascading.flow.planner.process.ProcessGraph
 
getOrdinal() - Method in interface cascading.flow.FlowStep
 
getOrdinal() - Method in class cascading.flow.planner.BaseFlowNode
 
getOrdinal() - Method in class cascading.flow.planner.BaseFlowStep
 
getOrdinal() - Method in interface cascading.flow.planner.process.ProcessModel
 
getOrdinal() - Method in class cascading.flow.planner.Scope
 
getOrdinal() - Method in class cascading.flow.stream.duct.DuctGraph.Ordinal
 
getOrdinal() - Method in class cascading.stats.FlowNodeStats
 
getOrdinalMap(Duct) - Method in class cascading.flow.stream.graph.StreamGraph
 
getOrdinals() - Method in class cascading.flow.planner.rule.util.ResultTree.Path
 
getOrdinalTopologicalIterator() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getOrdinalTopologicalIterator() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getOriginal() - Method in class cascading.tap.DecoratorTap
 
getOutgoingEntry() - Method in class cascading.scheme.ConcreteCall
 
getOutgoingEntry() - Method in interface cascading.scheme.SinkCall
Method getOutgoingEntry returns the final TupleEntry to be passed to the SinkCall.getOutput() output handler.
getOutgoingFields() - Method in class cascading.flow.stream.element.ElementStage
 
getOutgoingScopes() - Method in class cascading.flow.stream.element.BoundaryStage
 
getOutgoingScopes() - Method in interface cascading.flow.stream.element.ElementDuct
 
getOutgoingScopes() - Method in class cascading.flow.stream.element.ElementStage
 
getOutgoingScopes() - Method in class cascading.flow.stream.element.SpliceGate
 
getOutgoingSelector() - Method in class cascading.flow.stream.element.AggregatorEveryStage
 
getOutgoingSelector() - Method in class cascading.flow.stream.element.BufferEveryWindow
 
getOutgoingSelector() - Method in class cascading.flow.stream.element.EachStage
 
getOutgoingSelector() - Method in class cascading.flow.stream.element.GroupAssertionEveryStage
 
getOutgoingSelector() - Method in class cascading.flow.stream.element.OperatorStage
 
getOutGroupingFields() - Method in class cascading.flow.planner.Scope
Method getOutGroupingFields returns the outGroupingFields of this Scope object.
getOutGroupingSelector() - Method in class cascading.flow.planner.Scope
Method getOutGroupingSelector returns the outGroupingSelector of this Scope object.
getOutGroupingValueFields() - Method in class cascading.flow.planner.Scope
 
getOutput() - Method in class cascading.flow.stream.element.SinkStage
 
getOutput() - Method in class cascading.operation.Debug
 
getOutput() - Method in class cascading.scheme.ConcreteCall
 
getOutput() - Method in interface cascading.scheme.SinkCall
 
getOutput() - Method in class cascading.tuple.TupleEntrySchemeCollector
 
getOutputCollector() - Method in interface cascading.operation.AggregatorCall
Returns the TupleEntryCollector used to emit result values.
getOutputCollector() - Method in interface cascading.operation.BufferCall
Returns the TupleEntryCollector used to emit result values.
getOutputCollector() - Method in class cascading.operation.ConcreteCall
 
getOutputCollector() - Method in interface cascading.operation.FunctionCall
Returns the TupleEntryCollector used to emit result values.
getOutputPath() - Method in class cascading.CascadingTestCase
 
getOutputPathElements() - Method in class cascading.CascadingTestCase
 
getOutputSelector() - Method in class cascading.pipe.Operator
Method getOutputSelector returns the outputSelector of this Operator object.
getOutputSelector() - Method in exception cascading.pipe.OperatorException
Method getOutputSelector returns the outputSelector of this OperatorException object.
getOutValuesFields() - Method in class cascading.flow.planner.Scope
Method getOutValuesFields returns the outValuesFields of this Scope object.
getOutValuesSelector() - Method in class cascading.flow.planner.Scope
Method getOutValuesSelector returns the outValuesSelector of this Scope object.
getPairs() - Method in class cascading.flow.planner.iso.subgraph.iterator.IncludeRemainderSubGraphIterator
 
getPairs() - Method in class cascading.flow.planner.iso.subgraph.iterator.UniquePathSubGraphIterator
 
getParameterNames() - Method in class cascading.operation.expression.ScriptOperation
 
getParameterTypes() - Method in class cascading.operation.expression.ScriptOperation
 
getParent() - Method in class cascading.pipe.Pipe
Returns the enclosing parent Pipe instance, if any.
getParent() - Method in class cascading.tap.partition.BasePartitionTap
Method getParent returns the parent Tap of this PartitionTap object.
getPartition() - Method in class cascading.tap.partition.BasePartitionTap
Method getPartition returns the Partition instance used by this PartitionTap
getPartitionFields() - Method in class cascading.tap.partition.DelimitedPartition
 
getPartitionFields() - Method in interface cascading.tap.partition.Partition
The Fields used to populate the partition.
getPartitionSource() - Method in class cascading.flow.planner.rule.RulePartitioner
 
getPathDepth() - Method in class cascading.tap.partition.DelimitedPartition
 
getPathDepth() - Method in interface cascading.tap.partition.Partition
Returns the directory search depth of the partition.
getPathFor(ElementGraph, ElementGraph) - Method in class cascading.flow.planner.rule.RuleResult
 
getPathFor(ElementGraph) - Method in class cascading.flow.planner.rule.RuleResult
 
getPattern() - Method in class cascading.operation.regex.RegexOperation
Method getPattern returns the pattern of this RegexOperation object.
getPattern() - Method in class cascading.tap.partition.DelimitedPartition
 
getPatternString() - Method in class cascading.operation.assertion.AssertGroupBase
 
getPatternString() - Method in class cascading.operation.regex.RegexOperation
Method getPatternString returns the patternString of this RegexOperation object.
getPayload() - Method in exception cascading.tap.TapException
 
getPendingTime() - Method in class cascading.stats.CascadingStats
Method getPendingTime returns the pendingTime of this CascadingStats object.
getPermittedExceptions() - Method in class cascading.tuple.TupleEntrySchemeIteratorProps
 
getPipelineGraphFor(FlowElement) - Method in interface cascading.flow.FlowNode
 
getPipelineGraphFor(FlowElement) - Method in class cascading.flow.planner.BaseFlowNode
 
getPipelineGraphs() - Method in interface cascading.flow.FlowNode
 
getPipelineGraphs() - Method in class cascading.flow.planner.BaseFlowNode
 
getPipePos() - Method in class cascading.pipe.Splice
 
getPlanComparator() - Method in class cascading.flow.planner.rule.RuleRegistrySet
Returns planner comparator.
getPlanComparator() - Method in class cascading.flow.planner.rule.RuleSetExec
 
getPlannerContext() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getPlannerException() - Method in class cascading.flow.planner.rule.RuleResult
 
getPlannerInfo() - Method in class cascading.flow.BaseFlow
 
getPlannerInfo() - Method in interface cascading.flow.Flow
Returns any meta-data about the planner that created this Flow instance.
getPlannerInfo(String) - Method in class cascading.flow.planner.FlowPlanner
 
getPlannerLevel() - Method in class cascading.pipe.Operator
Method getPlannerLevel returns the plannerLevel of this Operator object.
getPlannerLevelFor(Class<? extends PlannerLevel>) - Method in class cascading.flow.planner.PlannerContext
 
getPlannerTimeoutSec() - Method in class cascading.flow.planner.rule.RuleRegistrySet
Gets planner timeout, in seconds.
getPlanPath() - Method in class cascading.CascadingTestCase
 
getPlanPathElements() - Method in class cascading.CascadingTestCase
 
getPlanStatsPath() - Method in class cascading.flow.planner.rule.util.TraceWriter
 
getPlanTracePath() - Method in class cascading.flow.planner.rule.util.TraceWriter
 
getPlanTransformTracePath() - Method in class cascading.flow.planner.rule.util.TraceWriter
 
getPlatformInfo() - Method in class cascading.flow.BaseFlow
 
getPlatformInfo() - Method in interface cascading.flow.Flow
Returns any meta-data about the underlying platform this Flow instance will run against.
getPlatformInfo() - Method in class cascading.flow.FlowConnector
Method getPlatformInfo returns an instance of PlatformInfo for the underlying platform.
getPlatformInfo() - Method in class cascading.flow.planner.FlowPlanner
 
getPos() - Method in class cascading.tuple.Fields
Method getPos returns the pos array of this Fields object.
getPos(Fields) - Method in class cascading.tuple.Fields
 
getPos(Comparable) - Method in class cascading.tuple.Fields
Method getPos returns the index of the give field value in this Fields instance.
getPos(Fields, Fields) - Method in class cascading.tuple.Tuple
 
getPredecessorFlows(Flow) - Method in class cascading.cascade.BaseCascade
 
getPredecessorFlows(Flow) - Method in interface cascading.cascade.Cascade
Method getPredecessorFlows returns a Collection of all the Flow instances that will be executed before the given Flow instance.
getPrefix() - Method in class cascading.operation.Debug
 
getPrevious() - Method in class cascading.pipe.Pipe
Get all the upstream pipes this pipe is connected to.
getPrevious() - Method in class cascading.pipe.Splice
 
getPrevious() - Method in class cascading.pipe.SubAssembly
 
getPreviousScopes(FlowElement) - Method in interface cascading.flow.FlowNode
 
getPreviousScopes(FlowElement) - Method in class cascading.flow.planner.BaseFlowNode
 
getPreviousScopes(FlowElement) - Method in class cascading.flow.planner.BaseFlowStep
Method getPreviousScopes returns the previous Scope instances.
getPrintFieldsEvery() - Method in class cascading.operation.Debug
Method getPrintFieldsEvery returns the printFieldsEvery interval value of this Debug object.
getPrintTupleEvery() - Method in class cascading.operation.Debug
Method getPrintTupleEvery returns the printTupleEvery interval value of this Debug object.
getPriorName() - Method in class cascading.flow.planner.Scope
 
getProcess() - Method in class cascading.flow.process.ProcessFlow
Method getProcess returns the process of this ProcessFlow object.
getProcessAnnotations() - Method in class cascading.flow.planner.BaseFlowNode
 
getProcessAnnotations() - Method in class cascading.flow.planner.BaseFlowStep
 
getProcessAnnotations() - Method in interface cascading.flow.planner.process.ProcessModel
Method getProcessAnnotations returns an immutable Map of platform specific annotations or meta-data that describe the current model type.
getProcessAttemptID() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getProcessDuration() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getProcessFinishTime() - Method in class cascading.stats.FlowSliceStats
 
getProcessLevels() - Method in class cascading.flow.planner.rule.RuleRegistry
 
getProcessLogger() - Method in class cascading.stats.CascadeStats
 
getProcessLogger() - Method in class cascading.stats.CascadingStats
 
getProcessLogger() - Method in class cascading.stats.FlowNodeStats
 
getProcessLogger() - Method in class cascading.stats.FlowStats
 
getProcessLogger() - Method in class cascading.stats.FlowStepStats
 
getProcessPendingTime() - Method in class cascading.stats.FlowSliceStats
 
getProcessProgress() - Method in class cascading.stats.FlowSliceStats
 
getProcessRunTime() - Method in class cascading.stats.FlowSliceStats
 
getProcessSliceID() - Method in class cascading.stats.FlowSliceStats
 
getProcessStartTime() - Method in class cascading.stats.FlowSliceStats
 
getProcessStatus() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getProcessStatus() - Method in class cascading.stats.FlowSliceStats
 
getProcessStatusURL() - Method in class cascading.stats.FlowStepStats
 
getProcessStepID() - Method in class cascading.stats.FlowSliceStats
 
getProcessStepID() - Method in class cascading.stats.FlowStepStats
Method getProcessStepID returns the ID representing the under platform process.
getProcessStepID() - Method in class cascading.stats.process.ProcessStepStats
 
getProcessSubmitTime() - Method in class cascading.stats.FlowSliceStats
 
getProperties() - Method in class cascading.flow.FlowConnector
Method getProperties returns the properties of this FlowConnector object.
getProperty(String) - Method in interface cascading.flow.Flow
Returns the String property associated with the given key from the current Configuration instance.
getProperty(String) - Method in class cascading.flow.FlowProcess
Method getProperty should be used to return configuration parameters from the underlying system.
getProperty(String) - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getProperty(String) - Method in class cascading.flow.FlowProcessWrapper
 
getProperty(String) - Method in class cascading.flow.process.ProcessFlow
 
getProperty(String) - Method in class cascading.flow.stream.element.ElementFlowProcess
 
getProperty(String) - Method in class cascading.flow.stream.graph.NodeStreamGraph
 
getProperty(String) - Method in class cascading.flow.stream.graph.StreamGraph
 
getProperty(Map<Object, Object>, String) - Static method in class cascading.property.PropertyUtil
 
getProperty(Map<Object, Object>, String, A) - Static method in class cascading.property.PropertyUtil
 
getProperty(Map<Object, Object>, FlowElement, String) - Static method in class cascading.property.PropertyUtil
 
getProperty(Map<Object, Object>, ConfigDef, String) - Static method in class cascading.property.PropertyUtil
 
getPropertyKeys() - Method in class cascading.flow.FlowProcess
Method getPropertyKeys returns an immutable collection of all available property key values.
getPropertyKeys() - Method in class cascading.flow.FlowProcess.NullFlowProcess
 
getPropertyKeys() - Method in class cascading.flow.FlowProcessWrapper
 
getPropertyKeys() - Method in class cascading.flow.stream.element.ElementFlowProcess
 
getQuote() - Method in class cascading.scheme.util.DelimitedParser
 
getRecursions() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getRegistry() - Method in class cascading.flow.planner.rule.RuleResult
 
getRelease() - Static method in class cascading.util.Version
 
getReleaseBuild() - Static method in class cascading.util.Version
 
getReleaseFull() - Static method in class cascading.util.Version
 
getReleaseMajor() - Static method in class cascading.util.Version
 
getReleaseMinor() - Static method in class cascading.util.Version
 
getRemainderPassThroughFields() - Method in class cascading.flow.planner.Scope
Method getRemainderFields returns the remainderFields of this Scope object.
getReplacement() - Method in class cascading.operation.regex.RegexReplace
 
getResult(AggregatorCall<Pair<Long[], Tuple>>) - Method in class cascading.operation.aggregator.Count
 
getResult(AggregatorCall<Tuple[]>) - Method in class cascading.operation.aggregator.ExtentBase
 
getResult(AggregatorCall<ExtremaValueBase.Context>) - Method in class cascading.operation.aggregator.ExtremaValueBase
 
getResult(AggregatorCall<Pair<Double[], Tuple>>) - Method in class cascading.operation.aggregator.Sum
 
getResultFieldSelectors() - Method in class cascading.operation.function.UnGroup
 
getResultStatus() - Method in class cascading.flow.planner.rule.RuleResult
 
getReturnType() - Method in class cascading.operation.expression.ScriptOperation
 
getReversedGraph() - Method in class cascading.flow.stream.graph.StreamGraph
 
getReversedTopologicalOrderIterator() - Method in class cascading.flow.stream.graph.StreamGraph
 
getReverseTopologicalIterator(ElementGraph) - Static method in class cascading.flow.planner.graph.ElementGraphs
 
getRhs() - Method in class cascading.tuple.io.TuplePair
Method getRhs returns the rhs of this TuplePair object.
getRhs() - Method in class cascading.util.Pair
 
getRuleName() - Method in class cascading.flow.planner.iso.assertion.Asserted
 
getRuleName() - Method in class cascading.flow.planner.iso.GraphResult
 
getRuleName() - Method in class cascading.flow.planner.iso.subgraph.Partitions
 
getRuleName() - Method in class cascading.flow.planner.iso.transformer.Transformed
 
getRuleName() - Method in interface cascading.flow.planner.rule.Rule
 
getRuleName() - Method in class cascading.flow.planner.rule.RuleAssert
 
getRuleName() - Method in class cascading.flow.planner.rule.RulePartitioner
 
getRuleName() - Method in class cascading.flow.planner.rule.RuleTransformer
 
getRulePhase() - Method in interface cascading.flow.planner.rule.Rule
 
getRulePhase() - Method in class cascading.flow.planner.rule.RuleAssert
 
getRulePhase() - Method in class cascading.flow.planner.rule.RulePartitioner
 
getRulePhase() - Method in class cascading.flow.planner.rule.RuleTransformer
 
getRuleRegistry() - Method in class cascading.flow.planner.PlannerContext
 
getRuleRegistrySet() - Method in class cascading.flow.FlowConnector
Returns the configured RuleRegistry, or the default for this platform.
getRulesFor(PlanPhase) - Method in class cascading.flow.planner.rule.RuleRegistry
 
getRunID() - Method in class cascading.flow.BaseFlow
 
getRunID() - Method in interface cascading.flow.Flow
Returns the run ID given when this Flow instance was defined in the FlowDef.
getRunID() - Method in class cascading.flow.FlowDef
 
getRunTime() - Method in class cascading.stats.CascadingStats
Method getRunTime returns the runTime of this CascadingStats object.
getScheme() - Method in class cascading.tap.DecoratorTap
 
getScheme() - Method in class cascading.tap.MultiSinkTap
 
getScheme() - Method in class cascading.tap.MultiSourceTap
 
getScheme() - Method in class cascading.tap.Tap
Method getScheme returns the scheme of this Tap object.
getScript() - Method in class cascading.operation.expression.ScriptFilter
 
getScript() - Method in class cascading.operation.expression.ScriptFunction
 
getScript() - Method in class cascading.operation.expression.ScriptTupleFunction
 
getSearchOrder() - Method in class cascading.flow.planner.iso.expression.ExpressionGraph
 
getSecondValue() - Method in class cascading.operation.function.SetValue
 
getSeed() - Method in class cascading.operation.filter.Sample
 
getSelect() - Method in class cascading.flow.planner.rule.RuleRegistrySet
Returns the result selection type.
getSelectorFields() - Method in exception cascading.tuple.FieldsResolverException
Method getSelectorFields returns the selectorFields of this FieldsResolverException object.
getShort(int) - Method in class cascading.tuple.Tuple
Method getShort returns the element at the given position as an short.
getShort(Comparable) - Method in class cascading.tuple.TupleEntry
Method getShort returns the element for the given field name or position as a short.
getSimpleTypeName(Type) - Static method in class cascading.util.Util
 
getSink(String) - Method in class cascading.flow.BaseFlow
 
getSink() - Method in class cascading.flow.BaseFlow
 
getSink(String) - Method in interface cascading.flow.Flow
 
getSink() - Method in interface cascading.flow.Flow
Method getSink returns the first sink of this Flow object.
getSink() - Method in interface cascading.flow.FlowStep
 
getSink() - Method in class cascading.flow.planner.BaseFlowStep
 
getSink() - Method in class cascading.flow.stream.element.SinkStage
 
getSinkAnnotations() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSinkAsList(Flow) - Static method in class cascading.CascadingTestCase
 
getSinkElementNames() - Method in interface cascading.flow.FlowNode
 
getSinkElementNames() - Method in class cascading.flow.planner.BaseFlowNode
 
getSinkElements(Enum) - Method in interface cascading.flow.FlowNode
 
getSinkElements() - Method in class cascading.flow.planner.BaseFlowNode
 
getSinkElements(Enum) - Method in class cascading.flow.planner.BaseFlowNode
 
getSinkElements() - Method in class cascading.flow.planner.BaseFlowStep
 
getSinkElements() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getSinkElements() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getSinkElements() - Method in interface cascading.flow.planner.process.ProcessModel
 
getSinkExpectedOrdinals() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSinkFields() - Method in class cascading.scheme.Scheme
Method getSinkFields returns the sinkFields of this Scheme object.
getSinkFields() - Method in class cascading.tap.DecoratorTap
 
getSinkFields() - Method in class cascading.tap.partition.BasePartitionTap.PartitionScheme
 
getSinkFields() - Method in class cascading.tap.SourceTap
 
getSinkFields() - Method in class cascading.tap.Tap
Method getSinkFields returns the sinkFields of this Tap object.
getSinkMap() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
getSinkMode() - Method in class cascading.tap.DecoratorTap
 
getSinkMode() - Method in class cascading.tap.Tap
Method getSinkMode returns the SinkMode }of this Tap object.
getSinkModified() - Method in class cascading.flow.BaseFlow
 
getSinkModified() - Method in interface cascading.flow.Flow
Method getSinkModified returns the youngest modified date of any sink Tap managed by this Flow instance.
getSinkModified(Object, Collection<Tap>) - Static method in class cascading.util.Util
 
getSinkName(Tap) - Method in interface cascading.flow.FlowStep
 
getSinkName(Tap) - Method in class cascading.flow.planner.BaseFlowStep
 
getSinkNames() - Method in class cascading.flow.BaseFlow
 
getSinkNames() - Method in interface cascading.flow.Flow
 
getSinkProcessID() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSinks() - Method in class cascading.flow.BaseFlow
 
getSinks() - Method in interface cascading.flow.Flow
Method getSinks returns the sinks of this Flow object.
getSinks() - Method in class cascading.flow.FlowDef
Method getSinks returns the sinks of this FlowDef object.
getSinks() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
getSinksCollection() - Method in class cascading.flow.BaseFlow
 
getSinksCollection() - Method in interface cascading.flow.Flow
Method getSinksCollection returns a Collection of sink Taps for this Flow object.
getSinksCopy() - Method in class cascading.flow.FlowDef
Method getSinksCopy returns a copy of the sink Map.
getSinkTapNames(Tap) - Method in interface cascading.flow.FlowNode
 
getSinkTapNames(Tap) - Method in class cascading.flow.planner.BaseFlowNode
 
getSinkTaps() - Method in class cascading.cascade.BaseCascade
 
getSinkTaps() - Method in interface cascading.cascade.Cascade
Method getSinkTaps returns all sink Tap instances in this Cascade instance.
getSinkTaps() - Method in class cascading.flow.planner.BaseFlowNode
 
getSinkTaps() - Method in class cascading.flow.planner.BaseFlowStep
 
getSinkTaps() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getSinkTaps() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getSinkTaps() - Method in interface cascading.flow.planner.process.ProcessModel
 
getSinkWith(String) - Method in interface cascading.flow.FlowStep
 
getSinkWith(String) - Method in class cascading.flow.planner.BaseFlowStep
 
getSize() - Method in class cascading.operation.assertion.AssertGroupBase
 
getSize() - Method in class cascading.operation.assertion.AssertGroupSizeEquals
 
getSize() - Method in class cascading.operation.assertion.AssertGroupSizeLessThan
 
getSize() - Method in class cascading.operation.assertion.AssertGroupSizeMoreThan
 
getSize() - Method in class cascading.operation.assertion.AssertSizeEquals
 
getSize() - Method in class cascading.operation.assertion.AssertSizeLessThan
 
getSize() - Method in class cascading.operation.assertion.AssertSizeMoreThan
 
getSize() - Method in class cascading.operation.function.UnGroup
 
getSize(FlowProcess<? extends Config>) - Method in interface cascading.tap.type.FileType
Method getSize returns the size of the file referenced by this tap.
getSize(Config) - Method in interface cascading.tap.type.FileType
Method getSize returns the size of the file referenced by this tap.
getSortingSelector() - Method in exception cascading.pipe.OperatorException
Method getSortingSelector returns the sortingSelector of this OperatorException object.
getSortingSelectors() - Method in class cascading.flow.planner.Scope
Method getSortingSelectors returns the sortingSelectors of this Scope object.
getSortingSelectors() - Method in interface cascading.pipe.Group
 
getSortingSelectors() - Method in class cascading.pipe.Splice
Method getSortingSelectors returns the sortingSelectors of this Splice object.
getSource(String) - Method in class cascading.flow.BaseFlow
 
getSource(String) - Method in interface cascading.flow.Flow
 
getSource() - Method in class cascading.flow.stream.element.SourceStage
 
getSourceAnnotations() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSourceAsList(Flow) - Static method in class cascading.CascadingTestCase
 
getSourceElementNames() - Method in interface cascading.flow.FlowNode
 
getSourceElementNames() - Method in class cascading.flow.planner.BaseFlowNode
 
getSourceElements(Enum) - Method in interface cascading.flow.FlowNode
 
getSourceElements() - Method in class cascading.flow.planner.BaseFlowNode
 
getSourceElements(Enum) - Method in class cascading.flow.planner.BaseFlowNode
 
getSourceElements() - Method in class cascading.flow.planner.BaseFlowStep
 
getSourceElements() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getSourceElements() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getSourceElements() - Method in interface cascading.flow.planner.process.ProcessModel
 
getSourceFields() - Method in class cascading.scheme.Scheme
Method getSourceFields returns the sourceFields of this Scheme object.
getSourceFields() - Method in class cascading.tap.DecoratorTap
 
getSourceFields() - Method in class cascading.tap.partition.BasePartitionTap.PartitionScheme
 
getSourceFields() - Method in class cascading.tap.SinkTap
 
getSourceFields() - Method in class cascading.tap.Tap
Method getSourceFields returns the sourceFields of this Tap object.
getSourceFields() - Method in exception cascading.tuple.FieldsResolverException
Method getSourceFields returns the sourceFields of this FieldsResolverException object.
getSourceMap() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
getSourceModified(Object, Iterator<Tap>, long) - Static method in class cascading.util.Util
 
getSourceName(Tap) - Method in interface cascading.flow.FlowStep
 
getSourceName(Tap) - Method in class cascading.flow.planner.BaseFlowStep
 
getSourceNames() - Method in class cascading.flow.BaseFlow
 
getSourceNames() - Method in interface cascading.flow.Flow
 
getSourceProcessID() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSourceProvidedOrdinals() - Method in class cascading.flow.planner.process.ProcessEdge
 
getSources() - Method in class cascading.flow.BaseFlow
 
getSources() - Method in interface cascading.flow.Flow
Method getSources returns the sources of this Flow object.
getSources() - Method in class cascading.flow.FlowDef
Method getSources returns the sources of this FlowDef object.
getSources() - Method in class cascading.flow.planner.graph.FlowElementGraph
 
getSourcesCollection() - Method in class cascading.flow.BaseFlow
 
getSourcesCollection() - Method in interface cascading.flow.Flow
Method getSourcesCollection returns a Collection of source Taps for this Flow object.
getSourcesCopy() - Method in class cascading.flow.FlowDef
Method getSourcesCopy returns a copy of the sources Map.
getSourceTapNames(Tap) - Method in interface cascading.flow.FlowNode
 
getSourceTapNames(Tap) - Method in class cascading.flow.planner.BaseFlowNode
 
getSourceTaps() - Method in class cascading.cascade.BaseCascade
 
getSourceTaps() - Method in interface cascading.cascade.Cascade
Method getSourceTaps returns all source Tap instances in this Cascade instance.
getSourceTaps() - Method in class cascading.flow.planner.BaseFlowNode
 
getSourceTaps() - Method in class cascading.flow.planner.BaseFlowStep
 
getSourceTaps() - Method in class cascading.flow.planner.process.BaseProcessGraph
 
getSourceTaps() - Method in interface cascading.flow.planner.process.ProcessGraph
 
getSourceTaps() - Method in interface cascading.flow.planner.process.ProcessModel
 
getSourceWith(String) - Method in interface cascading.flow.FlowStep
 
getSourceWith(String) - Method in class cascading.flow.planner.BaseFlowStep
 
getSpanElements(ProcessGraph<? extends ProcessModel>) - Method in class cascading.util.DOTProcessGraphWriter
 
getSpawnStrategy() - Method in class cascading.cascade.BaseCascade
 
getSpawnStrategy() - Method in class cascading.flow.BaseFlow
 
getSpawnStrategy() - Method in interface cascading.management.UnitOfWork
 
getSpillListener() - Method in class cascading.tuple.collect.SpillableTupleMap
 
getSpillReason(Spillable) - Method in interface cascading.tuple.collect.Spillable.SpillStrategy
 
getSplice() - Method in class cascading.flow.stream.element.SpliceGate
 
getStackTraceLineDelimiter() - Method in class cascading.tap.TrapProps
 
getStartTime() - Method in class cascading.stats.CascadingStats
Method getStartTime returns the startTime of this CascadingStats object.
getStats() - Method in class cascading.cascade.BaseCascade
 
getStats() - Method in class cascading.flow.BaseFlow
 
getStats() - Method in interface cascading.management.UnitOfWork
 
getStatsString() - Method in class cascading.stats.CascadingStats
 
getStatsString() - Method in class cascading.stats.FlowStats
 
getStatus() - Method in class cascading.operation.state.Status
 
getStatus() - Method in class cascading.stats.CascadingStats
Method getStatus returns the CascadingStats.Status of this CascadingStats object.
getStatus() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getStatus() - Method in class cascading.stats.FlowSliceStats
 
getStatusURL() - Method in class cascading.stats.FlowSliceStats.FlowSliceAttempt
 
getStepConfigDef() - Method in interface cascading.flow.FlowElement
 
getStepConfigDef() - Method in enum cascading.flow.planner.graph.Extent
 
getStepConfigDef() - Method in class cascading.pipe.Pipe
Returns a ConfigDef instance that allows for process level properties to be set and made available via a resulting FlowProcess instance when the pipe is invoked.
getStepConfigDef() - Method in class cascading.tap.DecoratorTap
 
getStepConfigDef() - Method in class cascading.tap.Tap
Returns a ConfigDef instance that allows for process level properties to be set and made available via a resulting FlowProcess instance when the tap is invoked.
getStepDisplayName() - Method in interface cascading.flow.FlowStep
Method getStepDisplayName returns the stepDisplayName of this FlowStep object.
getStepDisplayName() - Method in class cascading.flow.planner.BaseFlowStep
 
getStepDisplayName(int) - Method in class cascading.flow.planner.BaseFlowStep
 
getStepGraphFrom(Flow) - Static method in class cascading.flow.Flows
 
getStepsCount() - Method in class cascading.stats.FlowStats
Method getStepsCount returns the number of steps this Flow executed.
getStepsCount() - Method in class cascading.stats.process.ProcessFlowStats
 
getStepStats() - Method in class cascading.flow.planner.FlowStepJob
Method getStepStats returns the stepStats of this FlowStepJob object.
getStepToNodeGraphMap() - Method in class cascading.flow.planner.rule.RuleResult
 
getString(String[]) - Method in class cascading.management.CascadingServices.NullMetricsService
 
getString(String[]) - Method in interface cascading.management.MetricsService
 
getString(int) - Method in class cascading.tuple.Tuple
Method getString returns the element at the given position as a String.
getString(Comparable) - Method in class cascading.tuple.TupleEntry
Method getString returns the element for the given field name or position as a String.
getStringProperty(String) - Method in class cascading.flow.FlowProcess
Method getStringProperty should be used to return configuration parameters from the underlying system.
getStringProperty(String, String) - Method in class cascading.flow.FlowProcess
Method getStringProperty should be used to return configuration parameters from the underlying system.
getStringProperty(String) - Method in class cascading.flow.planner.PlannerContext
 
getStringProperty(Map<Object, Object>, String) - Static method in class cascading.property.PropertyUtil
 
getStringProperty(Properties, Map<Object, Object>, String) - Static method in class cascading.property.PropertyUtil
 
getSubGraphs() - Method in class cascading.flow.planner.iso.subgraph.Partitions
 
getSubmitPriority() - Method in class cascading.flow.BaseFlow
 
getSubmitPriority() - Method in interface cascading.flow.Flow
Method getSubmitPriority returns the submitPriority of this Flow object.
getSubmitPriority() - Method in interface cascading.flow.FlowStep
Method getSubmitPriority returns the submitPriority of this FlowStep object.
getSubmitPriority() - Method in class cascading.flow.planner.BaseFlowNode
 
getSubmitPriority() - Method in class cascading.flow.planner.BaseFlowStep
 
getSubmitPriority() - Method in interface cascading.flow.planner.process.ProcessModel
 
getSubmitTime() - Method in class cascading.stats.CascadingStats
Method getSubmitTime returns the submitTime of this CascadingStats object.
getSuccessorFlows(Flow) - Method in class cascading.cascade.BaseCascade
 
getSuccessorFlows(Flow) - Method in interface cascading.cascade.Cascade
Method getSuccessorFlows returns a Collection of all the Flow instances that will be executed after the given Flow instance.
getTags() - Method in class cascading.cascade.BaseCascade
Method getTags returns the tags associated with this Cascade object.
getTags() - Method in class cascading.flow.BaseFlow
 
getTags() - Method in interface cascading.flow.Flow
 
getTags() - Method in interface cascading.management.UnitOfWork
 
getTags() - Method in class cascading.property.AppProps
 
getTags() - Method in class cascading.property.UnitOfWorkDef
 
getTailFlows() - Method in class cascading.cascade.BaseCascade
 
getTailFlows() - Method in interface cascading.cascade.Cascade
Method getTailFlows returns all Flow instances that are at the "tail" of the flow graph.
getTailNames() - Method in class cascading.pipe.SubAssembly
Method getTailNames retu