String flowName
String id
int ordinal
String name
Map<K,V> processAnnotations
ElementGraph nodeSubGraph
List<E> pipelineGraphs
Map<K,V> trapMap
Set<E> sourceTaps
Set<E> sinkTaps
Map<K,V> reverseSourceTaps
Map<K,V> reverseSinkTaps
Map<K,V> streamPipelineMap
String flowName
String flowID
int submitPriority
String name
String id
int ordinal
Map<K,V> processAnnotations
List<E> listeners
ElementGraph elementGraph
FlowNodeGraph flowNodeGraph
Map<K,V> sources
Map<K,V> sinks
Map<K,V> traps
Tap<Config,Input,Output> tempSink
List<E> groups
FlowElement flowElement
ElementGraph elementGraph
String name
LinkedList<E> priorNames
Integer ordinal
boolean isNonBlocking
Scope.Kind kind
Fields incomingPassThroughFields
Fields remainderPassThroughFields
Fields operationArgumentFields
Fields operationDeclaredFields
Map<K,V> keySelectors
Map<K,V> sortingSelectors
Fields outGroupingSelector
Fields outGroupingFields
Fields outValuesSelector
Fields outValuesFields
EnumMultiMap<V> annotations
ElementGraph elementGraph
cascading.flow.planner.graph.ElementMaskSubGraph.FlowElementMaskFunctor mask
ElementGraph elementGraph
Set<E> flowElements
Set<E> scopes
boolean resolved
PlatformInfo platformInfo
Map<K,V> sources
Map<K,V> sinks
Map<K,V> traps
Map<K,V> checkpoints
boolean requireUniqueCheckpoints
String id
String sourceProcessID
String sinkProcessID
FlowElement flowElement
Set<E> sourceProvidedOrdinals
Set<E> sinkExpectedOrdinals
Set<E> sinkAnnotations
Set<E> sourceAnnotations
Map<K,V> edgeAnnotations
Debug.Output output
String prefix
boolean printFields
int printFieldsEvery
int printTupleEvery
Type[] types
Tuple values
Type type
CoercibleType<Canonical> canonical
Collection<E> ignoreTuples
Collection<E> ignoreValues
Type type
CoercibleType<Canonical> canonical
Tuple values
Object value
String patternString
long size
Tuple values
String message
boolean negateMatch
String delimiter
String patternString
String replacement
boolean replaceAll
String status
String format
String delimiter
Operation<Context> operation
Fields argumentSelector
Fields outputSelector
PlannerLevel plannerLevel
cascading.pipe.Splice.Kind kind
String spliceName
List<E> pipes
Map<K,V> keyFieldsMap
Map<K,V> sortFieldsMap
boolean reverseOrder
Fields declaredFields
Fields resultGroupFields
int numSelfJoins
Joiner joiner
String name
int capacity
Fields groupingFields
Fields[] argumentFields
AggregateBy.Functor[] functors
Aggregator<Context>[] aggregators
int capacity
Fields groupingFields
Fields[] argumentFields
Fields[] functorFields
AggregateBy.Functor[] functors
TupleHasher tupleHasher
Fields declaredFields
AverageBy.Include include
Fields declaredFields
CountBy.Include include
Fields declaredFields
Fields declaredFields
Fields declaredFields
Type sumType
CoercibleType<Canonical> canonical
int capacity
Unique.Include include
TupleHasher tupleHasher
Fields fieldDeclaration
Fields sourceFields
Pattern splitPattern
Pattern cleanPattern
Pattern escapePattern
String delimiter
String quote
boolean strict
boolean enforceStrict
int numValues
Type[] types
CoercibleType<Canonical>[] coercibles
boolean safe
FieldTypeResolver fieldTypeResolver
String name
ClientState clientState
CascadingStats.Status status
Set<E> listeners
long pendingTime
long startTime
long submitTime
long runTime
long finishedTime
Throwable throwable
String[] throwableTrace
AtomicLong lastCaptureDetail
FlowNode flowNode
boolean hasCapturedFinalDetail
Tuple payload
Tap<Config,Input,Output> parent
Partition partition
boolean keepParentOnDelete
int openWritesThreshold
long openedCollectors
Map<K,V> collectors
Scheme<Config,Input,Output,SourceContext,SinkContext> scheme
Fields partitionFields
Comparable<T>[] fields
boolean isOrdered
cascading.tuple.Fields.Kind kind
Type[] types
Comparator<T>[] comparators
int mapThreshold
int initListThreshold
Spillable.SpillListener spillListener
int index
Tuple tuple
Tuple[] tuples
TupleHasher.HashFunction hashFunction
Hasher<V>[] hashers
Comparator<T> comparator
int initialListSize
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.