This project has retired. For details please refer to its Attic page.

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.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.lib.Aggregate
  • org.apache.crunch.lib.Aggregate.PairValueComparator<K,V> (implements java.util.Comparator<T>)
  • org.apache.crunch.io.At
  • org.apache.crunch.types.avro.AvroDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>, java.io.Serializable)
    • org.apache.crunch.types.avro.AvroDeepCopier.AvroGenericDeepCopier
    • org.apache.crunch.types.avro.AvroDeepCopier.AvroReflectDeepCopier<T>
    • org.apache.crunch.types.avro.AvroDeepCopier.AvroSpecificDeepCopier<T>
  • org.apache.crunch.types.avro.AvroKeyConverter<K> (implements org.apache.crunch.types.Converter<K,V,S,T>)
  • org.apache.crunch.types.avro.AvroPairConverter<K,V> (implements org.apache.crunch.types.Converter<K,V,S,T>)
  • 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.AvroTableType<K,V> (implements org.apache.crunch.types.PTableType<K,V>)
  • 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.types.avro.SafeAvroSerialization<T> (implements org.apache.hadoop.io.serializer.Serialization<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.test.CrunchTestSupport
  • org.apache.crunch.contrib.io.jdbc.DataBaseSource<T> (implements org.apache.crunch.Source<T>)
  • org.apache.crunch.types.DeepCopier.NoOpDeepCopier<V> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.util.DistCache
  • 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.types.Protos.ExtractKeyFn<M,K>
      • org.apache.crunch.types.PTypes.EnumInputMapper<T>
      • org.apache.crunch.types.PTypes.EnumOutputMapper<T>
      • org.apache.crunch.types.PTypes.JacksonInputMapFn<T>
      • org.apache.crunch.types.PTypes.JacksonOutputMapFn<T>
      • org.apache.crunch.types.PTypes.ProtoInputMapFn<T>
      • org.apache.crunch.types.PTypes.ProtoOutputMapFn<T>
      • org.apache.crunch.types.PTypes.ThriftInputMapFn<T>
      • org.apache.crunch.types.PTypes.ThriftOutputMapFn<T>
    • org.apache.crunch.fn.MapKeysFn<K1,K2,V>
    • org.apache.crunch.fn.MapValuesFn<K,V1,V2>
    • org.apache.crunch.types.Protos.TextToProtoFn<M>
    • org.apache.crunch.lib.Sample.SamplerFn<S>
  • org.junit.rules.ExternalResource (implements org.junit.rules.TestRule)
    • org.apache.crunch.test.TemporaryPath
  • org.apache.crunch.io.From
  • org.apache.crunch.types.writable.GenericArrayWritable<T> (implements org.apache.hadoop.io.Writable)
  • 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.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.types.avro.AvroGroupedTableType<K,V>
    • org.apache.crunch.types.writable.WritableGroupedTableType<K,V>
  • 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.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> (implements java.io.Closeable)
    • org.apache.crunch.types.avro.AvroRecordReader<T>
  • 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
  • org.apache.crunch.types.writable.TextMapWritable<T> (implements org.apache.hadoop.io.Writable)
  • org.apache.crunch.io.To
  • 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.WritablePairConverter<K,V> (implements org.apache.crunch.types.Converter<K,V,S,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.CombineFn.Aggregator<T>
  • org.apache.crunch.types.Converter<K,V,S,T>
  • org.apache.crunch.types.DeepCopier<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.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.Tuple

Enum Hierarchy

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