Uses of Interface
org.apache.crunch.io.ReadableSource

Packages that use ReadableSource

Package	Description
org.apache.crunch.contrib.io.jdbc	Support for reading data from RDBMS using JDBC
org.apache.crunch.impl.dist
org.apache.crunch.io	Data input and output for Pipelines.
org.apache.crunch.io.impl
org.apache.crunch.kafka
org.apache.crunch.types	Common functionality for business object serialization.
org.apache.crunch.types.avro	Business object serialization using Apache Avro.
org.apache.crunch.types.writable	Business object serialization using Hadoop's Writables framework.

Uses of ReadableSource in org.apache.crunch.contrib.io.jdbc

Classes in org.apache.crunch.contrib.io.jdbc that implement ReadableSource

Modifier and Type	Class and Description
class	DataBaseSource<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable> Source from reading from a database via a JDBC connection.

Uses of ReadableSource in org.apache.crunch.impl.dist

Methods in org.apache.crunch.impl.dist that return ReadableSource

Modifier and Type	Method and Description
<T> ReadableSource<T>	DistributedPipeline.getMaterializeSourceTarget(PCollection<T> pcollection) Retrieve a ReadableSourceTarget that provides access to the contents of a PCollection.

Uses of ReadableSource in org.apache.crunch.io

Subinterfaces of ReadableSource in org.apache.crunch.io

Modifier and Type	Interface and Description
interface	ReadableSourceTarget<T> An interface that indicates that a SourceTarget instance can be read into the local client.

Uses of ReadableSource in org.apache.crunch.io.impl

Classes in org.apache.crunch.io.impl with annotations of type with type parameters of type that implement declared as with annotations of type with type parameters of type with annotations of type with annotations of type with type parameters of type that return that return types with arguments of type with parameters of type with type arguments of type that throw with annotations of type with annotations of type with parameters of type with type arguments of type that throw ReadableSource

Modifier and Type	Class and Description
class	org.apache.crunch.io.impl.FileSourceImpl<T>

Uses of ReadableSource in org.apache.crunch.kafka

Classes in org.apache.crunch.kafka that implement ReadableSource

Modifier and Type	Class and Description
class	KafkaSource A Crunch Source that will retrieve events from Kafka given start and end offsets.

Uses of ReadableSource in org.apache.crunch.types

Methods in org.apache.crunch.types that return ReadableSource

Modifier and Type	Method and Description
ReadableSource<T>	PType.createSourceTarget(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, Iterable<T> contents, int parallelism) Returns a ReadableSource that contains the data in the given Iterable.

Uses of ReadableSource in org.apache.crunch.types.avro

Methods in org.apache.crunch.types.avro that return ReadableSource

Modifier and Type	Method and Description
ReadableSource<T>	AvroType.createSourceTarget(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, Iterable<T> contents, int parallelism)

Uses of ReadableSource in org.apache.crunch.types.writable

Methods in org.apache.crunch.types.writable that return ReadableSource

Modifier and Type	Method and Description
ReadableSource<T>	WritableType.createSourceTarget(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, Iterable<T> contents, int parallelism)