[Enhancement](Load)Express the parameters of Stream Load using SQL

be/src/common/config.cpp

@@ -489,6 +489,15 @@ DEFINE_Int32(stream_load_record_expire_time_secs, "28800");
 // time interval to clean expired stream load records
 DEFINE_mInt64(clean_stream_load_record_interval_secs, "1800");
 
+// use memory in stream load default
+DEFINE_Int64(stream_load_exec_mem_limit, "214748364"); // 2G
+// The buffer size to store stream table function schema info
+DEFINE_Int64(stream_tvf_buffer_size, "1048576"); // 1MB
+// The exec timeout of stream load default
+DEFINE_Int32(stream_load_timeout_second, "10");
+// The timeout of BE wait FE report status
+DEFINE_Int32(stream_load_report_timeout_second, "3");
+
 // OlapTableSink sender's send interval, should be less than the real response time of a tablet writer rpc.
 // You may need to lower the speed when the sink receiver bes are too busy.
 DEFINE_mInt32(olap_table_sink_send_interval_ms, "1");

be/src/common/config.h

@@ -530,6 +530,15 @@ DECLARE_Int32(stream_load_record_expire_time_secs);
 // time interval to clean expired stream load records
 DECLARE_mInt64(clean_stream_load_record_interval_secs);
 
+// use memory in stream load default
+DECLARE_Int64(stream_load_exec_mem_limit); // 2G
+// The buffer size to store stream table function schema info
+DECLARE_Int64(stream_tvf_buffer_size); // 1MB
+// The exec timeout of stream load default
+DECLARE_Int32(stream_load_timeout_second);
+// The timeout of BE wait FE report status
+DECLARE_Int32(stream_load_report_timeout_second);
+
 // OlapTableSink sender's send interval, should be less than the real response time of a tablet writer rpc.
 // You may need to lower the speed when the sink receiver bes are too busy.
 DECLARE_mInt32(olap_table_sink_send_interval_ms);

be/src/http/action/stream_load.h

@@ -50,6 +50,9 @@ class StreamLoadAction : public HttpHandler {
     Status _data_saved_path(HttpRequest* req, std::string* file_path);
     Status _process_put(HttpRequest* http_req, std::shared_ptr<StreamLoadContext> ctx);
     void _save_stream_load_record(std::shared_ptr<StreamLoadContext> ctx, const std::string& str);
+    void _parse_format(const std::string& format_str, const std::string& compress_type_str,
+                       TFileFormatType::type* format_type, TFileCompressType::type* compress_type);
+    bool _is_format_support_streaming(TFileFormatType::type format);
 
 private:
     ExecEnv* _exec_env;