Apache Arrow (C++)
A columnar in-memory analytics layer designed to accelerate big data.
Classes | Namespaces | Enumerations | Functions | Variables
message.h File Reference
#include <cstdint>
#include <memory>
#include <string>
#include "arrow/status.h"
#include "arrow/util/macros.h"
#include "arrow/util/visibility.h"

Go to the source code of this file.

Classes

class  arrow::ipc::Message
 An IPC message including metadata and body. More...
 
class  arrow::ipc::MessageReader
 Abstract interface for a sequence of messages. More...
 

Namespaces

 arrow
 Top-level namespace for Apache Arrow C++ API.
 
 arrow::io
 
 arrow::ipc
 

Enumerations

enum  arrow::ipc::MetadataVersion : char { arrow::ipc::MetadataVersion::V1, arrow::ipc::MetadataVersion::V2, arrow::ipc::MetadataVersion::V3, arrow::ipc::MetadataVersion::V4 }
 

Functions

std::string arrow::ipc::FormatMessageType (Message::Type type)
 
Status arrow::ipc::ReadMessage (const int64_t offset, const int32_t metadata_length, io::RandomAccessFile *file, std::unique_ptr< Message > *message)
 Read encapsulated RPC message from position in file. More...
 
Status arrow::ipc::AlignStream (io::InputStream *stream, int32_t alignment=8)
 Advance stream to an 8-byte offset if its position is not a multiple of 8 already. More...
 
Status arrow::ipc::AlignStream (io::OutputStream *stream, int32_t alignment=8)
 Advance stream to an 8-byte offset if its position is not a multiple of 8 already. More...
 
Status arrow::ipc::CheckAligned (io::FileInterface *stream, int32_t alignment=8)
 Return error Status if file position is not a multiple of the indicated alignment. More...
 
Status arrow::ipc::ReadMessage (io::InputStream *stream, std::unique_ptr< Message > *message)
 Read encapsulated RPC message (metadata and body) from InputStream. More...
 

Variables

constexpr int arrow::ipc::kMaxNestingDepth = 64