- 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
-
- 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
Operator
s 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- FactoryLoader - Class in cascading.provider
-
- 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
-
- frequency(TupleEntry, Object) - Static method in class cascading.tuple.Tuples
-
- 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
-
- 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
-
- getArgumentFields() - Method in class cascading.pipe.assembly.AggregateBy
-
- getArguments() - Method in interface cascading.operation.AggregatorCall
-
- getArguments() - Method in class cascading.operation.ConcreteCall
-
- getArguments() - Method in interface cascading.operation.FilterCall
-
- getArguments() - Method in interface cascading.operation.FunctionCall
-
- getArguments() - Method in interface cascading.operation.GroupAssertionCall
-
- getArguments() - Method in interface cascading.operation.ValueAssertionCall
-
- 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
-
- 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
Tap
s 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
-
- getDeclaredFields() - Method in interface cascading.operation.BufferCall
-
- getDeclaredFields() - Method in class cascading.operation.ConcreteCall
-
- getDeclaredFields() - Method in interface cascading.operation.FunctionCall
-
- 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
Flow
s 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
-
- 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
-
- getGroup() - Method in interface cascading.operation.BufferCall
-
- getGroup() - Method in class cascading.operation.ConcreteCall
-
- getGroup() - Method in interface cascading.operation.GroupAssertionCall
-
- getGroupAssertion() - Method in class cascading.pipe.Every
-
- getGroupBy() - Method in class cascading.pipe.assembly.AggregateBy
-
- 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
-
- 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
-
- 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
-
- 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
-
- getOutputCollector() - Method in interface cascading.operation.BufferCall
-
- getOutputCollector() - Method in class cascading.operation.ConcreteCall
-
- getOutputCollector() - Method in interface cascading.operation.FunctionCall
-
- 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
Tap
s 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
Tap
s 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
-
- 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