pipeline::etl::transform::transformer::greptime

Function values_to_row

Source 
pub(crate) fn values_to_row(
    schema_info: &mut SchemaInfo,
    values: Value,
    pipeline_ctx: &PipelineContext<'_>,
    row: Option<Vec<Value>>,
    need_calc_ts: bool,
) -> Result<Row>
Expand description

need_calc_ts happens in two cases:

  1. full greptime_identity
  2. auto-transform without transformer

if transform is present in custom pipeline in v2 mode we dont need to calc ts again, nor do we need to check ts column name