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

Uses of Interface
org.apache.crunch.TableSource

Packages that use TableSource

org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.impl.dist
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mem	In-memory Pipeline implementation for rapid prototyping and testing.
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.spark.collect
org.apache.crunch.io	Data input and output for Pipelines.
org.apache.crunch.io.hbase
org.apache.crunch.io.impl
org.apache.crunch.io.seq
org.apache.crunch.io.text
org.apache.crunch.util	An assorted set of utilities.

Uses of TableSource in org.apache.crunch

Subinterfaces of TableSource in org.apache.crunch

interface

TableSourceTarget<K,V> An interface for classes that implement both the TableSource and the Target interfaces.

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

<K,V> PTable<K,V>

Pipeline.read(TableSource<K,V> tableSource) A version of the read method for TableSource instances that map to PTables.

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

Methods in org.apache.crunch.impl.dist with parameters of type TableSource

<K,V> PTable<K,V>

DistributedPipeline.read(TableSource<K,V> source)

Uses of TableSource in org.apache.crunch.impl.dist.collect

Fields in org.apache.crunch.impl.dist.collect declared as TableSource

protected TableSource<K,V>

BaseInputTable.source

Methods in org.apache.crunch.impl.dist.collect that return TableSource

TableSource<K,V>

BaseInputTable.getSource()

Methods in org.apache.crunch.impl.dist.collect with parameters of type TableSource

<K,V> BaseInputTable<K,V>

PCollectionFactory.createInputTable(TableSource<K,V> source, DistributedPipeline distributedPipeline)

Constructors in org.apache.crunch.impl.dist.collect with parameters of type TableSource

BaseInputTable(TableSource<K,V> source, DistributedPipeline pipeline)

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

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

<K,V> PTable<K,V>

MemPipeline.read(TableSource<K,V> source)

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

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

<K,V> BaseInputTable<K,V>

MRCollectionFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline)

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

InputTable(TableSource<K,V> source, MRPipeline pipeline)

Uses of TableSource in org.apache.crunch.impl.spark.collect

Methods in org.apache.crunch.impl.spark.collect with parameters of type TableSource

<K,V> BaseInputTable<K,V>

SparkCollectFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline)

Constructors in org.apache.crunch.impl.spark.collect with parameters of type TableSource

InputTable(TableSource<K,V> source, DistributedPipeline pipeline)

Uses of TableSource in org.apache.crunch.io

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

static <K,V> TableSource<K,V>	From.formattedFile(org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<?,?>> formatClass, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
static <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> TableSource<K,V>	From.formattedFile(org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>> formatClass, Class<K> keyClass, Class<V> valueClass) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat<K, V> implementations not covered by the provided TableSource and Source factory methods.
static <K,V> TableSource<K,V>	From.formattedFile(String pathName, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<?,?>> formatClass, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
static <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> TableSource<K,V>	From.formattedFile(String pathName, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>> formatClass, Class<K> keyClass, Class<V> valueClass) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat<K, V> implementations not covered by the provided TableSource and Source factory methods.
static <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, Class<K> keyClass, Class<V> valueClass) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given Path.
static <K,V> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given Path.
static <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> TableSource<K,V>	From.sequenceFile(String pathName, Class<K> keyClass, Class<V> valueClass) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given path name.
static <K,V> TableSource<K,V>	From.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given path name.

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

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

class

HBaseSourceTarget

Methods in org.apache.crunch.io.hbase that return TableSource

static TableSource<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>	FromHBase.table(String table)
static TableSource<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>	FromHBase.table(String table, org.apache.hadoop.hbase.client.Scan scan)

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

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

class	FileTableSourceImpl<K,V>
class	TableSourcePathTargetImpl<K,V>
class	TableSourceTargetImpl<K,V>

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

TableSourcePathTargetImpl(TableSource<K,V> source, PathTarget target)

TableSourcePathTargetImpl(TableSource<K,V> source, PathTarget target, FileNamingScheme fileNamingScheme)

TableSourceTargetImpl(TableSource<K,V> source, Target target)

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

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

class	SeqFileTableSource<K,V> A TableSource that uses SequenceFileInputFormat to read the input file.
class	SeqFileTableSourceTarget<K,V>

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

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

class	TextFileTableSource<K,V> A Source that uses the KeyValueTextInputFormat to process input text.
class	TextFileTableSourceTarget<K,V> A TableSource and SourceTarget implementation that uses the KeyValueTextInputFormat and TextOutputFormat to support reading and writing text files as PTable instances using a tab separator for the keys and the values.

Uses of TableSource in org.apache.crunch.util

Methods in org.apache.crunch.util with parameters of type TableSource

<K,V> PTable<K,V>

CrunchTool.read(TableSource<K,V> tableSource)