| 11 | /// A local filesystem data sink. |
| 12 | #[derive(Hash, PartialEq, Eq, PartialOrd, Ord, Clone, Debug, Serialize, Deserialize)] |
| 13 | pub struct CsvFile { |
| 14 | /// Path to a file on each workers local filesystem. |
| 15 | pub path: String, |
| 16 | /// Does the file include a header? |
| 17 | pub has_headers: bool, |
| 18 | /// Column delimiter to use. |
| 19 | pub delimiter: u8, |
| 20 | /// Allow flexible length records? |
| 21 | pub flexible: bool, |
| 22 | } |
| 23 | |
| 24 | impl Sinkable<u64> for CsvFile { |
| 25 | fn sink<S, P>( |