Serialized Form

Package cascading

Class cascading.BasicPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.BasicTrapPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.BufferPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.CascadingException extends RuntimeException implements Serializable

Class cascading.CascadingTestCase extends junit.framework.TestCase implements Serializable

Class cascading.CoGroupFieldedPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.ComparePlatformsTest extends cascading.CascadingTestCase implements Serializable

Class cascading.DistanceUseCasePlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.FieldedPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.FieldedPipesPlatformTest.LowerComparator extends Object implements Serializable

Class cascading.JoinFieldedPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.JoinFieldedPipesPlatformTest.AllComparator extends Object implements Serializable

Class cascading.MergePipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.PlatformTestCase extends cascading.CascadingTestCase implements Serializable

Serialized Fields

rootPath

String rootPath

currentPaths

Set<E> currentPaths

Class cascading.RegressionMiscPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.RegressionPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.SortedValuesPlatformTest extends cascading.PlatformTestCase implements Serializable

Serialized Fields

apacheCommonRegex

String apacheCommonRegex

apacheCommonParser

RegexParser apacheCommonParser

Class cascading.TestAggregator extends BaseOperation implements Serializable

serialVersionUID: 1L

Serialized Fields

value

Tuple[] value

duplicates

int duplicates

groupFields

Fields groupFields

Class cascading.TestBuffer extends BaseOperation<TupleEntryCollector> implements Serializable

Serialized Fields

path

Tap<Config,Input,Output> path

expectedSize

int expectedSize

insertHeader

boolean insertHeader

insertFooter

boolean insertFooter

value

Comparable<T> value

flushCalled

boolean flushCalled

Class cascading.TestFailAggregator extends BaseOperation implements Serializable

serialVersionUID: 1L

Serialized Fields

fail

int fail

Class cascading.TestFunction extends BaseOperation<Integer> implements Serializable

Serialized Fields

failon

int failon

value

Tuple value

isSafe

boolean isSafe

Class cascading.TestIdentityBuffer extends BaseOperation<Integer> implements Serializable

Serialized Fields

groupFields

Fields groupFields

numGroups

Integer numGroups

nullsAreOK

boolean nullsAreOK

Class cascading.TraceTest extends cascading.CascadingTestCase implements Serializable

Class cascading.TraceTest.TestSubAssembly extends SubAssembly implements Serializable

Serialized Fields

pipe

Pipe pipe

Class cascading.TrapPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.TypedFieldedPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.UnmodifiablePipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.UnmodifiablePipesPlatformTest.TestAggregator extends BaseOperation implements Serializable

Class cascading.UnmodifiablePipesPlatformTest.TestBuffer extends BaseOperation implements Serializable

Class cascading.UnmodifiablePipesPlatformTest.TestFilter extends BaseOperation implements Serializable

Class cascading.UnmodifiablePipesPlatformTest.TestFunction extends BaseOperation implements Serializable

Package cascading.cascade

Class cascading.cascade.CascadeException extends CascadingException implements Serializable

Class cascading.cascade.CascadePlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.cascade.ParallelCascadePlatformTest extends cascading.PlatformTestCase implements Serializable

Package cascading.flow

Class cascading.flow.AssemblyPlannerPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.ClasspathPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.ClasspathPlatformTest.TestFunction extends BaseOperation implements Serializable

Class cascading.flow.FlowException extends CascadingException implements Serializable

Serialized Fields

flowName

String flowName

Field flowName

Class cascading.flow.FlowProcessPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.FlowProcessPlatformTest.IterateInsert extends BaseOperation implements Serializable

Serialized Fields

tap

Tap<Config,Input,Output> tap

Class cascading.flow.FlowStrategiesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.ResolverExceptionsPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.SubAssemblyPlatformTest extends cascading.PlatformTestCase implements Serializable

Package cascading.flow.hadoop

Class cascading.flow.hadoop.BuildJobsHadoopTest extends cascading.CascadingTestCase implements Serializable

Class cascading.flow.hadoop.FlowPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.hadoop.HadoopFlowStep extends cascading.flow.planner.BaseFlowStep<org.apache.hadoop.mapred.JobConf> implements Serializable

Serialized Fields

mapperTraps

Map<K,V> mapperTraps

Field mapperTraps

reducerTraps

Map<K,V> reducerTraps

Field reducerTraps

Class cascading.flow.hadoop.MapReduceFlowPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.flow.hadoop.MapReduceFlowStep extends HadoopFlowStep implements Serializable

Serialized Fields

jobConf

org.apache.hadoop.mapred.JobConf jobConf

Field jobConf

Package cascading.flow.local

Class cascading.flow.local.LocalFlowStep extends cascading.flow.planner.BaseFlowStep<Properties> implements Serializable

Serialized Fields

traps

Map<K,V> traps

Field mapperTraps

tapProperties

Map<K,V> tapProperties

Map of Properties modified by each Tap's sourceConfInit/sinkConfInit

Package cascading.management

Class cascading.management.DocumentServiceException extends CascadingException implements Serializable

Package cascading.operation

Class cascading.operation.AssertionException extends OperationException implements Serializable

Class cascading.operation.BaseOperation extends Object implements Serializable

Serialized Fields

fieldDeclaration

Fields fieldDeclaration

Field fieldDeclaration

numArgs

int numArgs

Field numArgs

trace

String trace

Field trace

Class cascading.operation.Debug extends BaseOperation<Long> implements Serializable

Serialized Fields

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

Class cascading.operation.Identity extends BaseOperation<cascading.operation.Identity.Functor> implements Serializable

Serialized Fields

types

Type[] types

Field types

Class cascading.operation.Insert extends BaseOperation implements Serializable

Serialized Fields

values

Tuple values

Field values

Class cascading.operation.NoOp extends BaseOperation implements Serializable

Class cascading.operation.OperationException extends CascadingException implements Serializable

Package cascading.operation.aggregator

Class cascading.operation.aggregator.AggregatorsTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.aggregator.Average extends BaseOperation<Average.Context> implements Serializable

Serialized Fields

type

Type type

Field type

canonical

CoercibleType<Canonical> canonical

Class cascading.operation.aggregator.Count extends BaseOperation<cascading.util.Pair<Long[],Tuple>> implements Serializable

Class cascading.operation.aggregator.ExtentBase extends BaseOperation<Tuple[]> implements Serializable

Serialized Fields

ignoreTuples

Collection<E> ignoreTuples

Field ignoreTuples

Class cascading.operation.aggregator.ExtremaBase extends BaseOperation<ExtremaBase.Context> implements Serializable

Serialized Fields

ignoreValues

Collection<E> ignoreValues

Deprecated.

Field ignoreValues

Class cascading.operation.aggregator.ExtremaValueBase extends BaseOperation<ExtremaValueBase.Context> implements Serializable

Serialized Fields

ignoreValues

Collection<E> ignoreValues

Field ignoreValues

Class cascading.operation.aggregator.First extends ExtentBase implements Serializable

Serialized Fields

firstN

int firstN

Class cascading.operation.aggregator.Last extends ExtentBase implements Serializable

Class cascading.operation.aggregator.Max extends ExtremaBase implements Serializable

Class cascading.operation.aggregator.MaxValue extends ExtremaValueBase implements Serializable

Class cascading.operation.aggregator.Min extends ExtremaBase implements Serializable

Class cascading.operation.aggregator.MinValue extends ExtremaValueBase implements Serializable

Class cascading.operation.aggregator.Sum extends BaseOperation<cascading.util.Pair<Double[],Tuple>> implements Serializable

Serialized Fields

type

Type type

Field type

canonical

CoercibleType<Canonical> canonical

Package cascading.operation.assertion

Class cascading.operation.assertion.AppliedAssertionsPlatformTest extends cascading.PlatformTestCase implements Serializable

Serialized Fields

apacheCommonRegex

String apacheCommonRegex

apacheCommonParser

RegexParser apacheCommonParser

Class cascading.operation.assertion.AssertEquals extends BaseAssertion implements Serializable

Serialized Fields

values

Tuple values

Field values

Class cascading.operation.assertion.AssertEqualsAll extends BaseAssertion implements Serializable

Serialized Fields

value

Object value

Field value

Class cascading.operation.assertion.AssertExpression extends ExpressionOperation implements Serializable

Class cascading.operation.assertion.AssertGroupBase extends BaseAssertion<AssertGroupBase.Context> implements Serializable

Serialized Fields

patternString

String patternString

Field patternString

size

long size

Field size

Class cascading.operation.assertion.AssertGroupSizeEquals extends AssertGroupBase implements Serializable

Class cascading.operation.assertion.AssertGroupSizeLessThan extends AssertGroupBase implements Serializable

Class cascading.operation.assertion.AssertGroupSizeMoreThan extends AssertGroupBase implements Serializable

Class cascading.operation.assertion.AssertMatches extends RegexMatcher implements Serializable

Class cascading.operation.assertion.AssertMatchesAll extends RegexMatcher implements Serializable

Class cascading.operation.assertion.AssertNotEquals extends BaseAssertion implements Serializable

Serialized Fields

values

Tuple values

Field values

Class cascading.operation.assertion.AssertNotNull extends BaseAssertion implements Serializable

