|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
| Packages that use SparkRuntimeContext | |
|---|---|
| org.apache.crunch.impl.spark | |
| org.apache.crunch.impl.spark.fn | |
| Uses of SparkRuntimeContext in org.apache.crunch.impl.spark |
|---|
| Methods in org.apache.crunch.impl.spark that return SparkRuntimeContext | |
|---|---|
SparkRuntimeContext |
SparkRuntime.getRuntimeContext()
|
| Constructors in org.apache.crunch.impl.spark with parameters of type SparkRuntimeContext | |
|---|---|
SparkComparator(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt)
|
|
| Uses of SparkRuntimeContext in org.apache.crunch.impl.spark.fn |
|---|
| Constructors in org.apache.crunch.impl.spark.fn with parameters of type SparkRuntimeContext | |
|---|---|
CombineMapsideFunction(CombineFn<K,V> combineFn,
SparkRuntimeContext ctxt)
|
|
FlatMapDoFn(DoFn<S,T> fn,
SparkRuntimeContext ctxt)
|
|
FlatMapPairDoFn(DoFn<Pair<K,V>,T> fn,
SparkRuntimeContext ctxt)
|
|
MapFunction(MapFn fn,
SparkRuntimeContext ctxt)
|
|
PairFlatMapDoFn(DoFn<T,Pair<K,V>> fn,
SparkRuntimeContext ctxt)
|
|
PairFlatMapPairDoFn(DoFn<Pair<K,V>,Pair<K2,V2>> fn,
SparkRuntimeContext ctxt)
|
|
PairMapFunction(MapFn<Pair<K,V>,S> fn,
SparkRuntimeContext ctxt)
|
|
PairMapIterableFunction(MapFn<Pair<K,List<V>>,Pair<S,Iterable<T>>> fn,
SparkRuntimeContext runtimeContext)
|
|
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)
|
|
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||