async fn ingest_events(
handler: PipelineHandlerRef,
pipeline: PipelineDefinition,
requests: Vec<PipelineIngestRequest>,
query_ctx: QueryContextRef,
pipeline_params: GreptimePipelineParams,
tag_columns: HashMap<String, HashSet<String>>,
apply_tags: bool,
) -> Result<HttpResponse>Expand description
Like ingest_logs_inner, but retags metadata columns (identity default) before insert.