Home
last modified time | relevance | path

Searched refs:SerializedPageReader (Results 1 – 13 of 13) sorted by relevance

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/file/
H A Dserialized_reader.rs214 let page_reader = SerializedPageReader::new( in get_column_page_reader()
229 pub struct SerializedPageReader<T: Read> { struct
247 impl<T: Read> SerializedPageReader<T> { implementation
274 impl<T: Read> PageReader for SerializedPageReader<T> { implementation
H A Dreader.rs27 pub use crate::file::serialized_reader::{SerializedFileReader, SerializedPageReader};
H A Dwriter.rs541 reader::{FileReader, SerializedFileReader, SerializedPageReader},
923 let mut page_reader = SerializedPageReader::new( in test_page_roundtrip()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dcolumn_reader.cc168 class SerializedPageReader : public PageReader { class
170 SerializedPageReader(std::shared_ptr<ArrowInputStream> stream, int64_t total_num_rows, in SerializedPageReader() function in parquet::SerializedPageReader
241 void SerializedPageReader::InitDecryption() { in InitDecryption()
257 void SerializedPageReader::UpdateDecryption(const std::shared_ptr<Decryptor>& decryptor, in UpdateDecryption()
272 std::shared_ptr<Page> SerializedPageReader::NextPage() { in NextPage()
401 std::shared_ptr<Buffer> SerializedPageReader::DecompressPage(int compressed_len, in DecompressPage()
438 new SerializedPageReader(std::move(stream), total_num_rows, codec, pool, ctx)); in Open()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dcolumn_reader.cc215 class SerializedPageReader : public PageReader { class
217 SerializedPageReader(std::shared_ptr<ArrowInputStream> stream, int64_t total_num_rows, in SerializedPageReader() function in parquet::__anonb497d7530211::SerializedPageReader
289 void SerializedPageReader::InitDecryption() { in InitDecryption()
305 void SerializedPageReader::UpdateDecryption(const std::shared_ptr<Decryptor>& decryptor, in UpdateDecryption()
320 std::shared_ptr<Page> SerializedPageReader::NextPage() { in NextPage()
471 std::shared_ptr<Buffer> SerializedPageReader::DecompressIfNeeded( in DecompressIfNeeded()
509 new SerializedPageReader(std::move(stream), total_num_rows, codec, pool, ctx)); in Open()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/parquet/
H A Dcolumn_reader.cc215 class SerializedPageReader : public PageReader { class
217 SerializedPageReader(std::shared_ptr<ArrowInputStream> stream, int64_t total_num_rows, in SerializedPageReader() function in parquet::__anon2568aa120211::SerializedPageReader
289 void SerializedPageReader::InitDecryption() { in InitDecryption()
305 void SerializedPageReader::UpdateDecryption(const std::shared_ptr<Decryptor>& decryptor, in UpdateDecryption()
320 std::shared_ptr<Page> SerializedPageReader::NextPage() { in NextPage()
471 std::shared_ptr<Buffer> SerializedPageReader::DecompressIfNeeded( in DecompressIfNeeded()
509 new SerializedPageReader(std::move(stream), total_num_rows, codec, pool, ctx)); in Open()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/parquet/src/file/
H A Dreader.rs368 let page_reader = SerializedPageReader::new( in get_column_page_reader()
422 pub struct SerializedPageReader<T: Read> { struct
440 impl<T: Read> SerializedPageReader<T> { argument
467 impl<T: Read> PageReader for SerializedPageReader<T> { implementation
H A Dwriter.rs535 reader::{FileReader, SerializedFileReader, SerializedPageReader},
917 let mut page_reader = SerializedPageReader::new( in test_page_roundtrip()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/parquet/src/column/
H A Dwriter.rs858 properties::WriterProperties, reader::SerializedPageReader,
1431 SerializedPageReader::new( in test_column_writer_add_data_pages_with_dict()
1542 SerializedPageReader::new( in column_roundtrip()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/column/
H A Dwriter.rs999 properties::WriterProperties, reader::SerializedPageReader,
1631 SerializedPageReader::new( in test_column_writer_add_data_pages_with_dict()
1742 SerializedPageReader::new( in column_roundtrip()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/
H A DCHANGELOG_PARQUET.md369 * [PARQUET-641] - Instantiate stringstream only if needed in SerializedPageReader::NextPage
/dports/databases/arrow/apache-arrow-6.0.1/cpp/
H A DCHANGELOG_PARQUET.md369 * [PARQUET-641] - Instantiate stringstream only if needed in SerializedPageReader::NextPage
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/
H A DCHANGELOG_PARQUET.md369 * [PARQUET-641] - Instantiate stringstream only if needed in SerializedPageReader::NextPage