| 326 | virtual ~CollectListener() = default; |
| 327 | |
| 328 | Status OnSchemaDecoded(std::shared_ptr<Schema> schema, |
| 329 | std::shared_ptr<Schema> filtered_schema) override { |
| 330 | schema_ = std::move(schema); |
| 331 | filtered_schema_ = std::move(filtered_schema); |
| 332 | return Status::OK(); |
| 333 | } |
| 334 | |
| 335 | Status OnRecordBatchWithMetadataDecoded( |
| 336 | RecordBatchWithMetadata record_batch_with_metadata) override { |