Apache Arrow (C++)
A columnar in-memory analytics layer designed to accelerate big data.
Public Member Functions | Static Public Member Functions | List of all members
arrow::ipc::MessageReader Class Referenceabstract

Abstract interface for a sequence of messages. More...

#include <arrow/ipc/message.h>

Public Member Functions

virtual ~MessageReader ()=default
 
virtual Status ReadNextMessage (std::unique_ptr< Message > *message)=0
 Read next Message from the interface. More...
 

Static Public Member Functions

static std::unique_ptr< MessageReaderOpen (io::InputStream *stream)
 Create MessageReader that reads from InputStream. More...
 
static std::unique_ptr< MessageReaderOpen (const std::shared_ptr< io::InputStream > &owned_stream)
 Create MessageReader that reads from owned InputStream. More...
 

Detailed Description

Abstract interface for a sequence of messages.

Since
0.5.0

Constructor & Destructor Documentation

◆ ~MessageReader()

virtual arrow::ipc::MessageReader::~MessageReader ( )
virtualdefault

Member Function Documentation

◆ Open() [1/2]

static std::unique_ptr<MessageReader> arrow::ipc::MessageReader::Open ( io::InputStream stream)
static

Create MessageReader that reads from InputStream.

◆ Open() [2/2]

static std::unique_ptr<MessageReader> arrow::ipc::MessageReader::Open ( const std::shared_ptr< io::InputStream > &  owned_stream)
static

Create MessageReader that reads from owned InputStream.

◆ ReadNextMessage()

virtual Status arrow::ipc::MessageReader::ReadNextMessage ( std::unique_ptr< Message > *  message)
pure virtual

Read next Message from the interface.

Parameters
[out]messagean arrow::ipc::Message instance
Returns
Status

The documentation for this class was generated from the following file: