| 321 | virtual ~CollectListener() = default; |
| 322 | |
| 323 | Status OnSchemaDecoded(std::shared_ptr<Schema> schema, |
| 324 | std::shared_ptr<Schema> filtered_schema) override { |
| 325 | schema_ = std::move(schema); |
| 326 | filtered_schema_ = std::move(filtered_schema); |
| 327 | return Status::OK(); |
| 328 | } |
| 329 | |
| 330 | Status OnRecordBatchWithMetadataDecoded( |
| 331 | RecordBatchWithMetadata record_batch_with_metadata) override { |