Uses of Package
com.cloudera.crunch

Packages that use com.cloudera.crunch

com.cloudera.crunch
com.cloudera.crunch.fn
com.cloudera.crunch.impl.mem
com.cloudera.crunch.impl.mem.collect
com.cloudera.crunch.impl.mr
com.cloudera.crunch.impl.mr.collect
com.cloudera.crunch.impl.mr.emit
com.cloudera.crunch.impl.mr.plan
com.cloudera.crunch.impl.mr.run
com.cloudera.crunch.io
com.cloudera.crunch.io.avro
com.cloudera.crunch.io.hbase
com.cloudera.crunch.io.impl
com.cloudera.crunch.io.seq
com.cloudera.crunch.io.text
com.cloudera.crunch.lib
com.cloudera.crunch.materialize
com.cloudera.crunch.tool
com.cloudera.crunch.type
com.cloudera.crunch.type.avro
com.cloudera.crunch.type.writable
com.cloudera.crunch.util

Classes in com.cloudera.crunch used by com.cloudera.crunch

CombineFn
A special DoFn implementation that converts an Iterable of values into a single value.

CombineFn.Aggregator

CombineFn.AggregatorFactory
Interface for constructing new aggregator instances.

DoFn
Base class for all data processing functions in Crunch.

Emitter
Interface for writing outputs from a DoFn.

FilterFn
A DoFn for the common case of filtering the members of a PCollection based on a boolean condition.

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

GroupingOptions.Builder
Builder class for creating GroupingOptions instances.

Pair
A convenience class for two-element Tuples.

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

PGroupedTable
The Crunch representation of a grouped PTable.

Pipeline
Manages the state of a pipeline execution.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Tuple
A fixed-size collection of Objects, used in Crunch for representing joins between PCollections.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.

Classes in com.cloudera.crunch used by com.cloudera.crunch.fn

DoFn
Base class for all data processing functions in Crunch.

Emitter
Interface for writing outputs from a DoFn.

MapFn
A DoFn for the common case of emitting exactly one value for each input record.

Pair
A convenience class for two-element Tuples.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mem

Pair
A convenience class for two-element Tuples.

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

Pipeline
Manages the state of a pipeline execution.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mem.collect

DoFn
Base class for all data processing functions in Crunch.

FilterFn
A DoFn for the common case of filtering the members of a PCollection based on a boolean condition.

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

Pair
A convenience class for two-element Tuples.

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

PGroupedTable
The Crunch representation of a grouped PTable.

Pipeline
Manages the state of a pipeline execution.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mr

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

Pipeline
Manages the state of a pipeline execution.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mr.collect

CombineFn
A special DoFn implementation that converts an Iterable of values into a single value.

DoFn
Base class for all data processing functions in Crunch.

FilterFn
A DoFn for the common case of filtering the members of a PCollection based on a boolean condition.

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

Pair
A convenience class for two-element Tuples.

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

PGroupedTable
The Crunch representation of a grouped PTable.

Pipeline
Manages the state of a pipeline execution.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mr.emit

Emitter
Interface for writing outputs from a DoFn.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mr.plan

DoFn
Base class for all data processing functions in Crunch.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.impl.mr.run

DoFn
Base class for all data processing functions in Crunch.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io.avro

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io.hbase

Pair
A convenience class for two-element Tuples.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io.impl

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io.seq

Pair
A convenience class for two-element Tuples.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.io.text

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.lib

CombineFn
A special DoFn implementation that converts an Iterable of values into a single value.

DoFn
Base class for all data processing functions in Crunch.

Emitter
Interface for writing outputs from a DoFn.

Pair
A convenience class for two-element Tuples.

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.

Classes in com.cloudera.crunch used by com.cloudera.crunch.materialize

Pipeline
Manages the state of a pipeline execution.

Classes in com.cloudera.crunch used by com.cloudera.crunch.tool

PCollection
A representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.

PTable
A sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.

Source
A Source represents an input data set that is an input to one or more MapReduce jobs.

TableSource
The interface Source implementations that return a PTable.

Target
A Target represents the output destination of a Crunch job.

Classes in com.cloudera.crunch used by com.cloudera.crunch.type

DoFn
Base class for all data processing functions in Crunch.

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

MapFn
A DoFn for the common case of emitting exactly one value for each input record.

Pair
A convenience class for two-element Tuples.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

Tuple
A fixed-size collection of Objects, used in Crunch for representing joins between PCollections.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.

Classes in com.cloudera.crunch used by com.cloudera.crunch.type.avro

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

MapFn
A DoFn for the common case of emitting exactly one value for each input record.

Pair
A convenience class for two-element Tuples.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

Tuple
A fixed-size collection of Objects, used in Crunch for representing joins between PCollections.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.

Classes in com.cloudera.crunch used by com.cloudera.crunch.type.writable

GroupingOptions
Options that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting of keys is performed.

MapFn
A DoFn for the common case of emitting exactly one value for each input record.

Pair
A convenience class for two-element Tuples.

SourceTarget
An interface for classes that implement both the Source and the Target interfaces.

Tuple
A fixed-size collection of Objects, used in Crunch for representing joins between PCollections.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.

Classes in com.cloudera.crunch used by com.cloudera.crunch.util

DoFn
Base class for all data processing functions in Crunch.

MapFn
A DoFn for the common case of emitting exactly one value for each input record.

Pair
A convenience class for two-element Tuples.

Tuple3
A convenience class for three-element Tuples.

Tuple4
A convenience class for four-element Tuples.

TupleN
A Tuple instance for an arbitrary number of values.