Hierarchy For All Packages

Package Hierarchies:

cascading, cascading.cascade, cascading.flow, cascading.flow.hadoop, cascading.flow.local, cascading.management, cascading.management.state, cascading.operation, cascading.operation.aggregator, cascading.operation.assertion, 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.stats, cascading.stats.hadoop, cascading.stats.local, cascading.tap, cascading.tap.hadoop, cascading.tap.hadoop.io, cascading.tap.local, cascading.tap.local.io, cascading.tuple, cascading.tuple.collect, cascading.tuple.hadoop, cascading.tuple.hadoop.collect, cascading.tuple.hadoop.io, cascading.tuple.io

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.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.operation.BaseOperation<Context> (implements cascading.operation.Operation<Context>, java.io.Serializable)
    • 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.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.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.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.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.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.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.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.BytesSerialization (implements cascading.tuple.Comparison<T>, org.apache.hadoop.io.serializer.Serialization<T>)
    • 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.operation.expression.ExpressionOperation.Context
  • cascading.operation.aggregator.ExtremaBase.Context
  • 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.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.tuple.hadoop.io.IndexTupleDeserializer
  • cascading.tuple.hadoop.io.IndexTupleSerializer
  • cascading.pipe.joiner.InnerJoin (implements cascading.pipe.joiner.Joiner)
  • 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.pipe.joiner.JoinerClosure
    • cascading.flow.hadoop.HadoopGroupByClosure
      • cascading.flow.hadoop.HadoopCoGroupClosure
  • cascading.pipe.joiner.LeftJoin (implements cascading.pipe.joiner.Joiner)
  • 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.joiner.MixedJoin (implements cascading.pipe.joiner.Joiner)
  • 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>)
  • cascading.pipe.joiner.OuterJoin (implements cascading.pipe.joiner.Joiner)
  • 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.pipe.Pipe (implements cascading.flow.FlowElement, java.io.Serializable)
    • 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.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.tuple.collect.SpillableProps
    • cascading.tuple.hadoop.TupleSerializationProps
  • cascading.provider.ProviderLoader<Provider>
    • cascading.provider.FactoryLoader
    • cascading.provider.ServiceLoader
  • cascading.pipe.joiner.RightJoin (implements cascading.pipe.joiner.Joiner)
  • cascading.scheme.Scheme<Config,Input,Output,SourceContext,SinkContext> (implements java.io.Serializable)
    • 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.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.tap.local.FileTap
    • cascading.tap.hadoop.Hfs
      • cascading.tap.hadoop.Dfs
      • cascading.tap.hadoop.Lfs
    • 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.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.hadoop.io.TupleDeserializer
  • cascading.tuple.TupleEntry
  • cascading.tuple.TupleEntryCollector
    • 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.TupleEntrySchemeIterator<Config,Input>
      • cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
  • 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.property.UnitOfWorkDef<T>
    • cascading.cascade.CascadeDef
    • cascading.flow.FlowDef
  • cascading.management.UnitOfWorkExecutorStrategy (implements cascading.management.UnitOfWorkSpawnStrategy)

Interface Hierarchy

• 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.FlowListener
• cascading.flow.FlowSkipStrategy
• cascading.flow.FlowStep<Config>
• cascading.flow.FlowStepStrategy<Config>
• cascading.tuple.Hasher<V>
• 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.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
• java.io.Serializable
  • cascading.pipe.assembly.AggregateBy.Functor
  • cascading.flow.FlowElement
    • cascading.pipe.Group
  • cascading.pipe.joiner.Joiner
• 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
• cascading.management.UnitOfWork<Stats>
  • cascading.flow.Flow<Config>
• cascading.management.UnitOfWorkSpawnStrategy

Annotation Type Hierarchy

• 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.operation.AssertionLevel (implements cascading.operation.PlannerLevel)
    • cascading.operation.Debug.Output
    • cascading.operation.DebugLevel (implements cascading.operation.PlannerLevel)
    • cascading.pipe.assembly.AggregateBy.Flush
    • 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