MySQL
8.0.41
Source Code Documentation
Toggle main menu visibility
Main Page
Related Pages
Modules
Namespaces
Namespace List
Namespace Members
All
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Functions
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
z
Variables
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
y
z
Typedefs
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
Enumerations
a
b
c
d
e
f
g
i
k
l
m
n
o
p
r
s
t
u
v
w
Enumerator
a
b
c
d
e
f
g
h
i
j
l
m
n
o
p
q
r
s
t
u
v
w
x
z
Classes
Class List
Class Index
Class Hierarchy
Class Members
All
:
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
~
Functions
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
~
Variables
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Typedefs
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
z
Enumerations
a
b
c
d
e
f
g
h
i
k
l
m
n
o
p
q
r
s
t
u
v
w
x
Enumerator
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Related Functions
:
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
Files
File List
File Members
All
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Functions
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Variables
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Typedefs
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Enumerations
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
Enumerator
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
Macros
_
a
b
c
d
e
f
g
h
i
j
k
l
m
n
o
p
q
r
s
t
u
v
w
x
y
z
•
All
Classes
Namespaces
Files
Functions
Variables
Typedefs
Enumerations
Enumerator
Friends
Macros
Modules
Pages
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
private
static
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
inline
private
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
Parallel_reader_adapter
(size_t max_threads, ulint rowlen)
Parallel_reader_adapter
pending
(Thread_ctx *ctx) const
Parallel_reader_adapter
inline
private
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
Generated by
1.9.2
1.9.2 
