|
|||||||||
| 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
PTables. |
|
| 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 | ||||||||