Eight-column base schema. All fields nullable so the schema is uniform across base and zero-filled replicated copies.
()
| 129 | /// Eight-column base schema. All fields nullable so the schema is |
| 130 | /// uniform across base and zero-filled replicated copies. |
| 131 | fn base_schema() -> SchemaRef { |
| 132 | Arc::new(Schema::new(vec![ |
| 133 | Field::new("id", DataType::Int64, true), |
| 134 | Field::new("value", DataType::Float64, true), |
| 135 | Field::new("count", DataType::Int64, true), |
| 136 | Field::new("ts", DataType::Date32, true), |
| 137 | Field::new("category", DataType::Utf8, true), |
| 138 | Field::new("flag", DataType::Utf8, true), |
| 139 | Field::new("status", DataType::Utf8, true), |
| 140 | Field::new("text", DataType::Utf8, true), |
| 141 | ])) |
| 142 | } |
| 143 | |
| 144 | /// Synthesize one batch of length `n` covering rows `[start, start+n)`. |
| 145 | fn synthesize_batch(start: usize, n: usize, schema: &SchemaRef) -> Result<RecordBatch> { |