Overview
Package
Class
Use
Tree
Deprecated
Index
PREV NEXT
FRAMES
NO FRAMES
All Classes
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.
HBaseTypes
org.apache.crunch.io.hbase.
HBaseValueConverter
<V> (implements org.apache.crunch.types.
Converter
<K,V,S,T>)
org.apache.crunch.io.hbase.
HFileReaderFactory
(implements org.apache.crunch.io.
FileReaderFactory
<T>)
org.apache.crunch.io.hbase.
HFileUtils
org.apache.crunch.io.hbase.
HFileUtils.KeyValueComparator
(implements org.apache.hadoop.io.RawComparator<T>)
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.
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.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.util.
UnionReadableData
<T> (implements org.apache.crunch.
ReadableData
<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.
AvroMode
(implements org.apache.crunch.types.avro.
ReaderWriterFactory
)
Overview
Package
Class
Use
Tree
Deprecated
Index
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2014
The Apache Software Foundation
. All Rights Reserved.