|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
| Packages that use GroupingOptions | |
|---|---|
| org.apache.crunch | Client-facing API and core abstractions. |
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.spark | |
| org.apache.crunch.impl.spark.collect | |
| org.apache.crunch.impl.spark.fn | |
| org.apache.crunch.types | Common functionality for business object serialization. |
| Uses of GroupingOptions in org.apache.crunch |
|---|
| Methods in org.apache.crunch that return GroupingOptions | |
|---|---|
GroupingOptions |
GroupingOptions.Builder.build()
|
| Methods in org.apache.crunch with parameters of type GroupingOptions | |
|---|---|
PGroupedTable<K,V> |
PTable.groupByKey(GroupingOptions options)
Performs a grouping operation on the keys of this table, using the additional GroupingOptions to control how the grouping is executed. |
boolean |
GroupingOptions.isCompatibleWith(GroupingOptions other)
|
| Uses of GroupingOptions in org.apache.crunch.impl.dist.collect |
|---|
| Methods in org.apache.crunch.impl.dist.collect with parameters of type GroupingOptions | ||
|---|---|---|
|
PCollectionFactory.createGroupedTable(PTableBase<K,V> parent,
GroupingOptions groupingOptions)
|
|
BaseGroupedTable<K,V> |
PTableBase.groupByKey(GroupingOptions groupingOptions)
|
|
| Uses of GroupingOptions in org.apache.crunch.impl.spark |
|---|
| Constructors in org.apache.crunch.impl.spark with parameters of type GroupingOptions | |
|---|---|
SparkComparator(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt)
|
|
| Uses of GroupingOptions in org.apache.crunch.impl.spark.collect |
|---|
| Methods in org.apache.crunch.impl.spark.collect with parameters of type GroupingOptions | ||
|---|---|---|
|
SparkCollectFactory.createGroupedTable(PTableBase<K,V> parent,
GroupingOptions groupingOptions)
|
|
| Uses of GroupingOptions in org.apache.crunch.impl.spark.fn |
|---|
| Constructors in org.apache.crunch.impl.spark.fn with parameters of type GroupingOptions | |
|---|---|
ReduceGroupingFunction(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt)
|
|
| Uses of GroupingOptions in org.apache.crunch.types |
|---|
| Methods in org.apache.crunch.types with parameters of type GroupingOptions | |
|---|---|
abstract void |
PGroupedTableType.configureShuffle(org.apache.hadoop.mapreduce.Job job,
GroupingOptions options)
|
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||