Index (Cascading 3.0.4)

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