ingest_hudi_funcs
ingest_funcs
easy_sql
easy_sql.data_process
easy_sql.local_spark
easy_sql.logger
easy_sql.report
easy_sql.spark_optimizer
easy_sql.sql_processor_debugger
easy_sql.sql_tester
sql_config
EsService
Reporter
base_url (str) –
should_send (bool) –
index (str) –
query (object) –
url_path (str) –
data (str) –
es_service (EsService) –
index_prefix (str) –
now (Any) –
es index:
PUT /{index_prefix}_task_report {
“mappings”: { “properties”: {“task_id”: { “type”: “wildcard” }, “report”: { “type”: “text” }, “created_at”: { “type”: “date”, “format”: “yyyy-MM-dd HH:mm:ss” } } }
“task_id”: { “type”: “wildcard” }, “report”: { “type”: “text” }, “created_at”: { “type”: “date”, “format”: “yyyy-MM-dd HH:mm:ss” }
}
task_id (str) –
report (str) –