Function comment_ai_chunks_schema

crates/store/src/comments_store.rs:959–969

()

}

pub fn comment_ai_chunks_schema() -> Arc<Schema> {
    Arc::new(Schema::new(vec![
        Field::new("chunk_id", DataType::Utf8, false),
        Field::new("run_id", DataType::Utf8, false),
        Field::new("task_id", DataType::Utf8, false),
        low_cardinality_utf8_field("stream", false),
        Field::new("batch_index", DataType::Int32, false),
        compressed_utf8_field("content", false),
        Field::new("created_at", DataType::Timestamp(TimeUnit::Millisecond, None), false),
    ]))
}

fn build_comment_task_batch(record: &CommentTaskRecord) -> Result<RecordBatch> {
    let mut task_id = StringBuilder::new();