This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.spark.fn
Class ReduceInputFunction<K,V>

java.lang.Object
  org.apache.crunch.impl.spark.fn.ReduceInputFunction<K,V>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<scala.Tuple2<ByteArray,Iterable<byte[]>>,Pair<K,Iterable<V>>>

public class ReduceInputFunction<K,V>
extends Object
implements org.apache.spark.api.java.function.Function<scala.Tuple2<ByteArray,Iterable<byte[]>>,Pair<K,Iterable<V>>>

See Also:

Serialized Form

Constructor Summary

ReduceInputFunction(SerDe<K> keySerDe, SerDe<V> valueSerDe)

Method Summary

Pair<K,Iterable<V>>

call(scala.Tuple2<ByteArray,Iterable<byte[]>> kv)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReduceInputFunction

public ReduceInputFunction(SerDe<K> keySerDe,
                           SerDe<V> valueSerDe)

Method Detail

call

public Pair<K,Iterable<V>> call(scala.Tuple2<ByteArray,Iterable<byte[]>> kv)
                         throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<scala.Tuple2<ByteArray,Iterable<byte[]>>,Pair<K,Iterable<V>>>

Throws:

Exception