Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Hierarchy For All Packages
Package Hierarchies:
cascading
,
cascading.cascade
,
cascading.flow
,
cascading.flow.hadoop
,
cascading.flow.hadoop.util
,
cascading.flow.local
,
cascading.management
,
cascading.management.annotation
,
cascading.management.state
,
cascading.operation
,
cascading.operation.aggregator
,
cascading.operation.assertion
,
cascading.operation.buffer
,
cascading.operation.expression
,
cascading.operation.filter
,
cascading.operation.function
,
cascading.operation.regex
,
cascading.operation.state
,
cascading.operation.text
,
cascading.operation.xml
,
cascading.pipe
,
cascading.pipe.assembly
,
cascading.pipe.joiner
,
cascading.property
,
cascading.provider
,
cascading.scheme
,
cascading.scheme.hadoop
,
cascading.scheme.local
,
cascading.scheme.util
,
cascading.stats
,
cascading.stats.hadoop
,
cascading.stats.local
,
cascading.tap
,
cascading.tap.hadoop
,
cascading.tap.hadoop.io
,
cascading.tap.hadoop.util
,
cascading.tap.local
,
cascading.tap.local.io
,
cascading.tap.partition
,
cascading.tap.type
,
cascading.tuple
,
cascading.tuple.coerce
,
cascading.tuple.collect
,
cascading.tuple.hadoop
,
cascading.tuple.hadoop.collect
,
cascading.tuple.hadoop.io
,
cascading.tuple.hadoop.util
,
cascading.tuple.io
,
cascading.tuple.type
,
cascading.tuple.util
Class Hierarchy
java.lang.
Object
java.util.
AbstractMap
<K,V> (implements java.util.
Map
<K,V>)
java.util.
HashMap
<K,V> (implements java.lang.
Cloneable
, java.util.
Map
<K,V>, java.io.
Serializable
)
cascading.tuple.collect.
SpillableTupleMap
(implements cascading.tuple.collect.
Spillable
)
cascading.tuple.hadoop.collect.
HadoopSpillableTupleMap
cascading.pipe.assembly.
AggregateBy.CompositeFunction.Context
cascading.operation.assertion.
AssertGroupBase.Context
cascading.operation.aggregator.
Average.Context
cascading.pipe.assembly.
AverageBy.AverageFinal.Context
cascading.pipe.assembly.
AverageBy.AveragePartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.flow.
BaseFlow
<Config> (implements cascading.flow.
Flow
<Config>)
cascading.flow.hadoop.
HadoopFlow
cascading.flow.hadoop.
MapReduceFlow
cascading.flow.hadoop.
ProcessFlow
<P>
cascading.flow.local.
LocalFlow
cascading.flow.
BaseFlow.FlowHolder
cascading.flow.planner.BaseFlowStep<Config> (implements cascading.flow.
FlowStep
<Config>, java.io.
Serializable
)
cascading.flow.hadoop.
HadoopFlowStep
cascading.flow.hadoop.
MapReduceFlowStep
cascading.flow.local.
LocalFlowStep
cascading.pipe.joiner.
BaseJoiner
(implements cascading.flow.planner.DeclaresResults, cascading.pipe.joiner.
Joiner
)
cascading.pipe.joiner.
BufferJoin
cascading.pipe.joiner.
InnerJoin
cascading.pipe.joiner.
LeftJoin
cascading.pipe.joiner.
MixedJoin
cascading.pipe.joiner.
OuterJoin
cascading.pipe.joiner.
RightJoin
cascading.operation.
BaseOperation
<Context> (implements cascading.operation.
Operation
<Context>, java.io.
Serializable
, cascading.util.Traceable)
cascading.pipe.assembly.
AggregateBy.CompositeFunction
(implements cascading.operation.
Function
<Context>)
cascading.operation.aggregator.
Average
(implements cascading.operation.
Aggregator
<Context>)
cascading.pipe.assembly.
AverageBy.AverageFinal
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.assertion.
BaseAssertion
<C> (implements cascading.operation.
PlannedOperation
<Context>)
cascading.operation.assertion.
AssertEquals
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertEqualsAll
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertGroupBase
(implements cascading.operation.
GroupAssertion
<C>)
cascading.operation.assertion.
AssertGroupSizeEquals
cascading.operation.assertion.
AssertGroupSizeLessThan
cascading.operation.assertion.
AssertGroupSizeMoreThan
cascading.operation.assertion.
AssertNotEquals
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertNotNull
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertNull
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertSizeEquals
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertSizeLessThan
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertSizeMoreThan
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.aggregator.
Count
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.state.
Counter
(implements cascading.operation.
Filter
<Context>)
cascading.operation.text.
DateOperation
cascading.operation.text.
DateFormatter
(implements cascading.operation.
Function
<Context>)
cascading.operation.text.
DateParser
(implements cascading.operation.
Function
<Context>)
cascading.operation.
Debug
(implements cascading.operation.
Filter
<Context>, cascading.operation.
PlannedOperation
<Context>)
cascading.operation.aggregator.
ExtentBase
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.aggregator.
First
cascading.operation.aggregator.
Last
cascading.operation.aggregator.
ExtremaBase
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.aggregator.
Max
cascading.operation.aggregator.
Min
cascading.operation.aggregator.
ExtremaValueBase
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.aggregator.
MaxValue
cascading.operation.aggregator.
MinValue
cascading.operation.text.
FieldFormatter
(implements cascading.operation.
Function
<Context>)
cascading.operation.text.
FieldJoiner
(implements cascading.operation.
Function
<Context>)
cascading.operation.filter.
FilterNotNull
(implements cascading.operation.
Filter
<Context>)
cascading.operation.filter.
FilterNull
(implements cascading.operation.
Filter
<Context>)
cascading.operation.buffer.
FirstNBuffer
(implements cascading.operation.
Buffer
<Context>)
cascading.operation.
Identity
(implements cascading.operation.
Function
<Context>)
cascading.operation.
Insert
(implements cascading.operation.
Function
<Context>)
cascading.operation.filter.
Limit
(implements cascading.operation.
Filter
<Context>)
cascading.operation.filter.
Logic
(implements cascading.operation.
Filter
<Context>)
cascading.operation.filter.
And
cascading.operation.filter.
Or
cascading.operation.filter.
Xor
cascading.operation.
NoOp
(implements cascading.operation.
Function
<Context>)
cascading.operation.filter.
Not
(implements cascading.operation.
Filter
<Context>)
cascading.operation.regex.
RegexOperation
<C>
cascading.operation.regex.
RegexGenerator
(implements cascading.operation.
Function
<Context>)
cascading.operation.regex.
RegexMatcher
cascading.operation.assertion.
AssertMatches
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.assertion.
AssertMatchesAll
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.regex.
RegexFilter
(implements cascading.operation.
Filter
<Context>)
cascading.operation.regex.
RegexParser
(implements cascading.operation.
Function
<Context>)
cascading.operation.regex.
RegexReplace
(implements cascading.operation.
Function
<Context>)
cascading.operation.regex.
RegexSplitGenerator
(implements cascading.operation.
Function
<Context>)
cascading.operation.regex.
RegexSplitter
(implements cascading.operation.
Function
<Context>)
cascading.operation.filter.
Sample
(implements cascading.operation.
Filter
<Context>)
cascading.operation.expression.
ScriptOperation
cascading.operation.expression.
ExpressionOperation
cascading.operation.assertion.
AssertExpression
(implements cascading.operation.
ValueAssertion
<C>)
cascading.operation.expression.
ExpressionFilter
(implements cascading.operation.
Filter
<Context>)
cascading.operation.expression.
ExpressionFunction
(implements cascading.operation.
Function
<Context>)
cascading.operation.expression.
ScriptFilter
(implements cascading.operation.
Filter
<Context>)
cascading.operation.expression.
ScriptFunction
(implements cascading.operation.
Function
<Context>)
cascading.operation.expression.
ScriptTupleFunction
(implements cascading.operation.
Function
<Context>)
cascading.operation.function.
SetValue
(implements cascading.operation.
Function
<Context>)
cascading.operation.state.
Status
(implements cascading.operation.
Filter
<Context>)
cascading.operation.aggregator.
Sum
(implements cascading.operation.
Aggregator
<Context>)
cascading.operation.xml.
TagSoupParser
(implements cascading.operation.
Function
<Context>)
cascading.operation.function.
UnGroup
(implements cascading.operation.
Function
<Context>)
cascading.pipe.assembly.
Unique.FilterPartialDuplicates
(implements cascading.operation.
Filter
<Context>)
cascading.operation.xml.
XPathOperation
cascading.operation.xml.
XPathFilter
(implements cascading.operation.
Filter
<Context>)
cascading.operation.xml.
XPathGenerator
(implements cascading.operation.
Function
<Context>)
cascading.operation.xml.
XPathParser
(implements cascading.operation.
Function
<Context>)
cascading.management.state.
BaseState
(implements cascading.provider.
CascadingService
)
cascading.management.state.
ClientState
cascading.tuple.hadoop.
BigDecimalSerialization.BigDecimalDeserializer
(implements org.apache.hadoop.io.serializer.Deserializer<T>)
cascading.tuple.hadoop.
BigDecimalSerialization.BigDecimalSerializer
(implements org.apache.hadoop.io.serializer.Serializer<T>)
cascading.tuple.hadoop.util.
BytesComparator
(implements java.util.
Comparator
<T>, cascading.tuple.
Hasher
<V>, java.io.
Serializable
, cascading.tuple.
StreamComparator
<T>)
cascading.tuple.hadoop.
BytesSerialization.RawBytesDeserializer
(implements org.apache.hadoop.io.serializer.Deserializer<T>)
cascading.tuple.hadoop.
BytesSerialization.RawBytesSerializer
(implements org.apache.hadoop.io.serializer.Serializer<T>)
cascading.cascade.
Cascade
(implements cascading.management.
UnitOfWork
<Stats>)
cascading.cascade.
Cascade.CascadeJob
(implements java.util.concurrent.
Callable
<V>)
cascading.cascade.
CascadeConnector
cascading.cascade.
Cascades
cascading.management.
CascadingServices
cascading.management.
CascadingServices.NullDocumentService
(implements cascading.management.
DocumentService
)
cascading.management.
CascadingServices.NullMetricsService
(implements cascading.management.
MetricsService
)
cascading.stats.
CascadingStats
(implements java.io.
Serializable
)
cascading.stats.
CascadeStats
cascading.stats.
FlowStats
cascading.stats.
FlowStepStats
cascading.stats.hadoop.
HadoopStepStats
cascading.stats.local.
LocalStepStats
cascading.tuple.coerce.
Coercions
cascading.tuple.coerce.
Coercions.Coerce
<T> (implements cascading.tuple.type.
CoercibleType
<Canonical>)
cascading.tuple.coerce.
BigDecimalCoerce
cascading.tuple.coerce.
BooleanCoerce
cascading.tuple.coerce.
BooleanObjectCoerce
cascading.tuple.coerce.
CharacterCoerce
cascading.tuple.coerce.
CharacterObjectCoerce
cascading.tuple.coerce.
DoubleCoerce
cascading.tuple.coerce.
DoubleObjectCoerce
cascading.tuple.coerce.
FloatCoerce
cascading.tuple.coerce.
FloatObjectCoerce
cascading.tuple.coerce.
IntegerCoerce
cascading.tuple.coerce.
IntegerObjectCoerce
cascading.tuple.coerce.
LongCoerce
cascading.tuple.coerce.
LongObjectCoerce
cascading.tuple.coerce.
ObjectCoerce
cascading.tuple.coerce.
ShortCoerce
cascading.tuple.coerce.
ShortObjectCoerce
cascading.tuple.coerce.
StringCoerce
cascading.tap.hadoop.io.
CombineFileRecordReaderWrapper
<K,V> (implements org.apache.hadoop.mapred.RecordReader<K,V>)
cascading.operation.
ConcreteCall
<C> (implements cascading.operation.
AggregatorCall
<C>, cascading.operation.
BufferCall
<C>, cascading.operation.
FilterCall
<C>, cascading.operation.
FunctionCall
<C>, cascading.operation.
GroupAssertionCall
<C>, cascading.operation.
ValueAssertionCall
<C>)
cascading.scheme.
ConcreteCall
<Context,IO> (implements cascading.scheme.
SinkCall
<Context,Output>, cascading.scheme.
SourceCall
<Context,Input>)
cascading.property.
ConfigDef
(implements java.io.
Serializable
)
org.apache.hadoop.conf.Configured (implements org.apache.hadoop.conf.Configurable)
cascading.tuple.hadoop.
BigDecimalSerialization
(implements org.apache.hadoop.io.serializer.Serialization<T>)
cascading.tuple.hadoop.
BytesSerialization
(implements cascading.tuple.
Comparison
<T>, org.apache.hadoop.io.serializer.Serialization<T>)
cascading.tuple.hadoop.util.
DeserializerComparator
<T> (implements org.apache.hadoop.io.RawComparator<T>)
cascading.tuple.hadoop.util.
CoGroupingComparator
cascading.tuple.hadoop.util.
GroupingComparator
cascading.tuple.hadoop.util.
GroupingSortingComparator
cascading.tuple.hadoop.util.
ReverseGroupingSortingComparator
cascading.tuple.hadoop.util.
IndexTupleCoGroupingComparator
(implements org.apache.hadoop.conf.Configurable)
cascading.tuple.hadoop.util.
TupleComparator
(implements org.apache.hadoop.conf.Configurable)
cascading.tuple.hadoop.util.
ReverseTupleComparator
org.apache.hadoop.fs.FileSystem (implements java.io.
Closeable
)
cascading.tap.hadoop.io.
StreamedFileSystem
cascading.tap.hadoop.io.
HttpFileSystem
cascading.tuple.hadoop.
TupleSerialization
(implements org.apache.hadoop.io.serializer.Serialization<T>)
cascading.pipe.assembly.
CountBy.CountPartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.tuple.type.
DateType
(implements cascading.tuple.type.
CoercibleType
<Canonical>)
cascading.tuple.hadoop.util.
DelegatingTupleElementComparator
(implements java.util.
Comparator
<T>, cascading.tuple.
StreamComparator
<T>)
cascading.scheme.util.
DelimitedParser
(implements java.io.
Serializable
)
cascading.tap.partition.
DelimitedPartition
(implements cascading.tap.partition.
Partition
)
cascading.operation.aggregator.
ExtremaBase.Context
cascading.operation.aggregator.
ExtremaValueBase.Context
cascading.flow.hadoop.util.
FalseCollection
(implements java.util.
Collection
<E>)
cascading.tuple.
Fields
(implements java.lang.
Comparable
<T>, java.util.
Comparator
<T>, java.lang.
Iterable
<T>, java.io.
Serializable
)
cascading.pipe.assembly.
FirstBy.FirstPartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.flow.
FlowConnector
cascading.flow.hadoop.
HadoopFlowConnector
cascading.flow.local.
LocalFlowConnector
cascading.flow.hadoop.
FlowMapper
(implements org.apache.hadoop.mapred.MapRunnable<K1,V1,K2,V2>)
cascading.flow.
FlowProcess
<Config>
cascading.flow.
FlowProcess.NullFlowProcess
cascading.flow.
FlowProcessWrapper
<Config>
cascading.flow.hadoop.
HadoopFlowProcess
cascading.flow.local.
LocalFlowProcess
cascading.flow.
Flows
cascading.flow.
FlowSession
cascading.flow.
FlowSkipIfSinkExists
(implements cascading.flow.
FlowSkipStrategy
)
cascading.flow.
FlowSkipIfSinkNotStale
(implements cascading.flow.
FlowSkipStrategy
)
cascading.tap.hadoop.util.
Hadoop18TapUtil
cascading.stats.hadoop.
HadoopSliceStats
cascading.stats.hadoop.
HadoopSliceStats.HadoopAttempt
cascading.tuple.hadoop.collect.
HadoopTupleCollectionFactory
(implements cascading.tuple.collect.
TupleCollectionFactory
<Config>)
cascading.tuple.hadoop.collect.
HadoopTupleMapFactory
(implements cascading.tuple.collect.
TupleMapFactory
<Config>)
cascading.flow.hadoop.util.
HadoopUtil
cascading.tuple.hadoop.io.
IndexTupleDeserializer
cascading.tuple.hadoop.io.
IndexTupleSerializer
cascading.pipe.joiner.
InnerJoin.JoinIterator
(implements java.util.
Iterator
<E>)
cascading.pipe.joiner.
OuterJoin.JoinIterator
cascading.pipe.joiner.
LeftJoin.JoinIterator
cascading.pipe.joiner.
MixedJoin.JoinIterator
cascading.pipe.joiner.
RightJoin.JoinIterator
java.io.
InputStream
(implements java.io.
Closeable
)
java.io.
ByteArrayInputStream
cascading.tuple.hadoop.io.
BufferedInputStream
java.io.
FilterInputStream
java.io.
DataInputStream
(implements java.io.
DataInput
)
cascading.tuple.io.
TupleInputStream
cascading.tuple.hadoop.io.
HadoopTupleInputStream
org.apache.hadoop.fs.FSInputStream (implements org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable)
cascading.tap.hadoop.io.
FSDigestInputStream
cascading.flow.hadoop.util.
JavaObjectSerializer
(implements cascading.flow.hadoop.util.
ObjectSerializer
)
cascading.pipe.joiner.
JoinerClosure
cascading.flow.hadoop.
HadoopGroupByClosure
cascading.flow.hadoop.
HadoopCoGroupClosure
cascading.operation.filter.
Limit.Context
cascading.operation.filter.
Logic.Context
org.apache.hadoop.mapred.MapReduceBase (implements org.apache.hadoop.io.Closeable, org.apache.hadoop.mapred.JobConfigurable)
cascading.flow.hadoop.
FlowReducer
(implements org.apache.hadoop.mapred.Reducer<K2,V2,K3,V3>)
cascading.pipe.assembly.
MaxBy.MaxPartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.tap.hadoop.util.
MeasuredOutputCollector
(implements java.io.
Closeable
, org.apache.hadoop.mapred.OutputCollector<K,V>)
cascading.tap.hadoop.util.
MeasuredRecordReader
(implements org.apache.hadoop.mapred.RecordReader<K,V>)
cascading.pipe.assembly.
MinBy.MinPartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.tap.hadoop.io.
MultiInputFormat
(implements org.apache.hadoop.mapred.InputFormat<K,V>)
cascading.tap.hadoop.io.
MultiInputSplit
(implements org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.mapred.JobConfigurable)
cascading.tap.hadoop.io.
MultiRecordReaderIterator
(implements cascading.util.CloseableIterator<V>)
java.io.
OutputStream
(implements java.io.
Closeable
, java.io.
Flushable
)
java.io.
FileOutputStream
cascading.tap.local.io.
TapFileOutputStream
java.io.
FilterOutputStream
java.io.
DataOutputStream
(implements java.io.
DataOutput
)
cascading.tuple.io.
TupleOutputStream
cascading.tuple.hadoop.io.
HadoopTupleOutputStream
cascading.tap.partition.
PartitionTupleEntryIterator
(implements java.util.
Iterator
<E>)
cascading.pipe.
Pipe
(implements cascading.flow.
FlowElement
, java.io.
Serializable
, cascading.util.Traceable)
cascading.pipe.
Checkpoint
cascading.pipe.
Operator
cascading.pipe.
Each
cascading.pipe.
Every
cascading.pipe.
Splice
cascading.pipe.
CoGroup
(implements cascading.pipe.
Group
)
cascading.pipe.
GroupBy
(implements cascading.pipe.
Group
)
cascading.pipe.
HashJoin
cascading.pipe.
Merge
cascading.pipe.
SubAssembly
cascading.pipe.assembly.
AggregateBy
cascading.pipe.assembly.
AverageBy
cascading.pipe.assembly.
CountBy
cascading.pipe.assembly.
FirstBy
cascading.pipe.assembly.
MaxBy
cascading.pipe.assembly.
MinBy
cascading.pipe.assembly.
SumBy
cascading.pipe.assembly.
Coerce
cascading.pipe.assembly.
Discard
cascading.pipe.assembly.
Rename
cascading.pipe.assembly.
Retain
cascading.pipe.assembly.
Unique
cascading.property.
PropertyUtil
cascading.property.
Props
cascading.property.
AppProps
cascading.cascade.
CascadeProps
cascading.flow.
FlowConnectorProps
cascading.flow.
FlowProps
cascading.tap.hadoop.
HfsProps
cascading.tap.partition.
PartitionTapProps
cascading.tuple.collect.
SpillableProps
cascading.tuple.
TupleEntrySchemeIteratorProps
cascading.tuple.hadoop.
TupleSerializationProps
cascading.provider.
ProviderLoader
<Provider>
cascading.provider.
FactoryLoader
cascading.provider.
ServiceLoader
cascading.scheme.
Scheme
<Config,Input,Output,SourceContext,SinkContext> (implements java.io.
Serializable
, cascading.util.Traceable)
cascading.tap.partition.
BasePartitionTap.PartitionScheme
<Config,Input,Output>
cascading.tap.
BaseTemplateTap.TemplateScheme
<Config,Output>
cascading.scheme.
NullScheme
<Config,Input,Output,SourceContext,SinkContext>
cascading.scheme.hadoop.
SequenceFile
cascading.scheme.hadoop.
WritableSequenceFile
cascading.scheme.local.
TextDelimited
cascading.scheme.hadoop.
TextLine
cascading.scheme.hadoop.
TextDelimited
cascading.scheme.local.
TextLine
cascading.operation.expression.
ScriptOperation.Context
cascading.util.SingleValueIterator<Value> (implements java.util.
Iterator
<E>)
cascading.util.SingleValueCloseableIterator<Value> (implements cascading.util.CloseableIterator<V>)
cascading.tap.hadoop.io.
RecordReaderIterator
cascading.tuple.collect.
SpillableTupleList
(implements java.util.
Collection
<E>, cascading.tuple.collect.
Spillable
)
cascading.tuple.hadoop.collect.
HadoopSpillableTupleList
cascading.pipe.assembly.
SumBy.SumPartials
(implements cascading.pipe.assembly.
AggregateBy.Functor
)
cascading.tap.
Tap
<Config,Input,Output> (implements cascading.flow.
FlowElement
, java.io.
Serializable
, cascading.util.Traceable)
cascading.tap.partition.
BasePartitionTap
<Config,Input,Output>
cascading.tap.hadoop.
PartitionTap
cascading.tap.local.
PartitionTap
cascading.tap.
DecoratorTap
<MetaInfo,Config,Input,Output>
cascading.tap.hadoop.
DistCacheTap
cascading.tap.local.
FileTap
(implements cascading.tap.type.
FileType
<Config>)
cascading.tap.hadoop.
Hfs
(implements cascading.tap.type.
FileType
<Config>)
cascading.tap.hadoop.
Dfs
cascading.tap.hadoop.
Lfs
cascading.tap.hadoop.util.
TempHfs
cascading.tap.
SinkTap
<Config,Output>
cascading.tap.
BaseTemplateTap
<Config,Output>
cascading.tap.hadoop.
TemplateTap
cascading.tap.local.
TemplateTap
cascading.tap.
MultiSinkTap
<Child,Config,Output> (implements cascading.tap.
CompositeTap
<Child>)
cascading.tap.local.
StdErrTap
cascading.tap.local.
StdOutTap
cascading.tap.
SourceTap
<Config,Input>
cascading.tap.
MultiSourceTap
<Child,Config,Input> (implements cascading.tap.
CompositeTap
<Child>)
cascading.tap.hadoop.
GlobHfs
cascading.tap.local.
StdInTap
cascading.tap.hadoop.io.
TapOutputCollector
(implements java.io.
Closeable
, org.apache.hadoop.mapred.OutputCollector<K,V>)
java.lang.
Throwable
(implements java.io.
Serializable
)
java.lang.
Exception
java.lang.
RuntimeException
cascading.
CascadingException
cascading.cascade.
CascadeException
cascading.management.
DocumentServiceException
cascading.flow.
FlowException
cascading.operation.
OperationException
cascading.operation.
AssertionException
cascading.pipe.
OperatorException
cascading.tap.
TapException
cascading.tuple.
TupleException
cascading.tuple.
FieldsResolverException
cascading.flow.hadoop.util.
TimedIterator
(implements java.util.
Iterator
<E>)
cascading.tuple.
Tuple
(implements java.lang.
Comparable
<T>, java.lang.
Iterable
<T>, java.io.
Serializable
)
cascading.tuple.io.
IndexTuple
(implements java.lang.
Comparable
<T>)
cascading.tuple.io.
TuplePair
cascading.tuple.util.
TupleBuilder
cascading.tuple.hadoop.io.
TupleDeserializer
cascading.tuple.hadoop.util.
TupleElementComparator
(implements java.util.
Comparator
<T>, cascading.tuple.
StreamComparator
<T>)
cascading.tuple.hadoop.util.
TupleElementStreamComparator
(implements java.util.
Comparator
<T>, cascading.tuple.
StreamComparator
<T>)
cascading.tuple.
TupleEntry
cascading.tuple.
TupleEntryCollector
cascading.tap.partition.
BasePartitionTap.PartitionCollector
cascading.tuple.
TupleEntrySchemeCollector
<Config,Output>
cascading.tap.hadoop.io.
HadoopTupleEntrySchemeCollector
cascading.tuple.
TupleEntryIterator
(implements java.io.
Closeable
, java.util.
Iterator
<E>)
cascading.tuple.
TupleEntryChainIterator
cascading.tuple.
TupleEntryIterableChainIterator
cascading.tuple.
TupleEntrySchemeIterator
<Config,Input>
cascading.tap.hadoop.io.
HadoopTupleEntrySchemeIterator
cascading.tuple.util.
TupleHasher
(implements java.io.
Serializable
)
cascading.tuple.hadoop.util.
HasherPartitioner
(implements org.apache.hadoop.mapred.JobConfigurable)
cascading.tuple.hadoop.util.
CoGroupingPartitioner
(implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
cascading.tuple.hadoop.util.
GroupingPartitioner
(implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
cascading.tuple.hadoop.util.
GroupingSortingPartitioner
(implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
cascading.tuple.hadoop.io.
TuplePairDeserializer
cascading.tuple.hadoop.io.
TuplePairSerializer
cascading.tuple.
Tuples
cascading.tuple.hadoop.
TupleSerialization.SerializationElementReader
(implements cascading.tuple.io.
TupleInputStream.ElementReader
)
cascading.tuple.hadoop.
TupleSerialization.SerializationElementWriter
(implements cascading.tuple.io.
TupleOutputStream.ElementWriter
)
cascading.tuple.hadoop.io.
TupleSerializer
cascading.tuple.util.
TupleViews
cascading.property.
UnitOfWorkDef
<T>
cascading.cascade.
CascadeDef
cascading.flow.
FlowDef
cascading.management.
UnitOfWorkExecutorStrategy
(implements cascading.management.
UnitOfWorkSpawnStrategy
)
cascading.management.annotation.
URISanitizer
(implements cascading.management.annotation.
Sanitizer
)
Interface Hierarchy
cascading.flow.
AssemblyPlanner
cascading.flow.
AssemblyPlanner.Context
cascading.cascade.
CascadeListener
cascading.provider.
CascadingFactory
<Config,Instance>
cascading.tuple.collect.
TupleCollectionFactory
<Config>
cascading.tuple.collect.
TupleMapFactory
<Config>
cascading.provider.
CascadingService
cascading.management.
DocumentService
cascading.management.
MetricsService
cascading.tuple.
Comparison
<T>
cascading.tap.
CompositeTap
<Child>
cascading.property.
ConfigDef.Getter
cascading.property.
ConfigDef.Setter
cascading.flow.planner.DeclaresResults
cascading.operation.
Operation
<Context>
cascading.operation.
Aggregator
<Context>
cascading.operation.
Assertion
<PC>
cascading.operation.
GroupAssertion
<C>
cascading.operation.
ValueAssertion
<C>
cascading.operation.
Buffer
<Context>
cascading.operation.
Filter
<Context>
cascading.operation.
Function
<Context>
cascading.operation.
GroupAssertion
<C>
cascading.operation.
PlannedOperation
<Context>
cascading.operation.
Assertion
<PC>
cascading.operation.
GroupAssertion
<C>
cascading.operation.
ValueAssertion
<C>
cascading.operation.
GroupAssertion
<C>
cascading.operation.
ValueAssertion
<C>
cascading.operation.
ValueAssertion
<C>
cascading.tap.type.
FileType
<Config>
cascading.flow.
FlowDescriptors
cascading.flow.
FlowListener
cascading.flow.
FlowSkipStrategy
cascading.flow.
FlowStep
<Config>
cascading.flow.
FlowStepListener
cascading.flow.
FlowStepStrategy
<Config>
cascading.tuple.
Hasher
<V>
cascading.flow.hadoop.util.
ObjectSerializer
cascading.operation.
OperationCall
<Context>
cascading.operation.
AggregatorCall
<C>
cascading.operation.
BufferCall
<C>
cascading.operation.
FilterCall
<C>
cascading.operation.
FunctionCall
<C>
cascading.operation.
GroupAssertionCall
<C>
cascading.operation.
ValueAssertionCall
<C>
cascading.operation.
PlannerLevel
cascading.management.annotation.
Sanitizer
java.io.
Serializable
cascading.pipe.assembly.
AggregateBy.Functor
cascading.tuple.type.
CoercibleType
<Canonical> (also extends java.lang.reflect.
Type
)
cascading.scheme.util.
FieldTypeResolver
cascading.flow.
FlowElement
cascading.pipe.
Group
cascading.pipe.joiner.
Joiner
cascading.tap.partition.
Partition
cascading.scheme.
SinkCall
<Context,Output>
cascading.scheme.
SourceCall
<Context,Input>
cascading.tuple.collect.
Spillable
cascading.tuple.collect.
Spillable.SpillListener
cascading.tuple.collect.
Spillable.SpillStrategy
cascading.tuple.
StreamComparator
<T>
cascading.tuple.io.
TupleInputStream.ElementReader
cascading.tuple.io.
TupleOutputStream.ElementWriter
cascading.tuple.io.
TupleOutputStream.TupleElementWriter
java.lang.reflect.
Type
cascading.tuple.type.
CoercibleType
<Canonical> (also extends java.io.
Serializable
)
cascading.management.
UnitOfWork
<Stats>
cascading.flow.
Flow
<Config>
cascading.management.
UnitOfWorkSpawnStrategy
Annotation Type Hierarchy
cascading.management.annotation.
Property
(implements java.lang.annotation.
Annotation
)
cascading.management.annotation.
PropertyConfigured
(implements java.lang.annotation.
Annotation
)
cascading.management.annotation.
PropertyDescription
(implements java.lang.annotation.
Annotation
)
cascading.management.annotation.
PropertyOrder
(implements java.lang.annotation.
Annotation
)
cascading.management.annotation.
PropertyRegexSanitizer
(implements java.lang.annotation.
Annotation
)
cascading.management.annotation.
PropertySanitizer
(implements java.lang.annotation.
Annotation
)
cascading.tuple.hadoop.
SerializationToken
(implements java.lang.annotation.
Annotation
)
Enum Hierarchy
java.lang.
Object
java.lang.
Enum
<E> (implements java.lang.
Comparable
<T>, java.io.
Serializable
)
cascading.flow.
SliceCounters
cascading.flow.
StepCounters
cascading.flow.hadoop.
HadoopCoGroupClosure.Spill
cascading.management.annotation.
Order
cascading.management.annotation.
Visibility
cascading.operation.
AssertionLevel
(implements cascading.operation.
PlannerLevel
)
cascading.operation.
Debug.Output
cascading.operation.
DebugLevel
(implements cascading.operation.
PlannerLevel
)
cascading.pipe.assembly.
AggregateBy.Cache
cascading.pipe.assembly.
AggregateBy.Flush
cascading.pipe.assembly.
AverageBy.Include
cascading.pipe.assembly.
CountBy.Include
cascading.pipe.assembly.
Unique.Include
cascading.pipe.assembly.
Unique.Cache
cascading.property.
ConfigDef.Mode
cascading.scheme.hadoop.
TextLine.Compress
cascading.stats.
CascadingStats.Status
cascading.stats.hadoop.
HadoopSliceStats.Kind
cascading.tap.
BaseTemplateTap.Counters
cascading.tap.
SinkMode
cascading.tap.partition.
BasePartitionTap.Counters
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.