external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3883 from citusdata/circ_deps 

typedef TupleDestination only once
pull/3860/head
Hadi Moshayedi 2020-06-09 01:36:41 -07:00 committed by GitHub
parent 6869d7bfb2 198d5d8b0f
commit 5781aaf6c7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/include/distributed/multi_physical_planner.h
View File

@ -262,7 +262,7 @@ typedef struct TaskQuery
}data; }data;
}TaskQuery; }TaskQuery;
typedef struct TupleDestination TupleDestination; struct TupleDestination;
typedef struct Task typedef struct Task
{ {
@ -336,7 +336,7 @@ typedef struct Task
* Destination of tuples generated as a result of executing this task. Can be * Destination of tuples generated as a result of executing this task. Can be
* NULL, in which case executor might use a default destination. * NULL, in which case executor might use a default destination.
*/ */
TupleDestination *tupleDest; struct TupleDestination *tupleDest;
} Task; } Task;

4
src/include/distributed/tuple_destination.h
View File

@ -27,7 +27,7 @@ typedef struct TupleDestination TupleDestination;
* accept a queryNumber parameter which denotes the index of the query that * accept a queryNumber parameter which denotes the index of the query that
* tuple belongs to. * tuple belongs to.
*/ */
typedef struct TupleDestination struct TupleDestination
{ {
/* putTuple implements custom processing of a tuple */ /* putTuple implements custom processing of a tuple */
void (*putTuple)(TupleDestination *self, Task *task, void (*putTuple)(TupleDestination *self, Task *task,
@ -36,7 +36,7 @@ typedef struct TupleDestination
/* tupleDescForQuery returns tuple descriptor for a query number. Can return NULL. */ /* tupleDescForQuery returns tuple descriptor for a query number. Can return NULL. */
TupleDesc (*tupleDescForQuery)(TupleDestination *self, int queryNumber); TupleDesc (*tupleDescForQuery)(TupleDestination *self, int queryNumber);
} TupleDestination; };
extern TupleDestination * CreateTupleStoreTupleDest(Tuplestorestate *tupleStore, TupleDesc extern TupleDestination * CreateTupleStoreTupleDest(Tuplestorestate *tupleStore, TupleDesc
tupleDescriptor); tupleDescriptor);