java.lang.String id
int ordinal
java.lang.String name
java.util.Map<K,V> processAnnotations
ElementGraph nodeSubGraph
java.util.List<E> pipelineGraphs
java.util.Map<K,V> trapMap
java.util.Set<E> sourceTaps
java.util.Set<E> sinkTaps
java.util.Map<K,V> reverseSourceTaps
java.util.Map<K,V> reverseSinkTaps
java.util.Map<K,V> streamPipelineMap
java.util.Map<K,V> flowNodeDescriptor
java.lang.String flowName
java.lang.String flowID
int submitPriority
java.lang.String name
java.lang.String id
int ordinal
java.util.Map<K,V> processAnnotations
java.util.List<E> listeners
ElementGraph elementGraph
FlowNodeGraph flowNodeGraph
java.util.Map<K,V> sources
java.util.Map<K,V> sinks
java.util.Map<K,V> traps
Tap<Config,Input,Output> tempSink
java.util.List<E> groups
java.util.Map<K,V> flowStepDescriptor
FlowElement flowElement
ElementGraph elementGraph
java.lang.String name
java.util.LinkedList<E> priorNames
java.lang.Integer ordinal
boolean isNonBlocking
Scope.Kind kind
Fields incomingPassThroughFields
Fields remainderPassThroughFields
Fields operationArgumentFields
Fields operationDeclaredFields
java.util.Map<K,V> keySelectors
java.util.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
java.util.Set<E> flowElements
java.util.Set<E> scopes
boolean resolved
PlatformInfo platformInfo
java.util.Map<K,V> sources
java.util.Map<K,V> sinks
java.util.Map<K,V> traps
java.util.Map<K,V> checkpoints
boolean requireUniqueCheckpoints
java.lang.String id
java.lang.String sourceProcessID
java.lang.String sinkProcessID
FlowElement flowElement
java.util.Set<E> sourceProvidedOrdinals
java.util.Set<E> sinkExpectedOrdinals
java.util.Map<K,V> resolvedKeyFields
java.util.Map<K,V> resolvedSortFields
java.util.Map<K,V> resolvedValueFields
java.util.Set<E> sinkAnnotations
java.util.Set<E> sourceAnnotations
java.util.Map<K,V> edgeAnnotations
Transformed<E extends ElementGraph> transformed
Fields fieldDeclaration
int numArgs
java.lang.String trace
Debug.Output output
java.lang.String prefix
boolean printFields
int printFieldsEvery
int printTupleEvery
Tuple values
java.lang.reflect.Type type
CoercibleType<Canonical> canonical
java.lang.reflect.Type type
CoercibleType<Canonical> canonical
Tuple values
Tuple values
Operation<Context> operation
Fields argumentSelector
Fields outputSelector
PlannerLevel plannerLevel
cascading.pipe.Splice.Kind kind
java.lang.String spliceName
java.util.List<E> pipes
java.util.Map<K,V> keyFieldsMap
java.util.Map<K,V> sortFieldsMap
boolean reverseOrder
Fields declaredFields
Fields resultGroupFields
int numSelfJoins
Joiner joiner
java.lang.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
java.lang.Boolean doComparison
Fields declaredFields
Fields declaredFields
Fields declaredFields
java.lang.reflect.Type sumType
CoercibleType<Canonical> canonical
int capacity
Unique.Include include
TupleHasher tupleHasher
Fields fieldDeclaration
Fields sourceFields
java.util.regex.Pattern splitPattern
java.util.regex.Pattern cleanPattern
java.util.regex.Pattern escapePattern
java.lang.String delimiter
java.lang.String quote
boolean strict
boolean enforceStrict
int numValues
java.lang.reflect.Type[] types
CoercibleType<Canonical>[] coercibles
boolean safe
FieldTypeResolver fieldTypeResolver
java.util.Map<K,V> sliceStatsMap
CounterCache<Config,JobStatus,Counters> counterCache
boolean allChildrenFinished
CounterCache<Config,JobStatus,Counters> counterCache
Cascade cascade
java.util.Map<K,V> flowStatsMap
java.lang.String name
ClientState clientState
CascadingStats.Status status
java.util.Set<E> listeners
long pendingTime
long startTime
long submitTime
long runTime
long finishedTime
java.lang.Throwable throwable
java.lang.String[] throwableTrace
java.util.concurrent.atomic.AtomicLong lastCaptureDetail
FlowNode flowNode
boolean hasCapturedFinalDetail
Scheme<Config,Input,Output,SourceContext,SinkContext> scheme
SinkMode sinkMode
ConfigDef configDef
ConfigDef nodeConfigDef
ConfigDef stepConfigDef
java.lang.String id
java.lang.String trace
Tuple payload
Tap<Config,Input,Output> parent
Partition partition
java.util.List<E> sourcePartitionFilters
boolean keepParentOnDelete
int openWritesThreshold
long openedCollectors
java.util.Map<K,V> collectors
Scheme<Config,Input,Output,SourceContext,SinkContext> scheme
Fields partitionFields
Fields partitionFields
java.lang.String delimiter
int mapThreshold
int initListThreshold
Spillable.SpillListener spillListener
int index
Tuple tuple
Tuple[] tuples
TupleHasher.HashFunction hashFunction
Hasher<V>[] hashers
Trie.Entry<V> entry
char key
java.util.Map<K,V> children
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.