Class cascading.operation.assertion.AssertNull extends BaseAssertion implements Serializable

Class cascading.operation.assertion.AssertSizeEquals extends BaseAssertion implements Serializable

Serialized Fields

size

int size

Field size

Class cascading.operation.assertion.AssertSizeLessThan extends BaseAssertion implements Serializable

Serialized Fields

size

int size

Field size

Class cascading.operation.assertion.AssertSizeMoreThan extends BaseAssertion implements Serializable

Serialized Fields

size

int size

Field size

Class cascading.operation.assertion.BaseAssertion extends BaseOperation<C> implements Serializable

Serialized Fields

message

String message

Field message

Class cascading.operation.assertion.BuildAssertionsPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.operation.assertion.GroupAssertionsTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.assertion.ValueAssertionsTest extends cascading.CascadingTestCase implements Serializable

Package cascading.operation.buffer

Class cascading.operation.buffer.FirstNBuffer extends BaseOperation implements Serializable

Serialized Fields

firstN

int firstN

Package cascading.operation.expression

Class cascading.operation.expression.ExpressionFilter extends ExpressionOperation implements Serializable

Class cascading.operation.expression.ExpressionFunction extends ExpressionOperation implements Serializable

Class cascading.operation.expression.ExpressionOperation extends ScriptOperation implements Serializable

Class cascading.operation.expression.ExpressionTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.expression.ScriptFilter extends ScriptOperation implements Serializable

Class cascading.operation.expression.ScriptFunction extends ScriptOperation implements Serializable

Class cascading.operation.expression.ScriptOperation extends BaseOperation<ScriptOperation.Context> implements Serializable

Serialized Fields

block

String block

Field expression

parameterTypes

Class<T>[] parameterTypes

Field parameterTypes

parameterNames

String[] parameterNames

Field parameterNames

returnType

Class<T> returnType

returnType

Class cascading.operation.expression.ScriptTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.expression.ScriptTupleFunction extends ScriptOperation implements Serializable

Class cascading.operation.expression.ScriptTupleTest extends cascading.CascadingTestCase implements Serializable

Package cascading.operation.filter

Class cascading.operation.filter.And extends Logic implements Serializable

Class cascading.operation.filter.FilterNotNull extends BaseOperation implements Serializable

Class cascading.operation.filter.FilterNull extends BaseOperation implements Serializable

Class cascading.operation.filter.FilterTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.filter.FilterTest.BooleanFilter extends BaseOperation implements Serializable

Serialized Fields

result

boolean result

Class cascading.operation.filter.Limit extends BaseOperation<Limit.Context> implements Serializable

Serialized Fields

limit

long limit

Class cascading.operation.filter.LimitFilterTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

operationCall

ConcreteCall<C> operationCall

Class cascading.operation.filter.Logic extends BaseOperation<Logic.Context> implements Serializable

Serialized Fields

argumentSelectors

Fields[] argumentSelectors

Field fields

filters

Filter<Context>[] filters

Field filters

Class cascading.operation.filter.Not extends BaseOperation implements Serializable

Serialized Fields

filter

Filter<Context> filter

Field filter

Class cascading.operation.filter.Or extends Logic implements Serializable

Class cascading.operation.filter.Sample extends BaseOperation<Random> implements Serializable

Serialized Fields

seed

long seed

fraction

double fraction

Class cascading.operation.filter.SampleFilterTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

operationCall

ConcreteCall<C> operationCall

Class cascading.operation.filter.Xor extends Logic implements Serializable

Package cascading.operation.function

Class cascading.operation.function.SetValue extends BaseOperation implements Serializable

Serialized Fields

filter

Filter<Context> filter

Field filter

values

Tuple[] values

Field values

Class cascading.operation.function.UnGroup extends BaseOperation implements Serializable

Serialized Fields

groupFieldSelector

Fields groupFieldSelector

Field groupFieldSelector

resultFieldSelectors

Fields[] resultFieldSelectors

Field resultFieldSelectors

size

int size

Field size

Package cascading.operation.regex

Class cascading.operation.regex.RegexesTest extends cascading.CascadingTestCase implements Serializable

Class cascading.operation.regex.RegexFilter extends RegexMatcher implements Serializable

Serialized Fields

matchEachElement

boolean matchEachElement

Field matchEachElement

Class cascading.operation.regex.RegexGenerator extends RegexOperation<cascading.util.Pair<Matcher,Tuple>> implements Serializable

Class cascading.operation.regex.RegexMatcher extends RegexOperation<Matcher> implements Serializable

Serialized Fields

negateMatch

boolean negateMatch

Field removeMatch

