Skip to content

Commit

Permalink
address review comment
Browse files Browse the repository at this point in the history
  • Loading branch information
kiszk committed Apr 18, 2017
1 parent a6bedee commit c0dca2b
Showing 1 changed file with 0 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -106,16 +106,6 @@ object CombineTypedFilters extends Rule[LogicalPlan] {
* representation of data item. For example back to back map operations.
*/
object EliminateMapObjects extends Rule[LogicalPlan] {
/*
def apply(plan: LogicalPlan): LogicalPlan = plan transform {
case DeserializeToObject(Invoke(
MapObjects(_, _, _, _ : LambdaVariable, inputData, None),
funcName, returnType: ObjectType, arguments, propagateNull, returnNullable),
outputObjAttr, child) =>
DeserializeToObject(Invoke(
inputData, funcName, returnType, arguments, propagateNull, returnNullable),
outputObjAttr, child)
*/
def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
case MapObjects(_, _, _, LambdaVariable(_, _, _, false), inputData, None) => inputData
}
Expand Down

0 comments on commit c0dca2b

Please sign in to comment.