org.apache.crunch.impl.spark.fn

Class FlatMapIndexFn<S,T>

java.lang.Object

org.apache.crunch.impl.spark.fn.FlatMapIndexFn<S,T>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function2<Integer,Iterator,Iterator<T>>

public class FlatMapIndexFn<S,T>
extends Object
implements org.apache.spark.api.java.function.Function2<Integer,Iterator,Iterator<T>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlatMapIndexFn(DoFn<S,T> fn, boolean convertInput, SparkRuntimeContext ctxt)

Method Summary

Modifier and Type	Method and Description
Iterator<T>	call(Integer partitionId, Iterator input)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatMapIndexFn

public FlatMapIndexFn(DoFn<S,T> fn,
                      boolean convertInput,
                      SparkRuntimeContext ctxt)

Method Detail

call

public Iterator<T> call(Integer partitionId,
                        Iterator input)
                 throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function2<Integer,Iterator,Iterator<T>>

Throws:

Exception