Class cascading.operation.regex.RegexOperation extends BaseOperation<C> implements Serializable

Serialized Fields

patternString

String patternString

Field patternString

Class cascading.operation.regex.RegexParser extends RegexOperation<cascading.util.Pair<Matcher,Tuple>> implements Serializable

Serialized Fields

groups

int[] groups

Field groups

Class cascading.operation.regex.RegexReplace extends RegexOperation<cascading.util.Pair<Matcher,Tuple>> implements Serializable

Serialized Fields

replacement

String replacement

Field replacement

replaceAll

boolean replaceAll

Field replaceAll

Class cascading.operation.regex.RegexSplitGenerator extends RegexOperation<cascading.util.Pair<Pattern,Tuple>> implements Serializable

Class cascading.operation.regex.RegexSplitter extends RegexOperation<cascading.util.Pair<Pattern,Tuple>> implements Serializable

Serialized Fields

length

int length

Package cascading.operation.state

Class cascading.operation.state.Counter extends BaseOperation implements Serializable

Serialized Fields

counterEnum

Enum<E extends Enum<E>> counterEnum

groupString

String groupString

counterString

String counterString

increment

int increment

Class cascading.operation.state.Status extends BaseOperation<Boolean> implements Serializable

Serialized Fields

status

String status

Field status

Package cascading.operation.text

Class cascading.operation.text.DateFormatter extends DateOperation implements Serializable

Class cascading.operation.text.DateOperation extends BaseOperation<cascading.util.Pair<SimpleDateFormat,Tuple>> implements Serializable

Serialized Fields

zone

TimeZone zone

Field zone

locale

Locale locale

Field locale

dateFormatString

String dateFormatString

Field dateFormatString

Class cascading.operation.text.DateParser extends DateOperation implements Serializable

Serialized Fields

calendarFields

int[] calendarFields

Field calendarFields

Class cascading.operation.text.FieldFormatter extends BaseOperation<Tuple> implements Serializable

Serialized Fields

format

String format

Field format

Class cascading.operation.text.FieldJoiner extends BaseOperation<Tuple> implements Serializable

Serialized Fields

delimiter

String delimiter

Field delimiter

Package cascading.operation.xml

Class cascading.operation.xml.TagSoupParser extends BaseOperation implements Serializable

Serialized Fields

features

Map<K,V> features

Field features

Class cascading.operation.xml.XPathFilter extends XPathOperation implements Serializable

Serialized Fields

removeMatch

boolean removeMatch

Field removeMatch

Class cascading.operation.xml.XPathGenerator extends XPathOperation implements Serializable

Class cascading.operation.xml.XPathOperation extends BaseOperation<cascading.util.Pair<DocumentBuilder,Tuple>> implements Serializable

Serialized Fields

namespaces

String[][] namespaces

Field namespaces

paths

String[] paths

Field paths

Class cascading.operation.xml.XPathParser extends XPathOperation implements Serializable

Class cascading.operation.xml.XPathTest extends cascading.CascadingTestCase implements Serializable

Package cascading.pipe

Class cascading.pipe.Checkpoint extends Pipe implements Serializable

Class cascading.pipe.CoGroup extends Splice implements Serializable

Class cascading.pipe.Each extends Operator implements Serializable

Class cascading.pipe.Every extends Operator implements Serializable

Class cascading.pipe.GroupBy extends Splice implements Serializable

Class cascading.pipe.HashJoin extends Splice implements Serializable

Class cascading.pipe.Merge extends Splice implements Serializable

Class cascading.pipe.MergeGroupPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.pipe.Operator extends Pipe implements Serializable

Serialized Fields

operation

Operation<Context> operation

Field operation

argumentSelector

Fields argumentSelector

Field argumentSelector

outputSelector

Fields outputSelector

Field outputSelector

plannerLevel

PlannerLevel plannerLevel

Field assertionLevel

Class cascading.pipe.OperatorException extends CascadingException implements Serializable

Serialized Fields

incomingFields

Fields incomingFields

argumentSelector

Fields argumentSelector

groupingSelector

Fields groupingSelector

sortingSelector

Fields sortingSelector

declaredFields

Fields declaredFields

outputSelector

Fields outputSelector

Class cascading.pipe.Pipe extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

String name

Field name

previous

Pipe previous

Field previous

parent

Pipe parent

Field parent

configDef

ConfigDef configDef

stepConfigDef

ConfigDef stepConfigDef

id

String id

Field id

trace

String trace

Field trace

Class cascading.pipe.PipeParamTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

ARGS_PASS

Fields[] ARGS_PASS

FUNCS_PASS

Fields[] FUNCS_PASS

OUTS_PASS

