Prepare an arrow Schema for transport over the Arrow Flight protocol Convert dictionary types to underlying types See hydrate_dictionary for more information
(
schema: &Schema,
dictionary_tracker: &mut DictionaryTracker,
send_dictionaries: bool,
)
| 649 | /// |
| 650 | /// See hydrate_dictionary for more information |
| 651 | fn prepare_schema_for_flight( |
| 652 | schema: &Schema, |
| 653 | dictionary_tracker: &mut DictionaryTracker, |
| 654 | send_dictionaries: bool, |
| 655 | ) -> Schema { |
| 656 | let fields: Fields = schema |
| 657 | .fields() |
| 658 | .iter() |
| 659 | .map(|field| prepare_field_for_flight(field, dictionary_tracker, send_dictionaries)) |
| 660 | .collect(); |
| 661 | |
| 662 | Schema::new(fields).with_metadata(schema.metadata().clone()) |
| 663 | } |
| 664 | |
| 665 | /// Split [`RecordBatch`] so it hopefully fits into a gRPC response. |
| 666 | /// |