|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PTableType | |
---|---|
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.lib | Joining, sorting, aggregating, and other commonly used functionality. |
org.apache.crunch.types | Common functionality for business object serialization. |
org.apache.crunch.types.avro | Business object serialization using Apache Avro. |
org.apache.crunch.types.writable | Business object serialization using Hadoop's Writables framework. |
Uses of PTableType in org.apache.crunch |
---|
Methods in org.apache.crunch that return PTableType | |
---|---|
PTableType<K,V> |
PTable.getPTableType()
Returns the PTableType of this PTable . |
PTableType<K,V> |
TableSource.getTableType()
|
Methods in org.apache.crunch with parameters of type PTableType | ||
---|---|---|
|
PCollection.parallelDo(DoFn<S,Pair<K,V>> doFn,
PTableType<K,V> type)
Similar to the other parallelDo instance, but returns a
PTable instance instead of a PCollection . |
|
|
PCollection.parallelDo(String name,
DoFn<S,Pair<K,V>> doFn,
PTableType<K,V> type)
Similar to the other parallelDo instance, but returns a
PTable instance instead of a PCollection . |
Uses of PTableType in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type PTableType | ||
---|---|---|
static
|
MemPipeline.typedTableOf(PTableType<S,T> ptype,
Iterable<Pair<S,T>> pairs)
|
|
static
|
MemPipeline.typedTableOf(PTableType<S,T> ptype,
S s,
T t,
Object... more)
|
Uses of PTableType in org.apache.crunch.lib |
---|
Methods in org.apache.crunch.lib with parameters of type PTableType | ||
---|---|---|
static
|
PTables.getDetachedValue(PTableType<K,V> tableType,
Pair<K,V> value)
Create a detached value for a table Pair . |
|
static
|
SecondarySort.sortAndApply(PTable<K,Pair<V1,V2>> input,
DoFn<Pair<K,Iterable<Pair<V1,V2>>>,Pair<U,V>> doFn,
PTableType<U,V> ptype)
Perform a secondary sort on the given PTable instance and then apply a
DoFn to the resulting sorted data to yield an output PTable<U, V> . |
Uses of PTableType in org.apache.crunch.types |
---|
Methods in org.apache.crunch.types that return PTableType | ||
---|---|---|
PTableType<K,V> |
PGroupedTableType.getTableType()
|
|
|
PTypeFamily.tableOf(PType<K> key,
PType<V> value)
|
Constructors in org.apache.crunch.types with parameters of type PTableType | |
---|---|
PGroupedTableType(PTableType<K,V> tableType)
|
Uses of PTableType in org.apache.crunch.types.avro |
---|
Classes in org.apache.crunch.types.avro that implement PTableType | |
---|---|
class |
AvroTableType<K,V>
The implementation of the PTableType interface for Avro-based serialization. |
Methods in org.apache.crunch.types.avro that return PTableType | ||
---|---|---|
|
AvroTypeFamily.tableOf(PType<K> key,
PType<V> value)
|
Uses of PTableType in org.apache.crunch.types.writable |
---|
Methods in org.apache.crunch.types.writable that return PTableType | ||
---|---|---|
|
WritableTypeFamily.tableOf(PType<K> key,
PType<V> value)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |