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.contrib.text, org.apache.crunch.examples, org.apache.crunch.fn, org.apache.crunch.impl, org.apache.crunch.impl.dist, org.apache.crunch.impl.dist.collect, org.apache.crunch.impl.mem, org.apache.crunch.impl.mem.collect, org.apache.crunch.impl.mem.emit, org.apache.crunch.impl.mr, org.apache.crunch.impl.mr.collect, org.apache.crunch.impl.mr.emit, org.apache.crunch.impl.mr.exec, org.apache.crunch.impl.mr.plan, org.apache.crunch.impl.mr.run, org.apache.crunch.impl.spark, org.apache.crunch.impl.spark.collect, org.apache.crunch.impl.spark.fn, org.apache.crunch.impl.spark.serde, org.apache.crunch.io, org.apache.crunch.io.avro, org.apache.crunch.io.avro.trevni, org.apache.crunch.io.hbase, org.apache.crunch.io.impl, org.apache.crunch.io.parquet, org.apache.crunch.io.seq, org.apache.crunch.io.text, org.apache.crunch.lib, org.apache.crunch.lib.join, org.apache.crunch.lib.sort, org.apache.crunch.materialize, org.apache.crunch.materialize.pobject, 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>)
  • scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>, scala.ScalaObject)
    • org.apache.spark.api.java.function.WrappedFunction1<T,R> (implements scala.ScalaObject)
      • org.apache.spark.api.java.function.Function<T,R> (implements java.io.Serializable)
        • org.apache.spark.api.java.function.FlatMapFunction<T,R> (implements scala.ScalaObject)
          • org.apache.crunch.impl.spark.fn.FlatMapDoFn<S,T>
          • org.apache.crunch.impl.spark.fn.FlatMapPairDoFn<K,V,T>
        • org.apache.crunch.impl.spark.fn.InputConverterFunction<K,V,S>
        • org.apache.crunch.impl.spark.fn.MapFunction
        • org.apache.crunch.impl.spark.fn.PairMapFunction<K,V,S>
        • org.apache.crunch.impl.spark.fn.ReduceInputFunction<K,V>
      • org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V> (implements java.io.Serializable)
        • org.apache.crunch.impl.spark.fn.CombineMapsideFunction<K,V>
        • org.apache.crunch.impl.spark.fn.PairFlatMapDoFn<T,K,V>
        • org.apache.crunch.impl.spark.fn.PairFlatMapPairDoFn<K,V,K2,V2>
        • org.apache.crunch.impl.spark.fn.ReduceGroupingFunction
      • org.apache.spark.api.java.function.PairFunction<T,K,V> (implements java.io.Serializable)
        • org.apache.crunch.impl.spark.fn.MapOutputFunction<K,V>
        • org.apache.crunch.impl.spark.fn.OutputConverterFunction<K,V,S>
        • org.apache.crunch.impl.spark.fn.PairMapIterableFunction<K,V,S,T>
        • org.apache.crunch.impl.spark.fn.PartitionedMapOutputFunction<K,V>
        • org.apache.crunch.impl.spark.collect.ToByteArrayFunction
  • com.google.common.util.concurrent.AbstractFuture<V> (implements com.google.common.util.concurrent.ListenableFuture<V>)
    • org.apache.crunch.impl.mr.exec.MRExecutor (implements org.apache.crunch.impl.mr.MRPipelineExecution)
    • org.apache.crunch.impl.spark.SparkRuntime (implements org.apache.crunch.PipelineExecution)
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • org.apache.crunch.materialize.MaterializableMap<K,V>
  • 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.io.hbase.AtHBase
  • org.apache.crunch.io.avro.AvroFileReaderFactory<T> (implements org.apache.crunch.io.FileReaderFactory<T>)
  • org.apache.crunch.io.parquet.AvroParquetFileSource.Builder<T>
  • org.apache.crunch.types.avro.Avros
  • org.apache.crunch.impl.spark.serde.AvroSerDe<T> (implements org.apache.crunch.impl.spark.serde.SerDe<T>)
  • 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.join.BloomFilterJoinStrategy<K,U,V> (implements org.apache.crunch.lib.join.JoinStrategy<K,U,V>)
  • org.apache.crunch.impl.spark.ByteArray (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.crunch.impl.spark.IntByteArray (implements java.io.Serializable)
  • org.apache.crunch.CachingOptions
  • org.apache.crunch.CachingOptions.Builder
  • org.apache.crunch.impl.mr.exec.CappedExponentialCounter
  • org.apache.crunch.lib.Cartesian
  • org.apache.crunch.lib.Channels
  • org.apache.crunch.lib.Cogroup
  • org.apache.crunch.types.CollectionDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • 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 java.io.Serializable, org.apache.hadoop.util.Tool)
      • org.apache.crunch.examples.SortExample
    • org.apache.crunch.lib.join.JoinUtils.AvroPairGroupingComparator<T> (implements org.apache.hadoop.io.RawComparator<T>)
    • org.apache.crunch.lib.sort.ReverseAvroComparator<T> (implements org.apache.hadoop.io.RawComparator<T>)
    • org.apache.crunch.lib.sort.ReverseWritableComparator<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.impl.spark.CounterAccumulatorParam (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.crunch.io.CrunchInputs
  • org.apache.crunch.impl.spark.fn.CrunchIterable<S,T> (implements java.lang.Iterable<T>)
  • org.apache.crunch.impl.mr.exec.CrunchJobHooks
  • org.apache.crunch.impl.mr.exec.CrunchJobHooks.CompletionHook (implements org.apache.crunch.hadoop.mapreduce.lib.jobcontrol.CrunchControlledJob.Hook)
  • org.apache.crunch.impl.mr.exec.CrunchJobHooks.PrepareHook (implements org.apache.crunch.hadoop.mapreduce.lib.jobcontrol.CrunchControlledJob.Hook)
  • org.apache.crunch.io.CrunchOutputs<K,V>
  • org.apache.crunch.test.CrunchTestSupport
  • org.apache.crunch.test.DebugLogging
  • org.apache.crunch.types.DeepCopier.NoOpDeepCopier<V> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.lib.join.DefaultJoinStrategy<K,U,V> (implements org.apache.crunch.lib.join.JoinStrategy<K,U,V>)
  • org.apache.crunch.util.DelegatingReadableData<S,T> (implements org.apache.crunch.ReadableData<T>)
  • org.apache.crunch.util.DistCache
  • org.apache.crunch.lib.Distinct
  • org.apache.crunch.impl.dist.DistributedPipeline (implements org.apache.crunch.Pipeline)
    • org.apache.crunch.impl.mr.MRPipeline
    • org.apache.crunch.impl.spark.SparkPipeline
  • 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.FilterFn<T>
    • 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.lib.sort.SortFns.AvroGenericFn<V>
      • org.apache.crunch.lib.sort.SortFns.SingleKeyFn<V,K>
      • org.apache.crunch.lib.sort.SortFns.TupleKeyFn<V,K>
  • org.apache.crunch.util.DoFnIterator<S,T> (implements java.util.Iterator<E>)
  • org.apache.crunch.impl.mr.plan.DoNode
  • org.apache.crunch.impl.mr.plan.DotfileWriter
  • 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.io.impl.FileSourceImpl<T> (implements org.apache.crunch.Source<T>)
    • org.apache.crunch.io.avro.AvroFileSource<T> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.parquet.AvroParquetFileSource<T> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.contrib.io.jdbc.DataBaseSource<T>
    • org.apache.crunch.io.impl.FileTableSourceImpl<K,V> (implements org.apache.crunch.TableSource<K,V>)
      • org.apache.crunch.io.seq.SeqFileTableSource<K,V> (implements org.apache.crunch.io.ReadableSource<T>)
      • org.apache.crunch.io.text.TextFileTableSource<K,V> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.hbase.HFileSource (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.text.NLineFileSource<T> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.seq.SeqFileSource<T> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.text.TextFileSource<T> (implements org.apache.crunch.io.ReadableSource<T>)
    • org.apache.crunch.io.avro.trevni.TrevniKeySource<T> (implements org.apache.crunch.io.ReadableSource<T>)
  • org.apache.crunch.io.impl.FileTargetImpl (implements org.apache.crunch.io.PathTarget)
    • org.apache.crunch.io.avro.AvroFileTarget
    • org.apache.crunch.io.parquet.AvroParquetFileTarget
    • org.apache.crunch.io.avro.AvroPathPerKeyTarget
    • org.apache.crunch.io.hbase.HFileTarget
    • org.apache.crunch.io.seq.SeqFileTarget
    • org.apache.crunch.io.text.TextFileTarget
    • org.apache.crunch.io.avro.trevni.TrevniKeyTarget
  • org.apache.crunch.fn.FilterFns
  • org.apache.crunch.io.FormatBundle<K> (implements org.apache.hadoop.conf.Configurable, java.io.Serializable, org.apache.hadoop.io.Writable)
  • org.apache.crunch.io.From
  • org.apache.crunch.io.hbase.FromHBase
  • org.apache.crunch.GroupingOptions (implements java.io.Serializable)
  • org.apache.crunch.GroupingOptions.Builder
  • org.apache.crunch.impl.spark.GuavaUtils
  • org.apache.crunch.io.hbase.HBaseData (implements org.apache.crunch.ReadableData<T>)
  • org.apache.crunch.io.hbase.HBaseTarget (implements org.apache.crunch.io.MapReduceTarget)
    • org.apache.crunch.io.hbase.HBaseSourceTarget (implements org.apache.crunch.io.ReadableSourceTarget<T>, org.apache.crunch.TableSource<K,V>)
  • org.apache.crunch.io.hbase.HFileReaderFactory (implements org.apache.crunch.io.FileReaderFactory<T>)
  • org.apache.crunch.io.hbase.HFileUtils
  • org.apache.crunch.contrib.io.jdbc.IdentifiableName (implements org.apache.hadoop.mapreduce.lib.db.DBWritable, org.apache.hadoop.io.Writable)
  • org.apache.crunch.impl.mem.emit.InMemoryEmitter<T> (implements org.apache.crunch.Emitter<T>)
  • org.apache.hadoop.mapreduce.InputFormat<K,V>
    • org.apache.crunch.impl.mr.run.CrunchInputFormat<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.hadoop.mapreduce.lib.input.CombineFileInputFormat<K,V>
        • org.apache.crunch.impl.mr.run.CrunchCombineFileInputFormat<K,V>
      • org.apache.crunch.io.hbase.HFileInputFormat
  • org.apache.crunch.impl.mr.emit.IntermediateEmitter (implements org.apache.crunch.Emitter<T>)
  • 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.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
    • org.apache.crunch.impl.mr.run.CrunchMapper
  • org.apache.crunch.lib.Mapred
  • org.apache.crunch.lib.Mapreduce
  • org.apache.crunch.lib.join.MapsideJoinStrategy<K,U,V> (implements org.apache.crunch.lib.join.JoinStrategy<K,U,V>)
  • org.apache.crunch.materialize.MaterializableIterable<E> (implements java.lang.Iterable<T>)
  • org.apache.crunch.impl.mem.collect.MemCollection<S> (implements org.apache.crunch.PCollection<S>)
    • org.apache.crunch.impl.mem.collect.MemTable<K,V> (implements org.apache.crunch.PTable<K,V>)
  • org.apache.crunch.impl.mem.MemPipeline (implements org.apache.crunch.Pipeline)
  • org.apache.crunch.impl.mr.collect.MRCollectionFactory (implements org.apache.crunch.impl.dist.collect.PCollectionFactory)
  • org.apache.crunch.impl.mr.plan.MSCROutputHandler (implements org.apache.crunch.io.OutputHandler)
  • org.apache.crunch.impl.mr.plan.MSCRPlanner
  • org.apache.crunch.impl.mr.emit.MultipleOutputEmitter<T,K,V> (implements org.apache.crunch.Emitter<T>)
  • org.apache.crunch.lib.join.OneToManyJoin
  • org.apache.crunch.impl.mr.emit.OutputEmitter<T,K,V> (implements org.apache.crunch.Emitter<T>)
  • 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.crunch.types.avro.AvroPathPerKeyOutputFormat<T>
      • org.apache.crunch.io.hbase.HFileOutputFormatForCrunch
      • org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<K,V>
        • org.apache.crunch.types.avro.AvroTextOutputFormat<K,V>
      • org.apache.crunch.io.avro.trevni.TrevniOutputFormat<T>
  • org.apache.crunch.Pair<K,V> (implements java.lang.Comparable<T>, java.io.Serializable, 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
    • org.apache.crunch.lib.join.JoinUtils.TupleWritablePartitioner
    • org.apache.crunch.lib.sort.TotalOrderPartitioner<K,V> (implements org.apache.hadoop.conf.Configurable)
  • org.apache.spark.Partitioner (implements scala.ScalaObject, scala.Serializable)
    • org.apache.crunch.impl.spark.SparkPartitioner
  • org.apache.crunch.util.PartitionUtils
  • org.apache.crunch.impl.dist.collect.PCollectionImpl<S> (implements org.apache.crunch.PCollection<S>)
    • org.apache.crunch.impl.dist.collect.BaseDoCollection<S>
      • org.apache.crunch.impl.mr.collect.DoCollection<S> (implements org.apache.crunch.impl.dist.collect.MRCollection)
      • org.apache.crunch.impl.spark.collect.DoCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseGroupedTable<K,V> (implements org.apache.crunch.PGroupedTable<K,V>)
      • org.apache.crunch.impl.mr.collect.PGroupedTableImpl<K,V> (implements org.apache.crunch.impl.dist.collect.MRCollection)
      • org.apache.crunch.impl.spark.collect.PGroupedTableImpl<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseInputCollection<S>
      • org.apache.crunch.impl.mr.collect.InputCollection<S> (implements org.apache.crunch.impl.dist.collect.MRCollection)
      • org.apache.crunch.impl.spark.collect.InputCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseUnionCollection<S>
      • org.apache.crunch.impl.mr.collect.UnionCollection<S>
      • org.apache.crunch.impl.spark.collect.UnionCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.EmptyPCollection<T>
      • org.apache.crunch.impl.spark.collect.EmptyPCollection<T> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.PTableBase<K,V> (implements org.apache.crunch.PTable<K,V>)
      • org.apache.crunch.impl.dist.collect.BaseDoTable<K,V> (implements org.apache.crunch.PTable<K,V>)
        • org.apache.crunch.impl.mr.collect.DoTable<K,V> (implements org.apache.crunch.impl.dist.collect.MRCollection)
        • org.apache.crunch.impl.spark.collect.DoTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.BaseInputTable<K,V>
        • org.apache.crunch.impl.mr.collect.InputTable<K,V> (implements org.apache.crunch.impl.dist.collect.MRCollection)
        • org.apache.crunch.impl.spark.collect.InputTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.BaseUnionTable<K,V>
        • org.apache.crunch.impl.mr.collect.UnionTable<K,V>
        • org.apache.crunch.impl.spark.collect.UnionTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.EmptyPTable<K,V>
        • org.apache.crunch.impl.spark.collect.EmptyPTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
  • org.apache.crunch.types.PGroupedTableType<K,V> (implements org.apache.crunch.types.PType<T>)
  • org.apache.crunch.types.PGroupedTableType.HoldLastIterator<V> (implements java.util.Iterator<E>)
  • org.apache.crunch.types.PGroupedTableType.PTypeIterable<V> (implements java.lang.Iterable<T>)
  • org.apache.crunch.PipelineResult
  • org.apache.crunch.PipelineResult.StageResult
  • org.apache.crunch.impl.mr.plan.PlanningParameters
  • org.apache.crunch.materialize.pobject.PObjectImpl<S,T> (implements org.apache.crunch.PObject<T>)
    • org.apache.crunch.materialize.pobject.CollectionPObject<S>
    • org.apache.crunch.materialize.pobject.FirstElementPObject<T>
    • org.apache.crunch.materialize.pobject.MapPObject<K,V>
  • org.apache.crunch.types.Protos
  • org.apache.crunch.lib.PTables
  • org.apache.crunch.types.PTypes
  • org.apache.crunch.types.PTypeUtils
  • org.apache.crunch.io.impl.ReadableDataImpl<T> (implements org.apache.crunch.ReadableData<T>)
    • org.apache.crunch.io.parquet.AvroParquetReadableData<T>
    • org.apache.crunch.io.avro.AvroReadableData<T>
    • org.apache.crunch.io.hbase.HFileReadableData
    • org.apache.crunch.io.seq.SeqFileReadableData<T>
    • org.apache.crunch.io.text.TextReadableData<T>
    • org.apache.crunch.io.avro.trevni.TrevniReadableData<T>
  • org.apache.crunch.io.impl.ReadableSourceTargetImpl<T> (implements org.apache.crunch.io.ReadableSourceTarget<T>)
  • org.apache.hadoop.mapreduce.RecordWriter<K,V>
    • org.apache.crunch.io.avro.trevni.TrevniRecordWriter<T>
  • org.apache.hadoop.mapreduce.Reducer<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
    • org.apache.crunch.impl.mr.run.CrunchReducer
      • org.apache.crunch.impl.mr.run.CrunchCombiner
  • org.apache.crunch.types.avro.ReflectDataFactory (implements org.apache.crunch.types.avro.ReaderWriterFactory)
  • org.apache.crunch.impl.mr.run.RTNode (implements java.io.Serializable)
  • org.apache.crunch.impl.mr.run.RuntimeParameters
  • org.apache.crunch.lib.Sample
  • org.apache.crunch.lib.SecondarySort
  • org.apache.crunch.io.seq.SeqFileReaderFactory<T> (implements org.apache.crunch.io.FileReaderFactory<T>)
  • org.apache.crunch.io.SequentialFileNamingScheme (implements org.apache.crunch.io.FileNamingScheme)
  • org.apache.crunch.lib.Set
  • org.apache.crunch.lib.Shard
  • org.apache.crunch.lib.join.ShardedJoinStrategy<K,U,V> (implements org.apache.crunch.lib.join.JoinStrategy<K,U,V>)
  • org.apache.crunch.impl.SingleUseIterable<T> (implements java.lang.Iterable<T>)
  • org.apache.crunch.lib.Sort
  • org.apache.crunch.lib.Sort.ColumnOrder
  • org.apache.crunch.lib.sort.SortFns
  • org.apache.crunch.lib.sort.SortFns.KeyExtraction<V>
  • org.apache.crunch.io.impl.SourcePathTargetImpl<T> (implements org.apache.crunch.io.PathTarget)
    • org.apache.crunch.io.impl.ReadableSourcePathTargetImpl<T> (implements org.apache.crunch.io.ReadableSourceTarget<T>)
      • org.apache.crunch.io.avro.AvroFileSourceTarget<T>
      • org.apache.crunch.io.parquet.AvroParquetFileSourceTarget<T>
      • org.apache.crunch.io.seq.SeqFileSourceTarget<T>
      • org.apache.crunch.io.seq.SeqFileTableSourceTarget<K,V> (implements org.apache.crunch.TableSourceTarget<K,V>)
      • org.apache.crunch.io.text.TextFileSourceTarget<T>
      • org.apache.crunch.io.text.TextFileTableSourceTarget<K,V> (implements org.apache.crunch.TableSourceTarget<K,V>)
      • org.apache.crunch.io.avro.trevni.TrevniKeySourceTarget<T>
    • org.apache.crunch.io.impl.TableSourcePathTargetImpl<K,V> (implements org.apache.crunch.TableSource<K,V>)
  • org.apache.crunch.io.SourceTargetHelper
  • org.apache.crunch.impl.spark.collect.SparkCollectFactory (implements org.apache.crunch.impl.dist.collect.PCollectionFactory)
  • org.apache.crunch.impl.spark.SparkComparator (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.crunch.impl.spark.SparkRuntimeContext (implements java.io.Serializable)
  • org.apache.crunch.io.impl.TableSourceTargetImpl<K,V> (implements org.apache.crunch.TableSource<K,V>)
  • org.apache.crunch.test.TestCounters
  • org.apache.crunch.io.text.TextFileReaderFactory<T> (implements org.apache.crunch.io.FileReaderFactory<T>)
  • 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.io.hbase.ToHBase
  • 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.io.avro.trevni.TrevniFileReaderFactory<T> (implements org.apache.crunch.io.FileReaderFactory<T>)
  • org.apache.crunch.Tuple3<V1,V2,V3> (implements org.apache.crunch.Tuple)
    • org.apache.crunch.Tuple3.Collect<V1,V2,V3>
  • org.apache.crunch.Tuple4<V1,V2,V3,V4> (implements org.apache.crunch.Tuple)
    • org.apache.crunch.Tuple4.Collect<V1,V2,V3,V4>
  • 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.Union
  • org.apache.crunch.types.UnionDeepCopier (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.util.UnionReadableData<T> (implements org.apache.crunch.ReadableData<T>)
  • org.apache.crunch.types.writable.UnionWritable (implements org.apache.hadoop.io.WritableComparable<T>)
  • com.google.common.collect.UnmodifiableIterator<E> (implements java.util.Iterator<E>)
    • org.apache.crunch.io.impl.AutoClosingIterator<T> (implements java.io.Closeable)
  • org.apache.hadoop.io.WritableComparator (implements org.apache.hadoop.io.RawComparator<T>)
    • org.apache.crunch.lib.sort.TupleWritableComparator (implements org.apache.hadoop.conf.Configurable)
  • org.apache.crunch.types.writable.WritableDeepCopier<T> (implements org.apache.crunch.types.DeepCopier<T>)
  • org.apache.crunch.types.writable.Writables
  • org.apache.crunch.impl.spark.serde.WritableSerDe (implements org.apache.crunch.impl.spark.serde.SerDe<T>)
  • 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.Emitter<T>
• org.apache.crunch.io.FileNamingScheme
• org.apache.crunch.io.FileReaderFactory<T>
• java.util.concurrent.Future<V>
  • com.google.common.util.concurrent.ListenableFuture<V>
    • org.apache.crunch.impl.mr.MRPipelineExecution
    • org.apache.crunch.PipelineExecution
      • org.apache.crunch.impl.mr.MRPipelineExecution
  • org.apache.crunch.impl.mr.MRPipelineExecution
  • org.apache.crunch.PipelineExecution
    • org.apache.crunch.impl.mr.MRPipelineExecution
• org.apache.crunch.impl.dist.collect.MRCollection
• org.apache.crunch.impl.mr.MRJob
• 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.impl.dist.collect.PCollectionFactory
• org.apache.crunch.impl.dist.collect.PCollectionImpl.Visitor
• org.apache.crunch.Pipeline
• org.apache.crunch.PObject<T>
• org.apache.crunch.types.PTypeFamily
• org.apache.crunch.types.avro.ReaderWriterFactory
• java.io.Serializable
  • org.apache.crunch.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.lib.join.JoinStrategy<K,U,V>
  • org.apache.crunch.types.PTableType<K,V>
  • org.apache.crunch.types.PType<T>
    • org.apache.crunch.types.PTableType<K,V>
  • org.apache.crunch.ReadableData<T>
  • org.apache.crunch.impl.spark.serde.SerDe<T>
  • org.apache.crunch.lib.join.ShardedJoinStrategy.ShardingStrategy<K>
• 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.impl.spark.SparkCollection
• 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.PipelineExecution.Status
    • org.apache.crunch.impl.mr.MRJob.State
    • org.apache.crunch.impl.mr.run.NodeContext
    • org.apache.crunch.lib.Sort.Order
    • org.apache.crunch.lib.join.JoinType
    • org.apache.crunch.types.avro.AvroType.AvroRecordType
    • org.apache.crunch.types.avro.AvroMode (implements org.apache.crunch.types.avro.ReaderWriterFactory)