| 30 | /// Operator that copies the contents of a database to file(s) |
| 31 | #[derive(Clone)] |
| 32 | pub struct CopyTo { |
| 33 | /// The relation that determines the tuples to write to the output file(s) |
| 34 | pub input: Arc<LogicalPlan>, |
| 35 | /// The location to write the file(s) |
| 36 | pub output_url: String, |
| 37 | /// Determines which, if any, columns should be used for hive-style partitioned writes |
| 38 | pub partition_by: Vec<String>, |
| 39 | /// File type trait |
| 40 | pub file_type: Arc<dyn FileType>, |
| 41 | /// SQL Options that can affect the formats |
| 42 | pub options: HashMap<String, String>, |
| 43 | /// The schema of the output (a single column "count") |
| 44 | pub output_schema: DFSchemaRef, |
| 45 | } |
| 46 | |
| 47 | impl Debug for CopyTo { |
| 48 | fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result { |
no outgoing calls
searching dependent graphs…