From ae9c556d91a58f41098b40b3e10842570e4b3278 Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Thu, 15 Jan 2015 14:37:11 -0800 Subject: [PATCH] Updated example. --- .../src/main/scala/org/apache/spark/sql/SQLContext.scala | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala index cec36da8df35a..8ad1753dab757 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala @@ -347,19 +347,20 @@ class SQLContext(@transient val sparkContext: SparkContext) * * The following example registers a UDF in Java: * {{{ - * sqlContext.udf().register("myUDF", DataTypes.StringType, + * sqlContext.udf().register("myUDF", * new UDF2() { * @Override * public String call(Integer arg1, String arg2) { * return arg2 + arg1; * } - * }); + * }, DataTypes.StringType); * }}} * * Or, to use Java 8 lambda syntax: * {{{ - * sqlContext.udf().register("myUDF", DataTypes.StringType, - * (Integer arg1, String arg2) -> arg2 + arg1)); + * sqlContext.udf().register("myUDF", + * (Integer arg1, String arg2) -> arg2 + arg1), + * DataTypes.StringType); * }}} */ val udf: UDFRegistration = new UDFRegistration(this)