diff options
Diffstat (limited to 'sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala')
-rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala index 07aa1515f3..f19ad6e707 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala @@ -57,13 +57,6 @@ class KeyValueGroupedDataset[K, V] private[sql]( private def logicalPlan = queryExecution.analyzed private def sqlContext = queryExecution.sqlContext - private def groupedData = { - new RelationalGroupedDataset( - Dataset.ofRows(sqlContext, logicalPlan), - groupingAttributes, - RelationalGroupedDataset.GroupByType) - } - /** * Returns a new [[KeyValueGroupedDataset]] where the type of the key has been mapped to the * specified type. The mapping of key columns to the type follows the same rules as `as` on @@ -207,12 +200,6 @@ class KeyValueGroupedDataset[K, V] private[sql]( reduceGroups(f.call _) } - private def withEncoder(c: Column): Column = c match { - case tc: TypedColumn[_, _] => - tc.withInputType(resolvedVEncoder.bind(dataAttributes), dataAttributes) - case _ => c - } - /** * Internal helper function for building typed aggregations that return tuples. For simplicity * and code reuse, we do this without the help of the type system and then use helper functions |