com.splicemachine.derby.stream.spark

Class SparkFlatMapFunction<T,R>

java.lang.Object

com.splicemachine.derby.stream.spark.SparkFlatMapFunction<T,R>

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, org.apache.spark.api.java.function.FlatMapFunction<T,R>

public class SparkFlatMapFunction<T,R>
extends java.lang.Object
implements org.apache.spark.api.java.function.FlatMapFunction<T,R>, java.io.Externalizable

Mapping between Spark and SpliceMachine functional APIs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkFlatMapFunction()
SparkFlatMapFunction(ExternalizableFlatMapFunction<T,R> delegate)

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<R>	call(T t)
java.lang.String	getPrettyFunctionName()
void	readExternal(java.io.ObjectInput in)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkFlatMapFunction

public SparkFlatMapFunction(ExternalizableFlatMapFunction<T,R> delegate)

SparkFlatMapFunction

public SparkFlatMapFunction()

Method Detail

call

public java.util.Iterator<R> call(T t)
                           throws java.lang.Exception

Specified by:

call in interface org.apache.spark.api.java.function.FlatMapFunction<T,R>

Throws:

java.lang.Exception

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Specified by:

writeExternal in interface java.io.Externalizable

Throws:

java.io.IOException

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException

Specified by:

readExternal in interface java.io.Externalizable

Throws:

java.io.IOException

java.lang.ClassNotFoundException

getPrettyFunctionName

public java.lang.String getPrettyFunctionName()