Get the schema of an Arrow RecordBatch as a reference.
(batch: &RecordBatch)
| 166 | |
| 167 | /// Get the schema of an Arrow RecordBatch as a reference. |
| 168 | pub fn batch_schema(batch: &RecordBatch) -> SchemaRef { |
| 169 | batch.schema() |
| 170 | } |
| 171 | |
| 172 | /// Compute SUM of a numeric column in a RecordBatch. |
| 173 | pub fn arrow_sum(batch: &RecordBatch, column_name: &str) -> Option<f64> { |