MySQL 8.4.0
Source Code Documentation
Parallel_reader_adapter::Thread_ctx Struct Reference

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

Public Member Functions

 Thread_ctx ()
 Constructor. More...
 
 ~Thread_ctx ()=default
 Destructor. 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

◆ Thread_ctx()

Parallel_reader_adapter::Thread_ctx::Thread_ctx ( )

Constructor.

◆ ~Thread_ctx()

Parallel_reader_adapter::Thread_ctx::~Thread_ctx ( )
default

Destructor.

Member Data Documentation

◆ m_buffer

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

Buffer to store records to be sent to the adapter.

◆ m_n_read

size_t Parallel_reader_adapter::Thread_ctx::m_n_read {}

Number of records read.

◆ m_n_sent

size_t Parallel_reader_adapter::Thread_ctx::m_n_sent {}

Number of records sent to the adapter.

◆ m_partition_id

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: