This project has retired. For details please refer to its
Attic page.
CombineMapsideFunction (Apache Crunch 0.11.0 API)
org.apache.crunch.impl.spark.fn
Class CombineMapsideFunction<K,V>
java.lang.Object
org.apache.crunch.impl.spark.fn.CombineMapsideFunction<K,V>
- All Implemented Interfaces:
- Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<Iterator<scala.Tuple2<K,V>>,K,V>
public class CombineMapsideFunction<K,V>
- extends Object
- implements org.apache.spark.api.java.function.PairFlatMapFunction<Iterator<scala.Tuple2<K,V>>,K,V>
- See Also:
- Serialized Form
CombineMapsideFunction
public CombineMapsideFunction(CombineFn<K,V> combineFn,
SparkRuntimeContext ctxt)
call
public Iterable<scala.Tuple2<K,V>> call(Iterator<scala.Tuple2<K,V>> iter)
throws Exception
- Specified by:
call
in interface org.apache.spark.api.java.function.PairFlatMapFunction<Iterator<scala.Tuple2<K,V>>,K,V>
- Throws:
Exception
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.