Fields[] OUTS_PASS

ARGS_FAIL

Fields[] ARGS_FAIL

FUNCS_FAIL

Fields[] FUNCS_FAIL

OUTS_FAIL

Fields[] OUTS_FAIL

Class cascading.pipe.Splice extends Pipe implements Serializable

Serialized Fields

kind

cascading.pipe.Splice.Kind kind

spliceName

String spliceName

Field spliceName

pipes

List<E> pipes

Field pipes

keyFieldsMap

Map<K,V> keyFieldsMap

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

Class cascading.pipe.SubAssembly extends Pipe implements Serializable

Serialized Fields

previous

Pipe[] previous

Field previous

tails

Pipe[] tails

Field tails

Package cascading.pipe.assembly

Class cascading.pipe.assembly.AggregateBy extends SubAssembly implements Serializable

Serialized Fields

name

String name

threshold

int threshold

groupingFields

Fields groupingFields

argumentFields

Fields[] argumentFields

functors

AggregateBy.Functor[] functors

aggregators

Aggregator<Context>[] aggregators

Class cascading.pipe.assembly.AggregateBy.CompositeFunction extends BaseOperation<AggregateBy.CompositeFunction.Context> implements Serializable

Serialized Fields

threshold

int threshold

groupingFields

Fields groupingFields

argumentFields

Fields[] argumentFields

functorFields

Fields[] functorFields

functors

AggregateBy.Functor[] functors

Class cascading.pipe.assembly.AssemblyHelpersPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.pipe.assembly.AverageBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.AverageBy.AverageFinal extends BaseOperation<AverageBy.AverageFinal.Context> implements Serializable

Class cascading.pipe.assembly.AverageBy.AveragePartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

include

AverageBy.Include include

Class cascading.pipe.assembly.Coerce extends SubAssembly implements Serializable

Class cascading.pipe.assembly.CountBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.CountBy.CountPartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

include

CountBy.Include include

Class cascading.pipe.assembly.Discard extends SubAssembly implements Serializable

Class cascading.pipe.assembly.FirstBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.FirstBy.FirstPartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

Class cascading.pipe.assembly.MaxBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.MaxBy.MaxPartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

Class cascading.pipe.assembly.MinBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.MinBy.MinPartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

Class cascading.pipe.assembly.Rename extends SubAssembly implements Serializable

Class cascading.pipe.assembly.Retain extends SubAssembly implements Serializable

Class cascading.pipe.assembly.SumBy extends AggregateBy implements Serializable

Class cascading.pipe.assembly.SumBy.SumPartials extends Object implements Serializable

Serialized Fields

declaredFields

Fields declaredFields

sumType

Type sumType

canonical

CoercibleType<Canonical> canonical

Class cascading.pipe.assembly.Unique extends SubAssembly implements Serializable

Class cascading.pipe.assembly.Unique.FilterPartialDuplicates extends BaseOperation<LinkedHashMap<Tuple,Object>> implements Serializable

Serialized Fields

threshold

int threshold

include

Unique.Include include

Package cascading.pipe.joiner

Class cascading.pipe.joiner.InnerJoin extends Object implements Serializable

Class cascading.pipe.joiner.LeftJoin extends Object implements Serializable

Class cascading.pipe.joiner.MixedJoin extends Object implements Serializable

Serialized Fields

asInner

boolean[] asInner

Class cascading.pipe.joiner.OuterJoin extends Object implements Serializable

Class cascading.pipe.joiner.RightJoin extends Object implements Serializable

Package cascading.property

Class cascading.property.ConfigDef extends Object implements Serializable

Serialized Fields

config

Map<K,V> config

Class cascading.property.ConfigDefPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.property.ConfigDefPlatformTest.ConfigSubAssembly extends SubAssembly implements Serializable

Class cascading.property.ConfigDefPlatformTest.IterateInsert extends BaseOperation implements Serializable

Package cascading.scheme

Class cascading.scheme.NullScheme extends Scheme<Config,Input,Output,SourceContext,SinkContext> implements Serializable

Class cascading.scheme.Scheme extends Object implements Serializable

Serialized Fields

sinkFields

Fields sinkFields

Field sinkFields

sourceFields

Fields sourceFields

Field sourceFields

numSinkParts

int numSinkParts

Field numSinkParts

trace

String trace

Field trace

Class cascading.scheme.TextDelimitedPlatformTest extends cascading.PlatformTestCase implements Serializable

Package cascading.scheme.hadoop

Class cascading.scheme.hadoop.SequenceFile extends Scheme<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector,Object[],Void> implements Serializable

Class cascading.scheme.hadoop.TextDelimited extends TextLine implements Serializable

