greenplumn cdbcopy 源码
greenplumn cdbcopy 代码
文件路径：/src/include/cdb/cdbcopy.h
/*--------------------------------------------------------------------------
*
* cdbcopy.h
* Definitions and API functions for cdbcopy.c
* These are functions that are used by the backend
* COPY command in Greenplum Database.
*
* Portions Copyright (c) 2005-2008, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
*
*
* IDENTIFICATION
* src/include/cdb/cdbcopy.h
*
*--------------------------------------------------------------------------
*/
#ifndef CDBCOPY_H
#define CDBCOPY_H
#include "access/aosegfiles.h" /* for InvalidFileSegNumber const */
#include "lib/stringinfo.h"
#include "cdb/cdbgang.h"
#define COPYOUT_CHUNK_SIZE 16 * 1024
struct CdbDispatcherState;
struct CopyStateData;
typedef struct CdbCopy
{
int total_segs; /* total number of segments in cdb */
bool copy_in; /* direction: true for COPY FROM false for COPY TO */
StringInfoData copy_out_buf;/* holds a chunk of data from the database */
List *seglist; /* segs that currently take part in copy.
* for copy out, once a segment gave away all it's
* data rows, it is taken out of the list */
struct CdbDispatcherState *dispatcherState;
} CdbCopy;
/* global function declarations */
extern CdbCopy *makeCdbCopy(struct CopyStateData *cstate, bool copy_in);
extern void cdbCopyStart(CdbCopy *cdbCopy, CopyStmt *stmt, int file_encoding);
extern void cdbCopySendDataToAll(CdbCopy *c, const char *buffer, int nbytes);
extern void cdbCopySendData(CdbCopy *c, int target_seg, const char *buffer, int nbytes);
extern bool cdbCopyGetData(CdbCopy *c, bool cancel, uint64 *rows_processed);
extern void cdbCopyAbort(CdbCopy *c);
extern void cdbCopyEnd(CdbCopy *c,
int64 *total_rows_completed_p,
int64 *total_rows_rejected_p);
#endif /* CDBCOPY_H */
相关信息
相关文章
greenplumn cdbappendonlyblockdirectory 源码
greenplumn cdbappendonlystorage 源码
greenplumn cdbappendonlystorage_int 源码
greenplumn cdbappendonlystorageformat 源码
greenplumn cdbappendonlystoragelayer 源码
greenplumn cdbappendonlystorageread 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