Skip to content

Commit e33abd8

Browse files
committed
Fixed compilation error.
1 parent cceb650 commit e33abd8

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -330,25 +330,6 @@ class SchemaRDD(
330330
sqlContext,
331331
Filter(ScalaUdf(udf, BooleanType, Seq(UnresolvedAttribute(arg1.name))), logicalPlan))
332332

333-
/**
334-
* :: Experimental ::
335-
* Filters tuples using a function over a `Dynamic` version of a given Row. DynamicRows use
336-
* scala's Dynamic trait to emulate an ORM of in a dynamically typed language. Since the type of
337-
* the column is not known at compile time, all attributes are converted to strings before
338-
* being passed to the function.
339-
*
340-
* {{{
341-
* schemaRDD.where(r => r.firstName == "Bob" && r.lastName == "Smith")
342-
* }}}
343-
*
344-
* @group Query
345-
*/
346-
@Experimental
347-
def where(dynamicUdf: (DynamicRow) => Boolean) =
348-
new SchemaRDD(
349-
sqlContext,
350-
Filter(ScalaUdf(dynamicUdf, BooleanType, Seq(WrapDynamic(logicalPlan.output))), logicalPlan))
351-
352333
/**
353334
* :: Experimental ::
354335
* Returns a sampled version of the underlying dataset.

0 commit comments

Comments
 (0)