Serialized Fields

delimitedParser

DelimitedParser delimitedParser

Field delimitedParser

skipHeader

boolean skipHeader

Field skipHeader

writeHeader

boolean writeHeader

Class cascading.scheme.hadoop.TextLine extends Scheme<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector,Object[],Object[]> implements Serializable

serialVersionUID: 1L

Serialized Fields

sinkCompression

TextLine.Compress sinkCompression

Field sinkCompression

charsetName

String charsetName

Class cascading.scheme.hadoop.WritableSequenceFile extends SequenceFile implements Serializable

Serialized Fields

keyType

Class<T> keyType

valueType

Class<T> valueType

Class cascading.scheme.hadoop.WritableSequenceFilePlatformTest extends cascading.PlatformTestCase implements Serializable

Package cascading.scheme.local

Class cascading.scheme.local.TextDelimited extends Scheme<Properties,InputStream,OutputStream,LineNumberReader,PrintWriter> implements Serializable

Serialized Fields

skipHeader

boolean skipHeader

writeHeader

boolean writeHeader

delimitedParser

DelimitedParser delimitedParser

charsetName

String charsetName

Class cascading.scheme.local.TextLine extends Scheme<Properties,InputStream,OutputStream,LineNumberReader,PrintWriter> implements Serializable

Serialized Fields

charsetName

String charsetName

Package cascading.scheme.util

Class cascading.scheme.util.DelimitedParser extends Object implements Serializable

Serialized Fields

sourceFields

Fields sourceFields

Field sourceFields

splitPattern

Pattern splitPattern

Field splitPattern

cleanPattern

Pattern cleanPattern

Field cleanPattern

escapePattern

Pattern escapePattern

Field escapePattern

delimiter

String delimiter

Field delimiter *

quote

String quote

Field quote

strict

boolean strict

Field strict

enforceStrict

boolean enforceStrict

Field enforceStrict

numValues

int numValues

Field numValues

types

Type[] types

Field types

coercibles

CoercibleType<Canonical>[] coercibles

Fields coercibles

safe

boolean safe

Field safe

fieldTypeResolver

FieldTypeResolver fieldTypeResolver

fieldTypeResolver

Package cascading.stats

Class cascading.stats.CascadeStats extends CascadingStats implements Serializable

Serialized Fields

cascade

Cascade cascade

flowStatsList

List<E> flowStatsList

Field flowStatsList

Class cascading.stats.CascadingStats extends Object implements Serializable

Serialized Fields

name

String name

Field name

clientState

ClientState clientState

status

CascadingStats.Status status

Field status

pendingTime

long pendingTime

Field pendingTime

startTime

long startTime

Field startTime

submitTime

long submitTime

Field submitTime

runTime

long runTime

Field runTime

finishedTime

long finishedTime

Field finishedTime

throwable

Throwable throwable

Field throwable

Class cascading.stats.FlowStats extends CascadingStats implements Serializable

Serialized Fields

flow

Flow<Config> flow

flowStepStatsList

List<E> flowStepStatsList

Class cascading.stats.FlowStepStats extends CascadingStats implements Serializable

Serialized Fields

flowStep

FlowStep<Config> flowStep

Package cascading.stats.hadoop

Class cascading.stats.hadoop.CascadingStatsPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.stats.hadoop.HadoopStepStats extends FlowStepStats implements Serializable

Serialized Fields

idCache

Map<K,V> idCache

numMapTasks

int numMapTasks

Field numMapTasks

numReduceTasks

int numReduceTasks

Field numReducerTasks

cachedCounters

org.apache.hadoop.mapred.Counters cachedCounters

Fields counters

timeouts

int timeouts

Fields timeouts

taskStats

Map<K,V> taskStats

Field taskStats

Package cascading.stats.local

Class cascading.stats.local.CascadingStatsPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.stats.local.LocalStepStats extends FlowStepStats implements Serializable

Serialized Fields

counters

Map<K,V> counters

Package cascading.tap

Class cascading.tap.BaseTemplateTap extends SinkTap<Config,Output> implements Serializable

Serialized Fields

parent

Tap<Config,Input,Output> 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

Class cascading.tap.BaseTemplateTap.TemplateScheme extends Scheme<Config,Void,Output,Void,Void> implements Serializable

Serialized Fields

scheme

Scheme<Config,Input,Output,SourceContext,SinkContext> scheme

pathFields

Fields pathFields

Class cascading.tap.MultiSinkTap extends SinkTap<Config,Output> implements Serializable

Serialized Fields

taps

Tap<Config,Input,Output>[] taps

Field taps

tempPath

String tempPath

Field tempPath

childConfigs

