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

Uses of Package
org.apache.crunch

Packages that use org.apache.crunch

org.apache.crunch
org.apache.crunch.examples
org.apache.crunch.fn
org.apache.crunch.impl.mem
org.apache.crunch.impl.mem.collect
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.io
org.apache.crunch.io.avro
org.apache.crunch.io.hbase
org.apache.crunch.io.impl
org.apache.crunch.io.seq
org.apache.crunch.io.text
org.apache.crunch.lib
org.apache.crunch.lib.join
org.apache.crunch.materialize
org.apache.crunch.test	Provides a collection of test utilities.
org.apache.crunch.tool
org.apache.crunch.types
org.apache.crunch.types.avro
org.apache.crunch.types.writable
org.apache.crunch.util

Classes in org.apache.crunch used by org.apache.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.

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

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.

PipelineResult
Container for the results of a call to run or done on the Pipeline interface that includes details and statistics about the component stages of the data pipeline.

PipelineResult.StageResult

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 org.apache.crunch used by org.apache.crunch.examples

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.

Classes in org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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.

PipelineResult
Container for the results of a call to run or done on the Pipeline interface that includes details and statistics about the component stages of the data pipeline.

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 org.apache.crunch used by org.apache.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.

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

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 org.apache.crunch used by org.apache.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.

PipelineResult
Container for the results of a call to run or done on the Pipeline interface that includes details and statistics about the component stages of the data pipeline.

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 org.apache.crunch used by org.apache.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.

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

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 org.apache.crunch used by org.apache.crunch.impl.mr.emit

Emitter
Interface for writing outputs from a DoFn.

Classes in org.apache.crunch used by org.apache.crunch.impl.mr.exec

PipelineResult
Container for the results of a call to run or done on the Pipeline interface that includes details and statistics about the component stages of the data pipeline.

Classes in org.apache.crunch used by org.apache.crunch.impl.mr.plan

DoFn
Base class for all data processing functions in Crunch.

Pipeline
Manages the state of a pipeline execution.

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 org.apache.crunch used by org.apache.crunch.impl.mr.run

DoFn
Base class for all data processing functions in Crunch.

Classes in org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.crunch.lib.join

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.

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

Classes in org.apache.crunch used by org.apache.crunch.materialize

Pair
A convenience class for two-element Tuples.

Pipeline
Manages the state of a pipeline execution.

Classes in org.apache.crunch used by org.apache.crunch.test

Emitter
Interface for writing outputs from a DoFn.

Classes in org.apache.crunch used by org.apache.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 org.apache.crunch used by org.apache.crunch.types

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 org.apache.crunch used by org.apache.crunch.types.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 org.apache.crunch used by org.apache.crunch.types.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 org.apache.crunch used by org.apache.crunch.util

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.

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.