Serialized Form
Class cascading.DistanceUseCaseTest extends cascading.ClusterTestCase implements Serializable |
inputFileCritics
String inputFileCritics
outputPathEuclidean
String outputPathEuclidean
outputPathPearson
String outputPathPearson
Class cascading.TestAggregator extends BaseOperation implements Serializable |
serialVersionUID: 1L
value
Tuple[] value
duplicates
int duplicates
groupFields
Fields groupFields
Class cascading.TestBuffer extends BaseOperation implements Serializable |
exepectedSize
int exepectedSize
insertHeader
boolean insertHeader
insertFooter
boolean insertFooter
value
Comparable<T> value
Class cascading.TestFailAggregator extends BaseOperation implements Serializable |
serialVersionUID: 1L
fail
int fail
failon
int failon
value
Tuple value
isSafe
boolean isSafe
groupFields
Fields groupFields
numGroups
Integer numGroups
Class cascading.TestLongComparator extends Object implements Serializable |
reverse
boolean reverse
Class cascading.TestStringComparator extends Object implements Serializable |
reverse
boolean reverse
Class cascading.TestTextLine extends TextLine implements Serializable |
Class cascading.UnmodifiablePipesTest.TestAggregator extends BaseOperation implements Serializable |
Class cascading.UnmodifiablePipesTest.TestBuffer extends BaseOperation implements Serializable |
Class cascading.UnmodifiablePipesTest.TestFilter extends BaseOperation implements Serializable |
Class cascading.UnmodifiablePipesTest.TestFunction extends BaseOperation implements Serializable |
Package cascading.cascade |
resolved
boolean resolved
- Field resolved
sources
Map<K,V> sources
- Field sources
sinks
Map<K,V> sinks
- Field sinks
traps
Map<K,V> traps
- Field traps
plannerLevels
PlannerLevel[] plannerLevels
- Field assertionLevel
flowElement
FlowElement flowElement
- Field flowElement
flowName
String flowName
- Field flowName
Class cascading.flow.FlowProcessTest.IterateInsert extends BaseOperation implements Serializable |
path
String path
properties
Map<K,V> properties
- Field properties
parentFlowName
String parentFlowName
- Field parentFlowName
submitPriority
int submitPriority
- Field submitPriority
name
String name
- Field name
id
int id
- Field id
graph
org.jgrapht.graph.SimpleDirectedGraph<V,E> graph
- Field graph
sources
Map<K,V> sources
- Field sources
sink
Tap sink
- Field sink
mapperTraps
Map<K,V> mapperTraps
- Field mapperTraps
reducerTraps
Map<K,V> reducerTraps
- Field reducerTraps
tempSink
TempHfs tempSink
- Field tempSink
group
Group group
- Field group
jobConf
JobConf jobConf
- Field jobConf
elementGraph
ElementGraph elementGraph
- Field pipeGraph
name
String name
- Field name
kind
Scope.Kind kind
- Field kind
remainderFields
Fields remainderFields
- Field remainderFields
argumentFields
Fields argumentFields
- Field argumentSelector
declaredFields
Fields declaredFields
- Field declaredFields
isGroupBy
boolean isGroupBy
- Field isGroupBy
groupingSelectors
Map<K,V> groupingSelectors
- Field groupingSelectors
sortingSelectors
Map<K,V> sortingSelectors
- Field sortingSelectors
outGroupingSelector
Fields outGroupingSelector
- Field outGroupingSelector
outGroupingFields
Fields outGroupingFields
- Field outGroupingFields
outValuesSelector
Fields outValuesSelector
- Field outValuesSelector
outValuesFields
Fields outValuesFields
- Field outValuesFields
Package cascading.flow.hadoop |
numMapTasks
int numMapTasks
- Field numMapTasks
numReducerTasks
int numReducerTasks
- Field numReducerTasks
taskStats
ArrayList<E> taskStats
- Field taskStats
Package cascading.flow.stack |
Package cascading.operation |
fieldDeclaration
Fields fieldDeclaration
- Field fieldDeclaration
numArgs
int numArgs
- Field numArgs
trace
String trace
- Field trace
output
Debug.Output output
- Field output
prefix
String prefix
- Field prefix
printFields
boolean printFields
- Field printFields
printFieldsEvery
int printFieldsEvery
- Field printFieldsEvery
printTupleEvery
int printTupleEvery
- Field printTupleEvery
types
Class<T>[] types
- Field types
values
Tuple values
- Field values
Package cascading.operation.aggregator |
ignoreTuples
Collection<E> ignoreTuples
- Field ignoreTuples
ignoreValues
Collection<E> ignoreValues
- Field ignoreValues
type
Class<T> type
- Field type
Package cascading.operation.assertion |
values
Tuple values
- Field values
value
Object value
- Field value
patternString
String patternString
- Field patternString
size
long size
- Field size
message
String message
- Field message
message
String message
- Field message
values
Tuple values
- Field values
size
int size
- Field size
size
int size
- Field size
size
int size
- Field size
message
String message
- Field message
Package cascading.operation.expression |
expression
String expression
- Field expression
parameterTypes
Class<T>[] parameterTypes
- Field parameterTypes
parameterNames
String[] parameterNames
- Field parameterNames
Package cascading.operation.filter |
Class cascading.operation.filter.FilterTest.BooleanFilter extends BaseOperation implements Serializable |
result
boolean result
limit
long limit
argumentSelectors
Fields[] argumentSelectors
- Field fields
filters
Filter<C>[] filters
- Field filters
filter
Filter<C> filter
- Field filter
seed
long seed
fraction
double fraction
Package cascading.operation.function |
filter
Filter<C> filter
- Field filter
values
Serializable[] values
- Field values
groupFieldSelector
Fields groupFieldSelector
- Field groupFieldSelector
resultFieldSelectors
Fields[] resultFieldSelectors
- Field resultFieldSelectors
size
int size
- Field size
Package cascading.operation.regex |
matchEachElement
boolean matchEachElement
- Field matchEachElement
negateMatch
boolean negateMatch
- Field removeMatch
patternString
String patternString
- Field patternString
groups
int[] groups
- Field groups
replacement
String replacement
- Field replacement
replaceAll
boolean replaceAll
- Field replaceAll
Package cascading.operation.state |
counterEnum
Enum<E extends Enum<E>> counterEnum
groupString
String groupString
counterString
String counterString
increment
int increment
status
String status
- Field status
Package cascading.operation.text |
zone
TimeZone zone
- Field zone
locale
Locale locale
- Field locale
dateFormatString
String dateFormatString
- Field dateFormatString
calendarFields
int[] calendarFields
- Field calendarFields
format
String format
- Field format
delimiter
String delimiter
- Field delimiter
Package cascading.operation.xml |
features
Map<K,V> features
- Field features
removeMatch
boolean removeMatch
- Field removeMatch
namespaces
String[][] namespaces
- Field namespaces
paths
String[] paths
- Field paths
serialVersionUID: 1L
pipes
List<E> pipes
- Field pipes
groupFieldsMap
Map<K,V> groupFieldsMap
- Field groupFieldsMap
sortFieldsMap
Map<K,V> sortFieldsMap
- Field sortFieldsMap
reverseOrder
boolean reverseOrder
- Field reverseOrder
declaredFields
Fields declaredFields
- Field declaredFields
resultGroupFields
Fields resultGroupFields
- Field resultGroupFields
numSelfJoins
int numSelfJoins
- Field repeat
joiner
Joiner joiner
- Field coGrouper
groupName
String groupName
- Field groupName
isGroupBy
boolean isGroupBy
- Field isGroupBy
closure
GroupClosure closure
- Field closure
operation
Operation<C> operation
- Field operation
argumentSelector
Fields argumentSelector
- Field argumentSelector
outputSelector
Fields outputSelector
- Field outputSelector
plannerLevel
PlannerLevel plannerLevel
- Field assertionLevel
incomingFields
Fields incomingFields
argumentSelector
Fields argumentSelector
groupingSelector
Fields groupingSelector
sortingSelector
Fields sortingSelector
declaredFields
Fields declaredFields
outputSelector
Fields outputSelector
serialVersionUID: 1L
name
String name
- Field name
previous
Pipe previous
- Field previous
trace
String trace
- Field trace
tails
Pipe[] tails
- Field assembly
Package cascading.pipe.assembly |
name
String name
threshold
int threshold
argumentFields
Fields[] argumentFields
functors
AggregateBy.Functor[] functors
aggregators
Aggregator<C>[] aggregators
threshold
int threshold
groupingFields
Fields groupingFields
argumentFields
Fields[] argumentFields
functorFields
Fields[] functorFields
functors
AggregateBy.Functor[] functors
declaredFields
Fields declaredFields
declaredFields
Fields declaredFields
sumType
Class<T> sumType
threshold
int threshold
Package cascading.pipe.cogroup |
asInner
boolean[] asInner
sinkFields
Fields sinkFields
- Field sinkFields
sourceFields
Fields sourceFields
- Field sourceFields
numSinkParts
int numSinkParts
- Field numSinkParts
trace
String trace
- Field trace
serialVersionUID: 1L
splitPattern
Pattern splitPattern
- Field splitPattern
cleanPattern
Pattern cleanPattern
- Field cleanPattern
escapePattern
Pattern escapePattern
- Field escapePattern
skipHeader
boolean skipHeader
- Field skipHeader
delimiter
String delimiter
- Field delimiter *
quote
String quote
- Field quote
strict
boolean strict
- Field strict
numValues
int numValues
- Field numValues
types
Class<T>[] types
- Field types
safe
boolean safe
- Field safe
buffer
Object[] buffer
- Field buffer
decoratorTuple
cascading.scheme.TextDelimited.DecoratorTuple decoratorTuple
- Field decoratorTuple
serialVersionUID: 1L
sinkCompression
TextLine.Compress sinkCompression
- Field sinkCompression
keyType
Class<T> keyType
valueType
Class<T> valueType
cascadeID
String cascadeID
- Field cascadeId
flowStatsList
List<E> flowStatsList
- Field flowStatsList
name
String name
- Field name
status
CascadingStats.Status status
- Field status
startTime
long startTime
- Field startTime
finishedTime
long finishedTime
- Field finishedTime
throwable
Throwable throwable
- Field throwable
flowID
String flowID
stepStatsList
List<E> stepStatsList
pathPattern
String pathPattern
- Field pathPattern
pathFilter
PathFilter pathFilter
- Field pathFilter
serialVersionUID: 1L
stringPath
String stringPath
- Field stringPath
taps
Tap[] taps
- Field taps
tempPath
String tempPath
- Field tempPath
childConfigs
List<E> childConfigs
- Field childConfigs
taps
Tap[] taps
scheme
Scheme scheme
- Field scheme
writeDirect
boolean writeDirect
- Field writeDirect
sinkMode
SinkMode sinkMode
- Field mode
incomingFields
Fields incomingFields
selectorFields
Fields selectorFields
Class cascading.tap.TapTest extends cascading.ClusterTestCase implements Serializable |
inputFileComments
String inputFileComments
inputFileJoined
String inputFileJoined
inputFileCross
String inputFileCross
inputFileUpper
String inputFileUpper
inputFileLower
String inputFileLower
outputPath
String outputPath
Class cascading.tap.TapTest.CommentScheme extends TextLine implements Serializable |
name
String name
- Field name
schemeClass
Class<T> schemeClass
- Field schemeClass
temporaryPath
String temporaryPath
- Field temporaryPath
parent
Tap parent
- Field parent
pathTemplate
String pathTemplate
- Field pathTemplate
keepParentOnDelete
boolean keepParentOnDelete
- Field keepParentOnDelete
openTapsThreshold
int openTapsThreshold
- Field openTapsThreshold
collectors
Map<K,V> collectors
- Field collectors
scheme
Scheme scheme
pathFields
Fields pathFields
pathTemplate
String pathTemplate
fields
Comparable<T>[] fields
- Field fields
isOrdered
boolean isOrdered
- Field isOrdered
kind
cascading.tuple.Fields.Kind kind
- Field kind
comparators
Comparator<T>[] comparators
- Field comparators
sourceFields
Fields sourceFields
- Field sourceFields
selectorFields
Fields selectorFields
- Field selectorFields
index
int index
tuple
Tuple tuple
isUnmodifiable
boolean isUnmodifiable
- Field isUnmodifiable
elements
List<E> elements
- Field elements
tuples
Tuple[] tuples
- Field tuples
Package cascading.tuple.hadoop |
Class cascading.tuple.hadoop.SerializedPipesTest.Container extends Object implements Serializable |
value
String value
Class cascading.tuple.hadoop.SerializedPipesTest.InsertBoolean extends BaseOperation implements Serializable |
asBoolean
boolean asBoolean
Class cascading.tuple.hadoop.SerializedPipesTest.InsertBytes extends BaseOperation implements Serializable |
asBytes
String asBytes
Class cascading.tuple.hadoop.SerializedPipesTest.InsertRawBytes extends BaseOperation<Long> implements Serializable |
asBytes
String asBytes
increment
boolean increment
Class cascading.tuple.hadoop.SerializedPipesTest.InsertTestText extends BaseOperation<Long> implements Serializable |
testText
String testText
increment
boolean increment
moduloValueIsNull
int moduloValueIsNull
moduloResultIsNull
int moduloResultIsNull
Class cascading.tuple.hadoop.SerializedPipesTest.ReplaceAsBytes extends BaseOperation implements Serializable |
Class cascading.tuple.hadoop.TestTextComparator extends Object implements Serializable |
Copyright © 2007-2010 Concurrent, Inc. All Rights Reserved.