Confluo  0.1.0
Public Member Functions | List of all members
confluo.rpc.RecordBatchBuilder Class Reference

Public Member Functions

void addRecord (ByteBuffer record) throws IOException
 
rpc_record_batch getBatch () throws IOException
 
void clear ()
 

Detailed Description

A builder for a batch of records

Member Function Documentation

◆ addRecord()

void confluo.rpc.RecordBatchBuilder.addRecord ( ByteBuffer  record) throws IOException
inline

Adds a record to the batch builder

Parameters
recordThe record to add to the batch builder

◆ clear()

void confluo.rpc.RecordBatchBuilder.clear ( )
inline

Clears the record batch builder

◆ getBatch()

rpc_record_batch confluo.rpc.RecordBatchBuilder.getBatch ( ) throws IOException
inline

Gets the record batch

Returns
The record batch containing the records

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