diff --git a/src/include/distributed/multi_physical_planner.h b/src/include/distributed/multi_physical_planner.h index a2af0a480..78f13fd3c 100644 --- a/src/include/distributed/multi_physical_planner.h +++ b/src/include/distributed/multi_physical_planner.h @@ -262,7 +262,7 @@ typedef struct TaskQuery }data; }TaskQuery; -typedef struct TupleDestination TupleDestination; +struct TupleDestination; typedef struct Task { @@ -336,7 +336,7 @@ typedef struct Task * Destination of tuples generated as a result of executing this task. Can be * NULL, in which case executor might use a default destination. */ - TupleDestination *tupleDest; + struct TupleDestination *tupleDest; } Task; diff --git a/src/include/distributed/tuple_destination.h b/src/include/distributed/tuple_destination.h index 5fd9cd859..c04d4f7f9 100644 --- a/src/include/distributed/tuple_destination.h +++ b/src/include/distributed/tuple_destination.h @@ -27,7 +27,7 @@ typedef struct TupleDestination TupleDestination; * accept a queryNumber parameter which denotes the index of the query that * tuple belongs to. */ -typedef struct TupleDestination +struct TupleDestination { /* putTuple implements custom processing of a tuple */ void (*putTuple)(TupleDestination *self, Task *task, @@ -36,7 +36,7 @@ typedef struct TupleDestination /* tupleDescForQuery returns tuple descriptor for a query number. Can return NULL. */ TupleDesc (*tupleDescForQuery)(TupleDestination *self, int queryNumber); -} TupleDestination; +}; extern TupleDestination * CreateTupleStoreTupleDest(Tuplestorestate *tupleStore, TupleDesc tupleDescriptor);