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

org.apache.crunch.impl.spark.fn
Class MapFunction

java.lang.Object
  org.apache.crunch.impl.spark.fn.MapFunction

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<Object,Object>

public class MapFunction
extends Object
implements org.apache.spark.api.java.function.Function<Object,Object>

See Also:

Serialized Form

Constructor Summary

MapFunction(MapFn fn, SparkRuntimeContext ctxt)

Method Summary

Object

call(Object o)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapFunction

public MapFunction(MapFn fn,
                   SparkRuntimeContext ctxt)

Method Detail

call

public Object call(Object o)
            throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<Object,Object>

Throws:

Exception