hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

add item type and member of select into spec

Browse Source
This commit is contained in:
dontknow9179 2024-06-21 15:22:22 +00:00 committed by ob-robot
parent cc1b65e578
commit 9ec6708fb3
3 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/objit/include/objit/common/ob_item_type.h
View File

@ -2540,6 +2540,9 @@ typedef enum ObItemType
// for vector index
T_APPROX,
// select into outfile
T_BUFFER_SIZE,
T_PARTITION_EXPR,
T_MAX //Attention: add a new type before T_MAX
} ObItemType;

7
src/sql/engine/basic/ob_select_into_op.cpp
View File

@ -27,9 +27,10 @@ using namespace common;
namespace sql
{
OB_SERIALIZE_MEMBER(ObSelectIntoOpInput, task_id_, sqc_id_);
OB_SERIALIZE_MEMBER((ObSelectIntoSpec, ObOpSpec), into_type_, user_vars_,
outfile_name_, field_str_, line_str_, closed_cht_, is_optional_, select_exprs_, is_single_,
max_file_size_, escaped_cht_, cs_type_, parallel_);
OB_SERIALIZE_MEMBER((ObSelectIntoSpec, ObOpSpec), into_type_, user_vars_, outfile_name_,
field_str_, // FARM COMPAT WHITELIST FOR filed_str_: renamed
line_str_, closed_cht_, is_optional_, select_exprs_, is_single_, max_file_size_,
escaped_cht_, cs_type_, parallel_, file_partition_expr_, buffer_size_);
int ObSelectIntoOp::inner_open()

12
src/sql/engine/basic/ob_select_into_op.h
View File

@ -66,7 +66,9 @@ public:
is_single_(true),
max_file_size_(DEFAULT_MAX_FILE_SIZE),
escaped_cht_(),
parallel_(1)
parallel_(1),
file_partition_expr_(NULL),
buffer_size_(DEFAULT_BUFFER_SIZE)
{
cs_type_ = ObCharset::get_system_collation();
}
@ -74,9 +76,10 @@ public:
ObItemType into_type_;
common::ObFixedArray<common::ObString, common::ObIAllocator> user_vars_;
common::ObObj outfile_name_;
common::ObObj field_str_;
common::ObObj field_str_; // FARM COMPAT WHITELIST FOR filed_str_: renamed
common::ObObj line_str_;
common::ObObj closed_cht_;
// 431以下版本select into无法并行执行, 不会序列化算子, 修改closed_cht_类型不会导致升级兼容性问题
common::ObObj closed_cht_; // FARM COMPAT WHITELIST FOR closed_cht_: change type
bool is_optional_;
common::ObFixedArray<ObExpr*, common::ObIAllocator> select_exprs_;
bool is_single_;
@ -84,7 +87,10 @@ public:
common::ObObj escaped_cht_;
common::ObCollationType cs_type_;
int64_t parallel_;
sql::ObExpr* file_partition_expr_;
int64_t buffer_size_;
static const int64_t DEFAULT_MAX_FILE_SIZE = 256LL * 1024 * 1024;
static const int64_t DEFAULT_BUFFER_SIZE = 1LL * 1024 * 1024;
};
class ObSelectIntoOp : public ObOperator