Top | ![]() |
![]() |
![]() |
![]() |
gboolean | garrow_input_stream_advance () |
gboolean | garrow_input_stream_align () |
GArrowTensor * | garrow_input_stream_read_tensor () |
guint64 | garrow_seekable_input_stream_get_size () |
gboolean | garrow_seekable_input_stream_get_support_zero_copy () |
GArrowBuffer * | garrow_seekable_input_stream_read_at () |
GArrowBufferInputStream * | garrow_buffer_input_stream_new () |
GArrowBuffer * | garrow_buffer_input_stream_get_buffer () |
GArrowMemoryMappedInputStream * | garrow_memory_mapped_input_stream_new () |
GArrowGIOInputStream * | garrow_gio_input_stream_new () |
GInputStream * | garrow_gio_input_stream_get_raw () |
#define | GARROW_TYPE_INPUT_STREAM |
struct | GArrowInputStreamClass |
#define | GARROW_TYPE_SEEKABLE_INPUT_STREAM |
struct | GArrowSeekableInputStreamClass |
#define | GARROW_TYPE_BUFFER_INPUT_STREAM |
struct | GArrowBufferInputStreamClass |
struct | GArrowMemoryMappedInputStream |
struct | GArrowGIOInputStream |
GObject ╰── GArrowInputStream ╰── GArrowSeekableInputStream ├── GArrowGIOInputStream ╰── GArrowMemoryMappedInputStream
GArrowInputStream is a base class for input stream.
GArrowSeekableInputStream is a base class for input stream that supports random access.
GArrowBufferInputStream is a class to read data on buffer.
GArrowMemoryMappedInputStream is a class to read data in file by mapping the file on memory. It supports zero copy.
GArrowGIOInputStream is a class for GInputStream
based input
stream.
gboolean garrow_input_stream_advance (GArrowInputStream *input_stream
,gint64 n_bytes
,GError **error
);
input_stream |
A GArrowInputStream. |
|
n_bytes |
The number of bytes to be advanced. |
|
error |
Return location for a GError or |
[nullable] |
Since: 0.11.0
gboolean garrow_input_stream_align (GArrowInputStream *input_stream
,gint32 alignment
,GError **error
);
input_stream |
A GArrowInputStream. |
|
alignment |
The byte multiple for the metadata prefix, usually 8 or 64, to ensure the body starts on a multiple of that alignment. |
|
error |
Return location for a GError or |
[nullable] |
Since: 0.11.0
GArrowTensor * garrow_input_stream_read_tensor (GArrowInputStream *input_stream
,GError **error
);
Since: 0.11.0
guint64 garrow_seekable_input_stream_get_size (GArrowSeekableInputStream *input_stream
,GError **error
);
gboolean
garrow_seekable_input_stream_get_support_zero_copy
(GArrowSeekableInputStream *input_stream
);
GArrowBuffer * garrow_seekable_input_stream_read_at (GArrowSeekableInputStream *input_stream
,gint64 position
,gint64 n_bytes
,GError **error
);
GArrowBufferInputStream *
garrow_buffer_input_stream_new (GArrowBuffer *buffer
);
GArrowBuffer *
garrow_buffer_input_stream_get_buffer (GArrowBufferInputStream *input_stream
);
GArrowMemoryMappedInputStream * garrow_memory_mapped_input_stream_new (const gchar *path
,GError **error
);
GArrowGIOInputStream *
garrow_gio_input_stream_new (GInputStream *gio_input_stream
);
Since: 0.5.0
GInputStream *
garrow_gio_input_stream_get_raw (GArrowGIOInputStream *input_stream
);
Since: 0.5.0
struct GArrowSeekableInputStreamClass { GArrowInputStreamClass parent_class; };
struct GArrowBufferInputStreamClass { GArrowSeekableInputStreamClass parent_class; };
struct GArrowMemoryMappedInputStream;
It wraps arrow::io::MemoryMappedFile
.