| 811 | } |
| 812 | |
| 813 | Status WriteTable(const Table& table, io::OutputStream* dst, |
| 814 | const WriteProperties& properties) { |
| 815 | if (properties.version == kFeatherV1Version) { |
| 816 | return WriteFeatherV1(table, dst); |
| 817 | } else { |
| 818 | IpcWriteOptions ipc_options = IpcWriteOptions::Defaults(); |
| 819 | ipc_options.unify_dictionaries = true; |
| 820 | ipc_options.allow_64bit = true; |
| 821 | ARROW_ASSIGN_OR_RAISE( |
| 822 | ipc_options.codec, |
| 823 | util::Codec::Create(properties.compression, properties.compression_level)); |
| 824 | |
| 825 | std::shared_ptr<RecordBatchWriter> writer; |
| 826 | ARROW_ASSIGN_OR_RAISE(writer, MakeFileWriter(dst, table.schema(), ipc_options)); |
| 827 | RETURN_NOT_OK(writer->WriteTable(table, properties.chunksize)); |
| 828 | return writer->Close(); |
| 829 | } |
| 830 | } |
| 831 | |
| 832 | } // namespace feather |
| 833 | } // namespace ipc |
nothing calls this directly
no test coverage detected