| 1000 | } |
| 1001 | |
| 1002 | static void ReadOneBatchJson(const char* json, const Schema& expected_schema, |
| 1003 | std::shared_ptr<RecordBatch>* out) { |
| 1004 | auto buffer = Buffer::Wrap(json, strlen(json)); |
| 1005 | |
| 1006 | ASSERT_OK_AND_ASSIGN(auto reader, IntegrationJsonReader::Open(buffer)); |
| 1007 | |
| 1008 | AssertSchemaEqual(*reader->schema(), expected_schema, /*check_metadata=*/true); |
| 1009 | ASSERT_EQ(1, reader->num_record_batches()); |
| 1010 | |
| 1011 | ASSERT_OK_AND_ASSIGN(*out, reader->ReadRecordBatch(0)); |
| 1012 | ASSERT_OK((*out)->ValidateFull()); |
| 1013 | } |
| 1014 | |
| 1015 | TEST(TestJsonFileReadWrite, JsonExample1) { |
| 1016 | Schema ex_schema({field("foo", int32()), field("bar", float64())}); |
no test coverage detected