org.apache.crunch.impl.spark
Class SparkRuntimeContext
java.lang.Object
org.apache.crunch.impl.spark.SparkRuntimeContext
- All Implemented Interfaces:
- Serializable
public class SparkRuntimeContext
- extends Object
- implements Serializable
- See Also:
- Serialized Form
SparkRuntimeContext
public SparkRuntimeContext(org.apache.spark.Accumulator<Map<String,Map<String,Long>>> counters,
org.apache.spark.broadcast.Broadcast<byte[]> broadConf)
setConf
public void setConf(org.apache.spark.broadcast.Broadcast<byte[]> broadConf)
initialize
public void initialize(DoFn<?,?> fn)
getConfiguration
public org.apache.hadoop.conf.Configuration getConfiguration()
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.