qosakiosk.blogg.se

Necessary because we hold a std::unique_ptr. Public Functions ~RandomAccessFile ( ) override ¶ Subclassed by arrow::io::HdfsReadableFile, arrow::io::internal::RandomAccessFileConcurrencyWrapper, arrow::io::ReadWriteFileInterface, arrow::py::PyReadableFile, parquet::ParquetInputWrapper, arrow::io::internal::RandomAccessFileConcurrencyWrapper, arrow::io::internal::RandomAccessFileConcurrencyWrapper, arrow::io::internal::RandomAccessFileConcurrencyWrapper, arrow::io::SlowInputStreamBase class arrow::io :: RandomAccessFile : public std::enable_shared_from_this, public arrow::io:: InputStream, public arrow::io:: Seekable ¶ Zero copy reads imply the use of Buffer-returning Read() overloads. Return true if InputStream is capable of zero copy Buffer reads. nbytes: the maximum number of bytes to see May return NotImplemented on streams that don’t support it. May trigger buffering if the requested size is larger than the number of buffered bytes. The view becomes invalid after any operation on the stream. Return zero-copy string_view to upcoming bytes.ĭo not modify the stream position. Public Functions Status Advance (int64_t nbytes ) ¶Īdvance or skip stream indicated number of bytes. Subclassed by arrow::io::internal::InputStreamConcurrencyWrapper, arrow::io::RandomAccessFile, arrow::io::StdinStream, arrow::io::TransformInputStream, arrow::io::internal::InputStreamConcurrencyWrapper, arrow::io::internal::InputStreamConcurrencyWrapper, arrow::io::SlowInputStreamBase class arrow::io :: InputStream : public virtual arrow::io:: FileInterface, public virtual arrow::io:: Readable ¶

Status Flush ( ) ¶įlush buffered bytes, if any. See Write(const void*, int64_t) for details. Since the Buffer owns its memory, this method can avoid a copy if buffering is required. Status Write ( const std::shared_ptr & data ) ¶ To avoid potentially large copies, use the Write variant that takes an owned Buffer.

In the case where the stream buffers the data, it will be copied. Depending on the semantics of the stream, the data may be written out immediately, held in a buffer, or written asynchronously. This method always processes the bytes in full. Public Functions Status Write ( const void * data, int64_t nbytes ) = 0 ¶