|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of TableSource in org.apache.crunch |
---|
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.impl.mr.collect |
---|
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.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)
|
|
static
|
From.formattedFile(String path,
Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass,
PType<K> keyType,
PType<V> valueType)
|
|
static
|
From.sequenceFile(org.apache.hadoop.fs.Path path,
PType<K> keyType,
PType<V> valueType)
|
|
static
|
From.sequenceFile(String pathName,
PType<K> keyType,
PType<V> valueType)
|
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)
|
|
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>
|
class |
SeqFileTableSourceTarget<K,V>
|
Uses of TableSource in org.apache.crunch.tool |
---|
Methods in org.apache.crunch.tool with parameters of type TableSource | ||
---|---|---|
|
CrunchTool.read(TableSource<K,V> tableSource)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |