greenplumn pxf_fdw 源码
greenplumn pxf_fdw 代码
文件路径：/gpcontrib/pxf_fdw/pxf_fdw.h
/*
* pxf_fdw.h
* Foreign-data wrapper for PXF (Platform Extension Framework)
*
* IDENTIFICATION
* contrib/pxf_fdw/pxf_fdw.h
*/
#include "postgres.h"
#include "access/formatter.h"
#include "commands/copy.h"
#include "nodes/pathnodes.h"
#include "nodes/pg_list.h"
#include "utils/rel.h"
#ifndef PXF_FDW_H
#define PXF_FDW_H
#define PXF_FDW_DEFAULT_PROTOCOL "http"
#define PXF_FDW_DEFAULT_HOST "localhost"
#define PXF_FDW_DEFAULT_PORT 5888
/*
* Structure to store the PXF options */
typedef struct PxfOptions
{
/* PXF service options */
int pxf_port; /* port number for the PXF Service */
char *pxf_host; /* hostname for the PXF Service */
char *pxf_protocol; /* protocol for the PXF Service (i.e HTTP or
* HTTPS) */
/* Server doesn't come from options, it is the actual SERVER name */
char *server; /* the name of the external server */
/* Defined at options, but it is not visible to FDWs */
char exec_location; /* execute on COORDINATOR, ANY or ALL SEGMENTS,
* Greenplum MPP specific */
/* Single Row Error Handling */
int reject_limit;
bool is_reject_limit_rows;
bool log_errors;
/* FDW options */
char *protocol; /* PXF protocol */
char *resource; /* PXF resource */
char *format; /* PXF resource format */
char *profile; /* protocol[:format] */
List *copy_options; /* merged options for COPY */
List *options; /* merged options, excluding COPY, protocol,
* resource, format, wire_format, pxf_port,
* pxf_host, and pxf_protocol */
} PxfOptions;
/* Functions prototypes for pxf_option.c file */
PxfOptions *PxfGetOptions(Oid foreigntableid);
/* in pxf_deparse.c */
extern void deparseTargetList(Relation rel, Bitmapset *attrs_used, List **retrieved_attrs);
extern void classifyConditions(PlannerInfo *root, RelOptInfo *baserel, List *input_conds, List **remote_conds, List **local_conds);
#endif /* _PXF_FDW_H_ */
相关信息
相关文章
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
8、 openharmony