org.apache.spark.sql

Interface UDFRegistration

All Known Implementing Classes:

HiveContext, LocalHiveContext, SQLContext, TestHive, TestHiveContext, TestSQLContext

public interface UDFRegistration

Functions for registering scala lambda functions as UDFs in a SQLContext.

Method Summary

Methods

Modifier and Type	Method and Description
<T> void	registerFunction(String name, scala.Function1<?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$1) registerFunction 1-22 were generated by this script
<T> void	registerFunction(String name, scala.Function10<?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$10)
<T> void	registerFunction(String name, scala.Function11<?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$11)
<T> void	registerFunction(String name, scala.Function12<?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$12)
<T> void	registerFunction(String name, scala.Function13<?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$13)
<T> void	registerFunction(String name, scala.Function14<?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$14)
<T> void	registerFunction(String name, scala.Function15<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$15)
<T> void	registerFunction(String name, scala.Function16<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$16)
<T> void	registerFunction(String name, scala.Function17<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$17)
<T> void	registerFunction(String name, scala.Function18<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$18)
<T> void	registerFunction(String name, scala.Function19<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$19)
<T> void	registerFunction(String name, scala.Function2<?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$2)
<T> void	registerFunction(String name, scala.Function20<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$20)
<T> void	registerFunction(String name, scala.Function21<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$21)
<T> void	registerFunction(String name, scala.Function22<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$22)
<T> void	registerFunction(String name, scala.Function3<?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$3)
<T> void	registerFunction(String name, scala.Function4<?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$4)
<T> void	registerFunction(String name, scala.Function5<?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$5)
<T> void	registerFunction(String name, scala.Function6<?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$6)
<T> void	registerFunction(String name, scala.Function7<?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$7)
<T> void	registerFunction(String name, scala.Function8<?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$8)
<T> void	registerFunction(String name, scala.Function9<?,?,?,?,?,?,?,?,?,T> func, scala.reflect.api.TypeTags.TypeTag<T> evidence$9)
void	registerPython(String name, byte[] command, java.util.Map<String,String> envVars, java.util.List<String> pythonIncludes, String pythonExec, java.util.List<Broadcast<org.apache.spark.api.python.PythonBroadcast>> broadcastVars, Accumulator<java.util.List<byte[]>> accumulator, String stringDataType)

Method Detail

registerPython

void registerPython(String name,
                  byte[] command,
                  java.util.Map<String,String> envVars,
                  java.util.List<String> pythonIncludes,
                  String pythonExec,
                  java.util.List<Broadcast<org.apache.spark.api.python.PythonBroadcast>> broadcastVars,
                  Accumulator<java.util.List<byte[]>> accumulator,
                  String stringDataType)

registerFunction

<T> void registerFunction(String name,
                        scala.Function1<?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$1)

registerFunction 1-22 were generated by this script

(1 to 22).map { x => val types = (1 to x).map(x => "_").reduce(_ + ", " + _) s""" def registerFunction[T: TypeTag](name: String, func: Function$x[$types, T]): Unit = { def builder(e: Seq[Expression]) = ScalaUdf(func, ScalaReflection.schemaFor[T].dataType, e) functionRegistry.registerFunction(name, builder) } """ }

registerFunction

<T> void registerFunction(String name,
                        scala.Function2<?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$2)

registerFunction

<T> void registerFunction(String name,
                        scala.Function3<?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$3)

registerFunction

<T> void registerFunction(String name,
                        scala.Function4<?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$4)

registerFunction

<T> void registerFunction(String name,
                        scala.Function5<?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$5)

registerFunction

<T> void registerFunction(String name,
                        scala.Function6<?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$6)

registerFunction

<T> void registerFunction(String name,
                        scala.Function7<?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$7)

registerFunction

<T> void registerFunction(String name,
                        scala.Function8<?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$8)

registerFunction

<T> void registerFunction(String name,
                        scala.Function9<?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$9)

registerFunction

<T> void registerFunction(String name,
                        scala.Function10<?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$10)

registerFunction

<T> void registerFunction(String name,
                        scala.Function11<?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$11)

registerFunction

<T> void registerFunction(String name,
                        scala.Function12<?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$12)

registerFunction

<T> void registerFunction(String name,
                        scala.Function13<?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$13)

registerFunction

<T> void registerFunction(String name,
                        scala.Function14<?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$14)

registerFunction

<T> void registerFunction(String name,
                        scala.Function15<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$15)

registerFunction

<T> void registerFunction(String name,
                        scala.Function16<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$16)

registerFunction

<T> void registerFunction(String name,
                        scala.Function17<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$17)

registerFunction

<T> void registerFunction(String name,
                        scala.Function18<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$18)

registerFunction

<T> void registerFunction(String name,
                        scala.Function19<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$19)

registerFunction

<T> void registerFunction(String name,
                        scala.Function20<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$20)

registerFunction

<T> void registerFunction(String name,
                        scala.Function21<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$21)

registerFunction

<T> void registerFunction(String name,
                        scala.Function22<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,T> func,
                        scala.reflect.api.TypeTags.TypeTag<T> evidence$22)