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

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

java.lang.Object
  scala.runtime.AbstractFunction1<T,R>
      org.apache.spark.api.java.function.WrappedFunction1<T,R>
          org.apache.spark.api.java.function.Function<Object,Object>
              org.apache.crunch.impl.spark.fn.MapFunction

All Implemented Interfaces:

Serializable, scala.Function1<Object,Object>, scala.ScalaObject

public class MapFunction
extends 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 org.apache.spark.api.java.function.Function

returnType

Methods inherited from class org.apache.spark.api.java.function.WrappedFunction1

apply

Methods inherited from class scala.runtime.AbstractFunction1

andThen, andThen$mcDD$sp, andThen$mcDF$sp, andThen$mcDI$sp, andThen$mcDJ$sp, andThen$mcFD$sp, andThen$mcFF$sp, andThen$mcFI$sp, andThen$mcFJ$sp, andThen$mcID$sp, andThen$mcIF$sp, andThen$mcII$sp, andThen$mcIJ$sp, andThen$mcJD$sp, andThen$mcJF$sp, andThen$mcJI$sp, andThen$mcJJ$sp, andThen$mcVD$sp, andThen$mcVF$sp, andThen$mcVI$sp, andThen$mcVJ$sp, andThen$mcZD$sp, andThen$mcZF$sp, andThen$mcZI$sp, andThen$mcZJ$sp, apply$mcDD$sp, apply$mcDF$sp, apply$mcDI$sp, apply$mcDJ$sp, apply$mcFD$sp, apply$mcFF$sp, apply$mcFI$sp, apply$mcFJ$sp, apply$mcID$sp, apply$mcIF$sp, apply$mcII$sp, apply$mcIJ$sp, apply$mcJD$sp, apply$mcJF$sp, apply$mcJI$sp, apply$mcJJ$sp, apply$mcVD$sp, apply$mcVF$sp, apply$mcVI$sp, apply$mcVJ$sp, apply$mcZD$sp, apply$mcZF$sp, apply$mcZI$sp, apply$mcZJ$sp, compose, compose$mcDD$sp, compose$mcDF$sp, compose$mcDI$sp, compose$mcDJ$sp, compose$mcFD$sp, compose$mcFF$sp, compose$mcFI$sp, compose$mcFJ$sp, compose$mcID$sp, compose$mcIF$sp, compose$mcII$sp, compose$mcIJ$sp, compose$mcJD$sp, compose$mcJF$sp, compose$mcJI$sp, compose$mcJJ$sp, compose$mcVD$sp, compose$mcVF$sp, compose$mcVI$sp, compose$mcVJ$sp, compose$mcZD$sp, compose$mcZF$sp, compose$mcZI$sp, compose$mcZJ$sp, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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 class org.apache.spark.api.java.function.Function<Object,Object>

Throws:

Exception