List<E> childConfigs

Field childConfigs

Class cascading.tap.MultiSourceTap extends SourceTap<Config,Input> implements Serializable

Serialized Fields

identifier

String identifier

taps

Tap<Config,Input,Output>[] taps

Class cascading.tap.SinkTap extends Tap<Config,Void,Output> implements Serializable

Class cascading.tap.SourceTap extends Tap<Config,Input,Void> implements Serializable

Class cascading.tap.Tap extends Object implements Serializable

Serialized Fields

scheme

Scheme<Config,Input,Output,SourceContext,SinkContext> scheme

Field scheme

sinkMode

SinkMode sinkMode

Field mode

configDef

ConfigDef configDef

processConfigDef

ConfigDef processConfigDef

id

String id

Field id

trace

String trace

Field trace

Class cascading.tap.TapCollectorPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.tap.TapException extends CascadingException implements Serializable

Serialized Fields

payload

Tuple payload

Class cascading.tap.TapPlatformTest extends cascading.PlatformTestCase implements Serializable

Package cascading.tap.hadoop

Class cascading.tap.hadoop.Dfs extends Hfs implements Serializable

Class cascading.tap.hadoop.GlobHfs extends MultiSourceTap<Hfs,org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader> implements Serializable

Serialized Fields

pathPattern

String pathPattern

Field pathPattern

pathFilter

org.apache.hadoop.fs.PathFilter pathFilter

Field pathFilter

Class cascading.tap.hadoop.HadoopTapPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.tap.hadoop.HadoopTapPlatformTest.CommentScheme extends TextLine implements Serializable

Class cascading.tap.hadoop.HadoopTapPlatformTest.DupeConfigScheme extends TextLine implements Serializable

Class cascading.tap.hadoop.HadoopTapPlatformTest.ResolvedScheme extends TextLine implements Serializable

Serialized Fields

expectedFields

Fields expectedFields

Class cascading.tap.hadoop.Hfs extends Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> implements Serializable

Serialized Fields

stringPath

String stringPath

Field stringPath

Class cascading.tap.hadoop.Lfs extends Hfs implements Serializable

Class cascading.tap.hadoop.TemplateTap extends BaseTemplateTap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.OutputCollector> implements Serializable

Package cascading.tap.hadoop.util

Class cascading.tap.hadoop.util.TempHfs extends Hfs implements Serializable

Serialized Fields

name

String name

Field name

schemeClass

Class<T> schemeClass

Field schemeClass

Package cascading.tap.local

Class cascading.tap.local.FileTap extends Tap<Properties,InputStream,OutputStream> implements Serializable

Serialized Fields

path

String path

Class cascading.tap.local.LocalTapPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.tap.local.StdErrTap extends SinkTap<Properties,OutputStream> implements Serializable

Class cascading.tap.local.StdInTap extends SourceTap<Properties,InputStream> implements Serializable

Class cascading.tap.local.StdOutTap extends SinkTap<Properties,OutputStream> implements Serializable

Class cascading.tap.local.TemplateTap extends BaseTemplateTap<Properties,OutputStream> implements Serializable

Package cascading.tuple

Class cascading.tuple.Fields extends Object implements Serializable

Serialized Fields

fields

Comparable<T>[] fields

Field fields

isOrdered

boolean isOrdered

Field isOrdered

kind

cascading.tuple.Fields.Kind kind

Field kind

types

Type[] types

Field types

comparators

Comparator<T>[] comparators

Field comparators

Class cascading.tuple.FieldsComparatorTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

Class cascading.tuple.FieldsResolverException extends TupleException implements Serializable

Serialized Fields

sourceFields

Fields sourceFields

Field sourceFields

selectorFields

Fields selectorFields

Field selectorFields

Class cascading.tuple.FieldsTest extends cascading.CascadingTestCase implements Serializable

Class cascading.tuple.Tuple extends Object implements Serializable

Serialized Fields

isUnmodifiable

boolean isUnmodifiable

Field isUnmodifiable

elements

List<E> elements

Field elements

Class cascading.tuple.TupleEntryTest extends cascading.CascadingTestCase implements Serializable

Class cascading.tuple.TupleException extends CascadingException implements Serializable

Class cascading.tuple.TupleFieldsTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

fields

Fields fields

tuple

Tuple tuple

Class cascading.tuple.TupleTest extends cascading.CascadingTestCase implements Serializable

Serialized Fields

tuple

Tuple tuple

Class cascading.tuple.TupleViewTest extends cascading.CascadingTestCase implements Serializable

Package cascading.tuple.coerce

Class cascading.tuple.coerce.BigDecimalCoerce extends Coercions.Coerce<BigDecimal> implements Serializable

