Package uk.gov.gchq.gaffer.sparkaccumulo.operation.utils.java

Class ElementConverterFunction

java.lang.Object

uk.gov.gchq.gaffer.sparkaccumulo.operation.utils.java.ElementConverterFunction

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<Element,org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

public class ElementConverterFunction
extends Object
implements org.apache.spark.api.java.function.PairFlatMapFunction<Element,org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ElementConverterFunction(org.apache.spark.broadcast.Broadcast<AccumuloElementConverter> converterBroadcast)

Method Summary

Modifier and Type	Method	Description
Iterator<scala.Tuple2<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>	call(Element e)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElementConverterFunction

public ElementConverterFunction(org.apache.spark.broadcast.Broadcast<AccumuloElementConverter> converterBroadcast)

Method Detail

call

public Iterator<scala.Tuple2<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> call(Element e)
                                                                                                         throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.PairFlatMapFunction<Element,org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Throws:

Exception