java.lang.String outputPath
java.lang.String planPath
java.lang.String flowName
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.lang.String vendor
java.lang.String version
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
org.jgrapht.Graph<V,E> graph
ElementGraph elementGraph
cascading.flow.planner.graph.ElementMaskSubGraph.VertexMask vertexMask
cascading.flow.planner.graph.ElementMaskSubGraph.EdgeMask edgeMask
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
org.jgrapht.Graph<V,E> graph
org.jgrapht.graph.SimpleDirectedGraph<V,E> graph
java.util.Set<E> sourceElements
java.util.Set<E> sinkElements
java.util.Set<E> sourceTaps
java.util.Set<E> sinkTaps
java.util.Map<K,V> trapsMap
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
java.lang.reflect.Type[] types
Tuple values
java.lang.reflect.Type type
CoercibleType<Canonical> canonical
java.util.Collection<E> ignoreTuples
java.util.Collection<E> ignoreValues
int firstN
java.lang.reflect.Type type
CoercibleType<Canonical> canonical
Tuple values
java.lang.Object value
java.lang.String patternString
long size
Tuple values
int size
int size
int size
java.lang.String message
int firstN
long limit
long seed
double fraction
java.lang.String algorithm
int maxLength
java.lang.String charsetName
SerFunction<T,R> preDigest
SerFunction<T,R> postEncoding
boolean matchEachElement
boolean negateMatch
java.lang.String delimiter
java.lang.String patternString
int[] groups
java.lang.String replacement
boolean replaceAll
int length
java.lang.Enum<E extends java.lang.Enum<E>> counterEnum
java.lang.String groupString
java.lang.String counterString
int increment
java.lang.String status
java.util.TimeZone zone
java.util.Locale locale
java.lang.String dateFormatString
int[] calendarFields
java.lang.String format
java.lang.String delimiter
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
boolean[] asInner
java.util.Map<K,V> config
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
riffle.process.scheduler.ProcessWrapper processWrapper
java.util.Map<K,V> counters
long lastFetch
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
java.lang.String postfix
int numSplits
java.lang.Comparable<T>[] fields
boolean isOrdered
cascading.tuple.Fields.Kind kind
java.lang.reflect.Type[] types
java.util.Comparator<T>[] comparators
java.util.List<E> elements
int mapThreshold
int initListThreshold
Spillable.SpillListener spillListener
int index
Tuple tuple
Tuple[] tuples
java.util.TimeZone zone
java.util.Locale locale
java.lang.String dateFormatString
TupleHasher.HashFunction hashFunction
Hasher<V>[] hashers
java.util.Map<K,V> map
java.util.Comparator<T> comparator
int initialListSize
Trie.Entry<V> entry
char key
java.util.Map<K,V> children
java.lang.String prefix
java.lang.Object value
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.