Hierarchy For All Packages

Package Hierarchies:

• org.apache.crunch,
• org.apache.crunch.contrib,
• org.apache.crunch.contrib.bloomfilter,
• org.apache.crunch.contrib.io.jdbc,
• org.apache.crunch.contrib.text,
• org.apache.crunch.examples,
• org.apache.crunch.fn,
• org.apache.crunch.impl.mem,
• org.apache.crunch.impl.mr,
• org.apache.crunch.io,
• org.apache.crunch.lib,
• org.apache.crunch.lib.join,
• org.apache.crunch.test,
• org.apache.crunch.types,
• org.apache.crunch.types.avro,
• org.apache.crunch.types.writable,
• org.apache.crunch.util

Class Hierarchy

• java.lang.Object
  • org.apache.crunch.contrib.text.AbstractCompositeExtractor<T> (implements org.apache.crunch.contrib.text.Extractor<T>)
  • org.apache.crunch.contrib.text.AbstractSimpleExtractor<T> (implements org.apache.crunch.contrib.text.Extractor<T>)
  • org.apache.crunch.lib.Aggregate
  • org.apache.crunch.lib.Aggregate.PairValueComparator<K,V> (implements java.util.Comparator<T>)
  • org.apache.crunch.fn.Aggregators
  • org.apache.crunch.fn.Aggregators.SimpleAggregator<T> (implements org.apache.crunch.Aggregator<T>)
  • org.apache.crunch.io.At
  • org.apache.crunch.types.avro.Avros
  • org.apache.crunch.types.avro.AvroType<T> (implements org.apache.crunch.types.PType<T>)
  • org.apache.crunch.types.avro.AvroTypeFamily (implements org.apache.crunch.types.PTypeFamily)
  • org.apache.crunch.contrib.bloomfilter.BloomFilterFactory
  • org.apache.crunch.lib.Cartesian
  • org.apache.crunch.lib.Cogroup
  • org.apache.crunch.types.CollectionDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.CombineFn.PairAggregator<V1,V2>
  • org.apache.crunch.CombineFn.QuadAggregator<A,B,C,D>
  • org.apache.crunch.CombineFn.SimpleAggregator<T> (implements org.apache.crunch.CombineFn.Aggregator<T>)
    • org.apache.crunch.CombineFn.FirstNAggregator<V>
    • org.apache.crunch.CombineFn.LastNAggregator<V>
    • org.apache.crunch.CombineFn.MaxBigInts
    • org.apache.crunch.CombineFn.MaxDoubles
    • org.apache.crunch.CombineFn.MaxFloats
    • org.apache.crunch.CombineFn.MaxInts
    • org.apache.crunch.CombineFn.MaxLongs
    • org.apache.crunch.CombineFn.MaxNAggregator<V>
    • org.apache.crunch.CombineFn.MinBigInts
    • org.apache.crunch.CombineFn.MinDoubles
    • org.apache.crunch.CombineFn.MinFloats
    • org.apache.crunch.CombineFn.MinInts
    • org.apache.crunch.CombineFn.MinLongs
    • org.apache.crunch.CombineFn.MinNAggregator<V>
    • org.apache.crunch.CombineFn.StringConcatAggregator
    • org.apache.crunch.CombineFn.SumBigInts
    • org.apache.crunch.CombineFn.SumDoubles
    • org.apache.crunch.CombineFn.SumFloats
    • org.apache.crunch.CombineFn.SumInts
    • org.apache.crunch.CombineFn.SumLongs
  • org.apache.crunch.CombineFn.TripAggregator<A,B,C>
  • org.apache.crunch.CombineFn.TupleNAggregator
  • org.apache.crunch.io.CompositePathIterable<T> (implements java.lang.Iterable<T>)
  • org.apache.hadoop.conf.Configured (implements org.apache.hadoop.conf.Configurable)
    • org.apache.crunch.examples.AverageBytesByIP (implements java.io.Serializable, org.apache.hadoop.util.Tool)
    • org.apache.crunch.util.CrunchTool (implements org.apache.hadoop.util.Tool)
    • org.apache.crunch.lib.join.JoinUtils.AvroPairGroupingComparator<T> (implements org.apache.hadoop.io.RawComparator<T>)
    • org.apache.crunch.examples.SecondarySortExample (implements java.io.Serializable, org.apache.hadoop.util.Tool)
    • org.apache.crunch.examples.TotalBytesByIP (implements java.io.Serializable, org.apache.hadoop.util.Tool)
    • org.apache.crunch.examples.WordAggregationHBase (implements java.io.Serializable, org.apache.hadoop.util.Tool)
    • org.apache.crunch.examples.WordCount (implements java.io.Serializable, org.apache.hadoop.util.Tool)
  • org.apache.crunch.io.CrunchInputs
  • org.apache.crunch.io.CrunchOutputs<K,V>
  • org.apache.crunch.test.CrunchTestSupport
  • org.apache.crunch.contrib.io.jdbc.DataBaseSource<T> (implements org.apache.crunch.Source<T>)
  • org.apache.crunch.test.DebugLogging
  • org.apache.crunch.types.DeepCopier.NoOpDeepCopier<V> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.util.DistCache
  • org.apache.crunch.lib.Distinct
  • org.apache.crunch.DoFn<S,T> (implements java.io.Serializable)
    • org.apache.crunch.lib.Aggregate.TopKFn<K,V>
    • org.apache.crunch.contrib.bloomfilter.BloomFilterFn<S>
    • org.apache.crunch.CombineFn<S,T>
      • org.apache.crunch.lib.Aggregate.TopKCombineFn<K,V>
      • org.apache.crunch.CombineFn.AggregatorCombineFn<K,V>
    • org.apache.crunch.FilterFn<T>
      • org.apache.crunch.FilterFn.AndFn<S>
      • org.apache.crunch.FilterFn.NotFn<S>
      • org.apache.crunch.FilterFn.OrFn<S>
    • org.apache.crunch.lib.join.JoinFn<K,U,V>
      • org.apache.crunch.lib.join.FullOuterJoinFn<K,U,V>
      • org.apache.crunch.lib.join.InnerJoinFn<K,U,V>
      • org.apache.crunch.lib.join.LeftOuterJoinFn<K,U,V>
      • org.apache.crunch.lib.join.RightOuterJoinFn<K,U,V>
    • org.apache.crunch.MapFn<S,T>
      • org.apache.crunch.fn.CompositeMapFn<R,S,T>
      • org.apache.crunch.fn.ExtractKeyFn<K,V>
      • org.apache.crunch.fn.IdentityFn<T>
      • org.apache.crunch.fn.PairMapFn<K,V,S,T>
      • org.apache.crunch.types.PGroupedTableType.PairIterableMapFn<K,V>
    • org.apache.crunch.fn.MapKeysFn<K1,K2,V>
    • org.apache.crunch.fn.MapValuesFn<K,V1,V2>
  • org.junit.rules.ExternalResource (implements org.junit.rules.TestRule)
    • org.apache.crunch.test.TemporaryPath
  • org.apache.crunch.contrib.text.Extractors
  • org.apache.crunch.contrib.text.ExtractorStats
  • org.apache.crunch.fn.FilterFns
  • org.apache.crunch.io.FormatBundle<K> (implements java.io.Serializable)
  • org.apache.crunch.io.From
  • org.apache.crunch.GroupingOptions
  • org.apache.crunch.GroupingOptions.Builder
  • org.apache.hadoop.mapreduce.InputFormat<K,V>
    • org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>
      • org.apache.crunch.types.avro.AvroInputFormat<T>
      • org.apache.crunch.types.avro.AvroUtf8InputFormat
  • org.apache.crunch.lib.Join
  • org.apache.crunch.lib.join.JoinUtils
  • org.apache.crunch.lib.join.JoinUtils.TupleWritableComparator (implements org.apache.hadoop.io.RawComparator<T>)
  • org.apache.crunch.types.MapDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.lib.join.MapsideJoin
  • org.apache.crunch.impl.mem.MemPipeline (implements org.apache.crunch.Pipeline)
  • org.apache.crunch.impl.mr.MRPipeline (implements org.apache.crunch.Pipeline)
  • org.apache.hadoop.mapreduce.OutputFormat<K,V>
    • org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>
      • org.apache.crunch.types.avro.AvroOutputFormat<T>
      • org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<K,V>
        • org.apache.crunch.types.avro.AvroTextOutputFormat<K,V>
  • org.apache.crunch.Pair<K,V> (implements java.lang.Comparable<T>, org.apache.crunch.Tuple)
  • org.apache.crunch.ParallelDoOptions
  • org.apache.crunch.ParallelDoOptions.Builder
  • org.apache.crunch.contrib.text.Parse
  • org.apache.hadoop.mapreduce.Partitioner<KEY,VALUE>
    • org.apache.crunch.lib.join.JoinUtils.AvroIndexedRecordPartitioner<K,V>
    • org.apache.crunch.lib.join.JoinUtils.TupleWritablePartitioner
  • org.apache.crunch.io.PathTargetImpl (implements org.apache.crunch.io.PathTarget)
  • org.apache.crunch.types.PGroupedTableType<K,V> (implements org.apache.crunch.types.PType<T>)
  • org.apache.crunch.PipelineResult
  • org.apache.crunch.PipelineResult.StageResult
  • org.apache.crunch.types.Protos
  • org.apache.crunch.lib.PTables
  • org.apache.crunch.types.PTypes
  • org.apache.crunch.types.PTypeUtils
  • org.apache.crunch.types.avro.ReflectDataFactory
  • org.apache.crunch.lib.Sample
  • org.apache.crunch.lib.SecondarySort
  • org.apache.crunch.io.SequentialFileNamingScheme (implements org.apache.crunch.io.FileNamingScheme)
  • org.apache.crunch.lib.Set
  • org.apache.crunch.lib.Sort
  • org.apache.crunch.lib.Sort.ColumnOrder
  • org.apache.crunch.io.SourceTargetHelper
  • org.apache.crunch.test.TestCounters
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.crunch.CrunchRuntimeException
  • org.apache.crunch.io.To
  • org.apache.crunch.contrib.text.Tokenizer
  • org.apache.crunch.contrib.text.TokenizerFactory (implements java.io.Serializable)
  • org.apache.crunch.contrib.text.TokenizerFactory.Builder
  • org.apache.crunch.Tuple3<V1,V2,V3> (implements org.apache.crunch.Tuple)
  • org.apache.crunch.Tuple4<V1,V2,V3,V4> (implements org.apache.crunch.Tuple)
  • org.apache.crunch.types.TupleDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.types.TupleFactory<T> (implements java.io.Serializable)
  • org.apache.crunch.TupleN (implements org.apache.crunch.Tuple)
  • org.apache.crunch.util.Tuples
  • org.apache.crunch.util.Tuples.PairIterable<S,T> (implements java.lang.Iterable<T>)
  • org.apache.crunch.util.Tuples.QuadIterable<A,B,C,D> (implements java.lang.Iterable<T>)
  • org.apache.crunch.util.Tuples.TripIterable<A,B,C> (implements java.lang.Iterable<T>)
  • org.apache.crunch.util.Tuples.TupleNIterable (implements java.lang.Iterable<T>)
  • org.apache.crunch.types.writable.TupleWritable (implements org.apache.hadoop.io.WritableComparable<T>)
  • org.apache.crunch.types.writable.WritableDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.types.writable.Writables
  • org.apache.crunch.types.writable.WritableType<T,W> (implements org.apache.crunch.types.PType<T>)
  • org.apache.crunch.types.writable.WritableTypeFamily (implements org.apache.crunch.types.PTypeFamily)

Interface Hierarchy

• org.apache.crunch.CombineFn.AggregatorFactory<T>
• org.apache.crunch.Emitter<T>
• org.apache.crunch.io.FileNamingScheme
• org.apache.crunch.io.FileReaderFactory<T>
• org.apache.crunch.io.OutputHandler
• org.apache.crunch.PCollection<S>
  • org.apache.crunch.PGroupedTable<K,V>
  • org.apache.crunch.PTable<K,V>
• org.apache.crunch.Pipeline
• org.apache.crunch.PObject<T>
• org.apache.crunch.types.PTypeFamily
• java.io.Serializable
  • org.apache.crunch.Aggregator<T>
  • org.apache.crunch.CombineFn.Aggregator<T>
  • org.apache.crunch.types.Converter<K,V,S,T>
  • org.apache.crunch.types.DeepCopier<T>
  • org.apache.crunch.contrib.text.Extractor<T>
  • org.apache.crunch.types.PTableType<K,V>
  • org.apache.crunch.types.PType<T>
    • org.apache.crunch.types.PTableType<K,V>
• org.apache.crunch.Source<T>
  • org.apache.crunch.io.ReadableSource<T>
    • org.apache.crunch.io.ReadableSourceTarget<T> (also extends org.apache.crunch.SourceTarget<T>)
  • org.apache.crunch.io.ReadableSourceTarget<T> (also extends org.apache.crunch.io.ReadableSource<T>, org.apache.crunch.SourceTarget<T>)
  • org.apache.crunch.SourceTarget<T> (also extends org.apache.crunch.Target)
    • org.apache.crunch.io.ReadableSourceTarget<T> (also extends org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.TableSourceTarget<K,V> (also extends org.apache.crunch.TableSource<K,V>)
  • org.apache.crunch.TableSource<K,V>
    • org.apache.crunch.TableSourceTarget<K,V> (also extends org.apache.crunch.SourceTarget<T>)
  • org.apache.crunch.TableSourceTarget<K,V> (also extends org.apache.crunch.SourceTarget<T>, org.apache.crunch.TableSource<K,V>)
• org.apache.crunch.Target
  • org.apache.crunch.io.MapReduceTarget
    • org.apache.crunch.io.PathTarget
  • org.apache.crunch.io.PathTarget
  • org.apache.crunch.io.ReadableSourceTarget<T> (also extends org.apache.crunch.io.ReadableSource<T>, org.apache.crunch.SourceTarget<T>)
  • org.apache.crunch.SourceTarget<T> (also extends org.apache.crunch.Source<T>)
    • org.apache.crunch.io.ReadableSourceTarget<T> (also extends org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.TableSourceTarget<K,V> (also extends org.apache.crunch.TableSource<K,V>)
  • org.apache.crunch.TableSourceTarget<K,V> (also extends org.apache.crunch.SourceTarget<T>, org.apache.crunch.TableSource<K,V>)
• org.apache.crunch.Tuple

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.crunch.Target.WriteMode
    • org.apache.crunch.lib.Sort.Order