Airbyte Kotlin Bulk CDK
Toggle table of contents
1.0.2
jvm
Platform filter
jvm
Switch theme
Search in API
Airbyte Kotlin Bulk CDK
bulk-cdk-toolkit-legacy-task-load-db
/
io.airbyte.cdk.load.write.db
/
BulkLoaderFactory
Bulk
Loader
Factory
interface
BulkLoaderFactory
<
K
:
WithStream
,
T
:
RemoteObject
<
*
>
>
:
ObjectLoader
Members
Properties
input
Partitions
Link copied to clipboard
open
override
val
inputPartitions
:
Int
max
Memory
Ratio
Reserved
For
Parts
Link copied to clipboard
open
val
maxMemoryRatioReservedForParts
:
Double
max
Num
Concurrent
Loads
Link copied to clipboard
abstract
val
maxNumConcurrentLoads
:
Int
num
Part
Workers
Link copied to clipboard
open
val
numPartWorkers
:
Int
num
Upload
Completers
Link copied to clipboard
open
val
numUploadCompleters
:
Int
num
Upload
Workers
Link copied to clipboard
open
val
numUploadWorkers
:
Int
object
Size
Bytes
Link copied to clipboard
open
val
objectSizeBytes
:
Long
part
Size
Bytes
Link copied to clipboard
open
val
partSizeBytes
:
Long
state
After
Upload
Link copied to clipboard
open
override
val
stateAfterUpload
:
BatchState
Functions
create
Link copied to clipboard
abstract
fun
create
(
key
:
K
,
partition
:
Int
)
:
BulkLoader
<
T
>
socket
Part
Size
Bytes
Link copied to clipboard
open
fun
socketPartSizeBytes
(
numberOfSockets
:
Int
)
:
Long
socket
Upload
Parallelism
Link copied to clipboard
open
fun
socketUploadParallelism
(
numberOfSockets
:
Int
)
:
Int