Parallel_reader_adapter Member List

This is the complete list of members for Parallel_reader_adapter, including all inherited members.

ADAPTER_SEND_BUFFER_SIZE	Parallel_reader_adapter	privatestatic
add_scan(trx_t *trx, const Parallel_reader::Config &config, Parallel_reader::F &&f)	Parallel_reader_adapter
end(Parallel_reader::Thread_ctx *reader_thread_ctx)	Parallel_reader_adapter	private
End_fn typedef	Parallel_reader_adapter
init(Parallel_reader::Thread_ctx *reader_thread_ctx, row_prebuilt_t *prebuilt)	Parallel_reader_adapter	private
Init_fn typedef	Parallel_reader_adapter
is_buffer_full(Thread_ctx *ctx) const	Parallel_reader_adapter	inlineprivate
Load_fn typedef	Parallel_reader_adapter
m_batch_size	Parallel_reader_adapter	private
m_end_fn	Parallel_reader_adapter	private
m_init_fn	Parallel_reader_adapter	private
m_load_fn	Parallel_reader_adapter	private
m_mysql_row	Parallel_reader_adapter	private
m_parallel_reader	Parallel_reader_adapter	private
m_prebuilt	Parallel_reader_adapter	private
m_thread_ctxs	Parallel_reader_adapter	private
max_threads() const	Parallel_reader_adapter	inline
Parallel_reader_adapter(size_t max_threads, ulint rowlen, bool use_reserved_threads=false)	Parallel_reader_adapter
pending(Thread_ctx *ctx) const	Parallel_reader_adapter	inlineprivate
process_rows(const Parallel_reader::Ctx *reader_ctx)	Parallel_reader_adapter
run(void **thread_contexts, Init_fn init_fn, Load_fn load_fn, End_fn end_fn)	Parallel_reader_adapter
send_batch(Parallel_reader::Thread_ctx *reader_thread_ctx, size_t partition_id, uint64_t n_recs)	Parallel_reader_adapter	private
set(row_prebuilt_t *prebuilt)	Parallel_reader_adapter
~Parallel_reader_adapter()=default	Parallel_reader_adapter