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

Uses of Class
org.apache.crunch.types.PGroupedTableType

Packages that use PGroupedTableType

org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mr.plan
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.fn
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.
org.apache.crunch.types	Common functionality for business object serialization.

Uses of PGroupedTableType in org.apache.crunch

Methods in org.apache.crunch that return PGroupedTableType

PGroupedTableType<K,V>

PGroupedTable.getGroupedTableType() Return the PGroupedTableType containing serialization information for this PGroupedTable.

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

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

protected PGroupedTableType<K,V>

BaseGroupedTable.ptype

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

PGroupedTableType<K,V>

BaseGroupedTable.getGroupedTableType()

Uses of PGroupedTableType in org.apache.crunch.impl.mr.plan

Methods in org.apache.crunch.impl.mr.plan with parameters of type PGroupedTableType

static <K,V> DoNode

DoNode.createGroupingNode(String name, PGroupedTableType<K,V> ptype)

Uses of PGroupedTableType in org.apache.crunch.impl.spark

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

SparkComparator(GroupingOptions options, PGroupedTableType ptype, SparkRuntimeContext ctxt)

Uses of PGroupedTableType in org.apache.crunch.impl.spark.fn

Constructors in org.apache.crunch.impl.spark.fn with parameters of type PGroupedTableType

PartitionedMapOutputFunction(SerDe<K> keySerde, SerDe<V> valueSerde, PGroupedTableType<K,V> ptype, Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass, int numPartitions, SparkRuntimeContext runtimeContext)

ReduceGroupingFunction(GroupingOptions options, PGroupedTableType ptype, SparkRuntimeContext ctxt)

Uses of PGroupedTableType in org.apache.crunch.lib

Methods in org.apache.crunch.lib with parameters of type PGroupedTableType

static <K,V> Pair<K,Iterable<V>>

PTables.getGroupedDetachedValue(PGroupedTableType<K,V> groupedTableType, Pair<K,Iterable<V>> value) Created a detached value for a PGroupedTable value.

Uses of PGroupedTableType in org.apache.crunch.types

Methods in org.apache.crunch.types that return PGroupedTableType

PGroupedTableType<K,V>

PTableType.getGroupedTableType() Returns the grouped table version of this type.