Airbyte Kotlin Bulk CDK
Toggle table of contents
0.1.92
jvm
Platform filter
jvm
Switch theme
Search in API
Airbyte Kotlin Bulk CDK
bulk-cdk-toolkit-load-db
/
io.airbyte.cdk.load.write.db
/
InsertLoader
Insert
Loader
interface
InsertLoader
<
Q
:
InsertLoaderRequest
>
:
LoadStrategy
Members
Types
Partitioning
Strategy
Link copied to clipboard
enum
PartitioningStrategy
:
Enum
<
InsertLoader.PartitioningStrategy
>
Properties
estimated
Byte
Size
Per
Request
Link copied to clipboard
open
val
estimatedByteSizePerRequest
:
Long
input
Partitions
Link copied to clipboard
open
override
val
inputPartitions
:
Int
max
Memory
Ratio
To
Use
For
Requests
Link copied to clipboard
open
val
maxMemoryRatioToUseForRequests
:
Double
num
Request
Builders
Link copied to clipboard
open
val
numRequestBuilders
:
Int
num
Request
Executors
Link copied to clipboard
open
val
numRequestExecutors
:
Int
partitioning
Strategy
Link copied to clipboard
open
val
partitioningStrategy
:
InsertLoader.PartitioningStrategy
Functions
create
Accumulator
Link copied to clipboard
abstract
fun
createAccumulator
(
streamDescriptor
:
DestinationStream.Descriptor
,
partition
:
Int
)
:
InsertLoaderRequestBuilder
<
Q
>