File tree 2 files changed +20
-2
lines changed 2 files changed +20
-2
lines changed Original file line number Diff line number Diff line change @@ -439,8 +439,8 @@ _outGather(StringInfo str, const Gather *node)
439
439
440
440
_outPlanInfo (str , (const Plan * ) node );
441
441
442
- WRITE_UINT_FIELD (num_workers );
443
- WRITE_UINT_FIELD (single_copy );
442
+ WRITE_INT_FIELD (num_workers );
443
+ WRITE_BOOL_FIELD (single_copy );
444
444
}
445
445
446
446
static void
Original file line number Diff line number Diff line change @@ -1998,6 +1998,22 @@ _readUnique(void)
1998
1998
READ_DONE ();
1999
1999
}
2000
2000
2001
+ /*
2002
+ * _readGather
2003
+ */
2004
+ static Gather *
2005
+ _readGather (void )
2006
+ {
2007
+ READ_LOCALS (Gather );
2008
+
2009
+ ReadCommonPlan (& local_node -> plan );
2010
+
2011
+ READ_INT_FIELD (num_workers );
2012
+ READ_BOOL_FIELD (single_copy );
2013
+
2014
+ READ_DONE ();
2015
+ }
2016
+
2001
2017
/*
2002
2018
* _readHash
2003
2019
*/
@@ -2365,6 +2381,8 @@ parseNodeString(void)
2365
2381
return_value = _readWindowAgg ();
2366
2382
else if (MATCH ("UNIQUE" , 6 ))
2367
2383
return_value = _readUnique ();
2384
+ else if (MATCH ("GATHER" , 6 ))
2385
+ return_value = _readGather ();
2368
2386
else if (MATCH ("HASH" , 4 ))
2369
2387
return_value = _readHash ();
2370
2388
else if (MATCH ("SETOP" , 5 ))
You can’t perform that action at this time.
0 commit comments