Class cascading.tuple.coerce.BooleanCoerce extends Coercions.Coerce<Boolean> implements Serializable

Class cascading.tuple.coerce.BooleanObjectCoerce extends Coercions.Coerce<Boolean> implements Serializable

Class cascading.tuple.coerce.CharacterCoerce extends Coercions.Coerce<Character> implements Serializable

Class cascading.tuple.coerce.CharacterObjectCoerce extends Coercions.Coerce<Character> implements Serializable

Class cascading.tuple.coerce.Coercions.Coerce extends Object implements Serializable

Class cascading.tuple.coerce.DoubleCoerce extends Coercions.Coerce<Double> implements Serializable

Class cascading.tuple.coerce.DoubleObjectCoerce extends Coercions.Coerce<Double> implements Serializable

Class cascading.tuple.coerce.FloatCoerce extends Coercions.Coerce<Float> implements Serializable

Class cascading.tuple.coerce.FloatObjectCoerce extends Coercions.Coerce<Float> implements Serializable

Class cascading.tuple.coerce.IntegerCoerce extends Coercions.Coerce<Integer> implements Serializable

Class cascading.tuple.coerce.IntegerObjectCoerce extends Coercions.Coerce<Integer> implements Serializable

Class cascading.tuple.coerce.LongCoerce extends Coercions.Coerce<Long> implements Serializable

Class cascading.tuple.coerce.LongObjectCoerce extends Coercions.Coerce<Long> implements Serializable

Class cascading.tuple.coerce.ObjectCoerce extends Coercions.Coerce<Object> implements Serializable

Class cascading.tuple.coerce.ShortCoerce extends Coercions.Coerce<Short> implements Serializable

Class cascading.tuple.coerce.ShortObjectCoerce extends Coercions.Coerce<Short> implements Serializable

Class cascading.tuple.coerce.StringCoerce extends Coercions.Coerce<String> implements Serializable

Package cascading.tuple.collect

Class cascading.tuple.collect.SpillableTupleMap extends HashMap<Tuple,Collection<Tuple>> implements Serializable

Serialized Fields

mapThreshold

int mapThreshold

initListThreshold

int initListThreshold

spillListener

Spillable.SpillListener spillListener

Package cascading.tuple.hadoop

Class cascading.tuple.hadoop.HadoopSerializationPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.tuple.hadoop.SerializedPipesPlatformTest extends cascading.PlatformTestCase implements Serializable

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.Container extends Object implements Serializable

Serialized Fields

value

String value

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.InsertBoolean extends BaseOperation implements Serializable

Serialized Fields

asBoolean

boolean asBoolean

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.InsertBytes extends BaseOperation implements Serializable

Serialized Fields

asBytes

String asBytes

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.InsertRawBytes extends BaseOperation<Long> implements Serializable

Serialized Fields

asBytes

String asBytes

increment

boolean increment

randomIncrement

boolean randomIncrement

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.InsertTestText extends BaseOperation<Long> implements Serializable

Serialized Fields

testText

String testText

increment

boolean increment

moduloValueIsNull

int moduloValueIsNull

moduloResultIsNull

int moduloResultIsNull

Class cascading.tuple.hadoop.SerializedPipesPlatformTest.ReplaceAsBytes extends BaseOperation implements Serializable

Class cascading.tuple.hadoop.SpillableTupleHadoopTest extends cascading.CascadingTestCase implements Serializable

Class cascading.tuple.hadoop.TestTextComparator extends Object implements Serializable

Class cascading.tuple.hadoop.TupleTest extends cascading.CascadingTestCase implements Serializable

Package cascading.tuple.hadoop.collect

Class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap extends SpillableTupleMap implements Serializable

Serialized Fields

flowProcess

FlowProcess<Config> flowProcess

spillStrategy

Spillable.SpillStrategy spillStrategy

tupleCollectionFactory

TupleCollectionFactory<Config> tupleCollectionFactory

Package cascading.tuple.hadoop.util

Class cascading.tuple.hadoop.util.BytesComparator extends Object implements Serializable

Package cascading.tuple.io

Class cascading.tuple.io.IndexTuple extends Tuple implements Serializable

Serialized Fields

index

int index

tuple

Tuple tuple

Class cascading.tuple.io.TuplePair extends Tuple implements Serializable

Serialized Fields

tuples

Tuple[] tuples

Field tuples

Package cascading.tuple.type

Class cascading.tuple.type.DateType extends Object implements Serializable

Serialized Fields

zone

TimeZone zone

Field zone

locale

Locale locale

Field locale

dateFormatString

String dateFormatString

Field dateFormatString