()
| 514 | |
| 515 | #[test] |
| 516 | fn write_simple_rows() { |
| 517 | let schema = Schema::new(vec![ |
| 518 | Field::new("c1", DataType::Int32, true), |
| 519 | Field::new("c2", DataType::Utf8, true), |
| 520 | ]); |
| 521 | |
| 522 | let a = Int32Array::from(vec![Some(1), Some(2), Some(3), None, Some(5)]); |
| 523 | let b = StringArray::from(vec![Some("a"), Some("b"), Some("c"), Some("d"), None]); |
| 524 | |
| 525 | let batch = RecordBatch::try_new(Arc::new(schema), vec![Arc::new(a), Arc::new(b)]).unwrap(); |
| 526 | |
| 527 | let mut buf = Vec::new(); |
| 528 | { |
| 529 | let mut writer = LineDelimitedWriter::new(&mut buf); |
| 530 | writer.write_batches(&[&batch]).unwrap(); |
| 531 | } |
| 532 | |
| 533 | assert_json_eq( |
| 534 | &buf, |
| 535 | r#"{"c1":1,"c2":"a"} |
| 536 | {"c1":2,"c2":"b"} |
| 537 | {"c1":3,"c2":"c"} |
| 538 | {"c2":"d"} |
| 539 | {"c1":5} |
| 540 | "#, |
| 541 | ); |
| 542 | } |
| 543 | |
| 544 | #[test] |
| 545 | fn write_large_utf8_and_utf8_view() { |
nothing calls this directly
no test coverage detected