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

Uses of Interface
org.apache.crunch.Source

Packages that use Source

org.apache.crunch
org.apache.crunch.impl.mem
org.apache.crunch.impl.mr
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.mr.plan
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.tool

Uses of Source in org.apache.crunch

Subinterfaces of Source in org.apache.crunch

interface	SourceTarget<T> An interface for classes that implement both the Source and the Target interfaces.
interface	TableSource<K,V> The interface Source implementations that return a PTable.

Methods in org.apache.crunch with parameters of type Source

<T> PCollection<T>

Pipeline.read(Source<T> source) Converts the given Source into a PCollection that is available to jobs run using this Pipeline instance.

Uses of Source in org.apache.crunch.impl.mem

Methods in org.apache.crunch.impl.mem with parameters of type Source

<T> PCollection<T>

MemPipeline.read(Source<T> source)

Uses of Source in org.apache.crunch.impl.mr

Methods in org.apache.crunch.impl.mr with parameters of type Source

<S> PCollection<S>

MRPipeline.read(Source<S> source)

Uses of Source in org.apache.crunch.impl.mr.collect

Methods in org.apache.crunch.impl.mr.collect that return Source

Source<S>

InputCollection.getSource()

Constructors in org.apache.crunch.impl.mr.collect with parameters of type Source

InputCollection(Source<S> source, MRPipeline pipeline)

Uses of Source in org.apache.crunch.impl.mr.plan

Methods in org.apache.crunch.impl.mr.plan that return Source

Source<?>

DoNode.getSource()

Methods in org.apache.crunch.impl.mr.plan with parameters of type Source

static <S> DoNode

DoNode.createInputNode(Source<S> source)

Uses of Source in org.apache.crunch.io

Subinterfaces of Source in org.apache.crunch.io

interface	ReadableSource<T>
interface	ReadableSourceTarget<T> An interface that indicates that a SourceTarget instance can be read into the local client.

Methods in org.apache.crunch.io that return Source

static <T> Source<T>	From.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType)
static <T> Source<T>	From.avroFile(String pathName, AvroType<T> avroType)
static <T> Source<T>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <T> Source<T>	From.sequenceFile(String pathName, PType<T> ptype)
static Source<String>	From.textFile(org.apache.hadoop.fs.Path path)
static <T> Source<T>	From.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static Source<String>	From.textFile(String pathName)
static <T> Source<T>	From.textFile(String pathName, PType<T> ptype)

Uses of Source in org.apache.crunch.io.avro

Classes in org.apache.crunch.io.avro that implement Source

class	AvroFileSource<T>
class	AvroFileSourceTarget<T>

Uses of Source in org.apache.crunch.io.hbase

Classes in org.apache.crunch.io.hbase that implement Source

class

HBaseSourceTarget

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

Classes in org.apache.crunch.io.impl that implement Source

class	FileSourceImpl<T>
class	FileTableSourceImpl<K,V>
class	ReadableSourcePathTargetImpl<T>
class	ReadableSourceTargetImpl<T>
class	SourcePathTargetImpl<T>
class	SourceTargetImpl<T>
class	TableSourcePathTargetImpl<K,V>
class	TableSourceTargetImpl<K,V>

Constructors in org.apache.crunch.io.impl with parameters of type Source

SourcePathTargetImpl(Source<T> source, PathTarget target)

SourceTargetImpl(Source<T> source, Target target)

Uses of Source in org.apache.crunch.io.seq

Classes in org.apache.crunch.io.seq that implement Source

class	SeqFileSource<T>
class	SeqFileSourceTarget<T>
class	SeqFileTableSource<K,V>
class	SeqFileTableSourceTarget<K,V>

Uses of Source in org.apache.crunch.io.text

Classes in org.apache.crunch.io.text that implement Source

class	TextFileSource<T>
class	TextFileSourceTarget<T>

Uses of Source in org.apache.crunch.tool

Methods in org.apache.crunch.tool with parameters of type Source

<T> PCollection<T>

CrunchTool.read(Source<T> source)