Callback thread context for each of the spawned threads. More...

Public Attributes
size_t	m_n_read {}
	Number of records read. More...

size_t	m_n_sent {}
	Number of records sent to the adapter. More...

size_t	m_partition_id {std::numeric_limits<size_t>::max()}
	Partition ID for the records in buffer. More...

std::vector< byte, ut::allocator< byte > >	m_buffer
	Buffer to store records to be sent to the adapter. More...

Detailed Description

Callback thread context for each of the spawned threads.

Constructor & Destructor Documentation

Parallel_reader_adapter::Thread_ctx::Thread_ctx ( )

Constructor.

Parallel_reader_adapter::Thread_ctx::~Thread_ctx ( )

default

Destructor.

std::vector<byte, ut::allocator<byte> > Parallel_reader_adapter::Thread_ctx::m_buffer

Buffer to store records to be sent to the adapter.

size_t Parallel_reader_adapter::Thread_ctx::m_n_read {}

Number of records read.

size_t Parallel_reader_adapter::Thread_ctx::m_n_sent {}

Number of records sent to the adapter.

size_t Parallel_reader_adapter::Thread_ctx::m_partition_id {std::numeric_limits<size_t>::max()}

Partition ID for the records in buffer.

Must be set when adding more records to be sent i.e. while incrementing m_n_read.

The documentation for this struct was generated from the following files: