This project has retired. For details please refer to its Attic page.
Uses of Class org.apache.crunch.impl.spark.SparkRuntimeContext (Apache Crunch 0.10.0 API)

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

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)
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.