|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TableSource | |
---|---|
org.apache.crunch | Client-facing API and core abstractions. |
org.apache.crunch.impl.mem | In-memory Pipeline implementation for rapid prototyping and testing. |
org.apache.crunch.impl.mr | A Pipeline implementation that runs on Hadoop MapReduce. |
org.apache.crunch.io | Data input and output for Pipelines. |
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 | ||
---|---|---|
|
Pipeline.read(TableSource<K,V> tableSource)
A version of the read method for TableSource instances that map to
PTable s. |
Uses of TableSource in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type TableSource | ||
---|---|---|
|
MemPipeline.read(TableSource<K,V> source)
|
Uses of TableSource in org.apache.crunch.impl.mr |
---|
Methods in org.apache.crunch.impl.mr with parameters of type TableSource | ||
---|---|---|
|
MRPipeline.read(TableSource<K,V> source)
|
Uses of TableSource in org.apache.crunch.io |
---|
Methods in org.apache.crunch.io that return TableSource | ||
---|---|---|
static
|
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
|
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
|
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
|
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
|
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
|
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
|
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
|
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.util |
---|
Methods in org.apache.crunch.util with parameters of type TableSource | ||
---|---|---|
|
CrunchTool.read(TableSource<K,V> tableSource)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |