change implements to new node

Author: jiaqizho

src/backend/cdb/cdbllize.c

@@ -1506,6 +1506,7 @@ motion_sanity_walker(Node *node, sanity_result_t *result)
 	{
 		case T_Result:
 		case T_WindowAgg:
+		case T_WindowHashAgg:
 		case T_TableFunctionScan:
 		case T_ShareInputScan:
 		case T_Append:

src/backend/cdb/cdbplan.c

@@ -694,6 +694,25 @@ plan_tree_mutator(Node *node,
 				return (Node *) newwindow;
 			}
 			break;
+		case T_WindowHashAgg:
+			{
+				WindowHashAgg  *window = (WindowHashAgg *) node;
+				WindowHashAgg  *newwindow;
+
+				FLATCOPY(newwindow, window, WindowHashAgg);
+				PLANMUTATE(newwindow, window);
+
+				COPYARRAY(newwindow, window, partNumCols, partColIdx);
+				COPYARRAY(newwindow, window, partNumCols, partOperators);
+
+				COPYARRAY(newwindow, window, ordNumCols, ordColIdx);
+				COPYARRAY(newwindow, window, ordNumCols, ordOperators);
+				MUTATE(newwindow->startOffset, window->startOffset, Node *);
+				MUTATE(newwindow->endOffset, window->endOffset, Node *);
+
+				return (Node *) newwindow;
+			}
+			break;
 
 		case T_Unique:
 			{

src/backend/cdb/cdbtargeteddispatch.c

@@ -522,6 +522,7 @@ DirectDispatchUpdateContentIdsFromPlan(PlannerInfo *root, Plan *plan)
 			DisableTargetedDispatch(&dispatchInfo);
 			break;
 		case T_WindowAgg:
+		case T_WindowHashAgg:
 		case T_TableFunctionScan:
 		case T_RecursiveUnion:
 			/* no change to dispatchInfo */

src/backend/executor/nodeWindowAgg.c

@@ -2617,9 +2617,6 @@ ExecInitWindowAgg(WindowAgg *node, EState *estate, int eflags)
 	TupleDesc	scanDesc;
 	ListCell   *l;
 
-	// not support window hash agg
-	Assert(!node->isWindowHashAgg);
-
 	/* check for unsupported flags */
 	Assert(!(eflags & (EXEC_FLAG_BACKWARD | EXEC_FLAG_MARK)));