Uses of Class
org.apache.crunch.impl.spark.SparkRuntimeContext

Packages that use SparkRuntimeContext

Package	Description
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

Modifier and Type	Method and Description
SparkRuntimeContext	SparkRuntime.getRuntimeContext()

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

Constructor and Description
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

Constructor and Description
CombineMapsideFunction(CombineFn<K,V> combineFn, SparkRuntimeContext ctxt)
FlatMapIndexFn(DoFn<S,T> fn, boolean convertInput, 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)
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, int numPartitions, GroupingOptions options, SparkRuntimeContext runtimeContext)
ReduceGroupingFunction(GroupingOptions options, PGroupedTableType ptype, SparkRuntimeContext ctxt)
Tuple2MapFunction(MapFn<Pair<K,V>,Pair<K,V>> fn, SparkRuntimeContext ctxt)