renmae option

Author: zhanglei1949

flex/storages/rt_mutable_graph/loading_config.cc

@@ -425,7 +425,7 @@ static bool parse_bulk_load_config_file(const std::string& config_file,
         load_config.metadata_[reader_options::DOUBLE_QUOTE] = "false";
         load_config.metadata_[reader_options::ESCAPE_CHAR] = "\\";
         load_config.metadata_[reader_options::ESCAPING] = "false";
-        load_config.metadata_[reader_options::BLOCK_SIZE_KEY] =
+        load_config.metadata_[reader_options::BATCH_SIZE_KEY] =
             std::to_string(reader_options::DEFAULT_BLOCK_SIZE);
         load_config.metadata_[reader_options::BATCH_READER] = "false";
         // put all key values in meta_data into metadata_
@@ -443,12 +443,12 @@ static bool parse_bulk_load_config_file(const std::string& config_file,
                     << " value: " << it->second.as<std::string>();
             if (reader_options::CSV_META_KEY_WORDS.find(key) !=
                 reader_options::CSV_META_KEY_WORDS.end()) {
-              if (key == reader_options::BLOCK_SIZE_KEY) {
+              if (key == reader_options::BATCH_SIZE_KEY) {
                 // special case for block size
                 // parse block size (MB, b, KB, B) to bytes
                 auto block_size_str = it->second.as<std::string>();
                 auto block_size = parse_block_size(block_size_str);
-                load_config.metadata_[reader_options::BLOCK_SIZE_KEY] =
+                load_config.metadata_[reader_options::BATCH_SIZE_KEY] =
                     std::to_string(block_size);
               } else {
                 load_config.metadata_[key] = it->second.as<std::string>();
@@ -608,10 +608,10 @@ bool LoadingConfig::GetIsDoubleQuoting() const {
 
 // get block size
 int32_t LoadingConfig::GetBlockSize() const {
-  if (metadata_.find(reader_options::BLOCK_SIZE_KEY) == metadata_.end()) {
+  if (metadata_.find(reader_options::BATCH_SIZE_KEY) == metadata_.end()) {
     return reader_options::DEFAULT_BLOCK_SIZE;
   }
-  auto str = metadata_.at(reader_options::BLOCK_SIZE_KEY);
+  auto str = metadata_.at(reader_options::BATCH_SIZE_KEY);
   return std::stoi(str);
 }
 

flex/storages/rt_mutable_graph/loading_config.h

@@ -45,15 +45,16 @@ static const char* ESCAPE_CHAR = "escape_char";
 static const char* QUOTING = "quoting";
 static const char* QUOTE_CHAR = "quote_char";
 static const char* DOUBLE_QUOTE = "double_quote";
-static const char* BLOCK_SIZE_KEY = "block_size";
+static const char* BATCH_SIZE_KEY = "batch_size";
 // whether or not to use record batch reader. If true, the reader will read
 // data in batches, otherwise, the reader will read data row by row.
 static const char* BATCH_READER = "batch_reader";
 
 // static unordered_set
 static const std::unordered_set<std::string> CSV_META_KEY_WORDS = {
-    DELIMITER,   HEADER_ROW, INCLUDE_COLUMNS, COLUMN_TYPES, ESCAPING,
-    ESCAPE_CHAR, QUOTING,    QUOTE_CHAR,      DOUBLE_QUOTE, BLOCK_SIZE_KEY,BATCH_READER};
+    DELIMITER,    HEADER_ROW,     INCLUDE_COLUMNS, COLUMN_TYPES,
+    ESCAPING,     ESCAPE_CHAR,    QUOTING,         QUOTE_CHAR,
+    DOUBLE_QUOTE, BATCH_SIZE_KEY, BATCH_READER};
 
 }  // namespace reader_options