(batch: &'a RecordBatch, column: &str)
| 1711 | } |
| 1712 | |
| 1713 | fn ts_array<'a>(batch: &'a RecordBatch, column: &str) -> Result<&'a TimestampMillisecondArray> { |
| 1714 | let array = batch |
| 1715 | .column_by_name(column) |
| 1716 | .with_context(|| format!("column not found: {column}"))?; |
| 1717 | array |
| 1718 | .as_any() |
| 1719 | .downcast_ref::<TimestampMillisecondArray>() |
| 1720 | .with_context(|| format!("column {column} is not TimestampMillisecondArray")) |
| 1721 | } |
| 1722 | |
| 1723 | fn nullable_string_value(array: &StringArray, idx: usize) -> Option<String> { |
| 1724 | if array.is_null(idx) { |
no test coverage detected