connectionType

string

The connection to SAP Vora can be configured directly using dsn or indirectly using connection.

Default: "dsn"

dsn

string

A valid data source name in the format v2://host:port/?binary=true. Make sure that you add /?binary=true to the end, because only binary transfer is available for the SAP Vora Transaction Coordinator.

Default: "v2://localhost:2204/?binary=true"

user

string

The user name if the connection is configured using dsn.

Default: ""

password

string

The password if the connection is configured using dsn.

Default: ""

connection

object

A valid connection configuration provided by ConnectionManager.

aggregation

bool

Enables the automatic aggregation of records to trigger a series of bulk inserts independently of the number of records contained in each Avro message.

Default: false

aggregateMaxBytes

int

Limits the maximal size of the aggregated records in bytes under the auto-aggregation mode. Until the aggregated records reach this limit, the records are aggregated.

Default: 4194304

aggregateMaxRecs

int

Limits the maximal number of the aggregated records under the auto-aggregation mode. Until the aggregated records reach this limit, the records are aggregated.

Default: 1000

aggregateMaxTime

int

Limits the maximal time in milliseconds to wait until flushing the aggregated records that have not reached the size constraints.

Default: 2000

databaseSchema

string

The database schema name.

Default: "TPCH"

engineType

string

The engine type ("DISK" or "SERIES").

Default: "DISK"

partitionKeyRegex

string

A regular expression to match some Avro field names to identify the partition key.

Default: ""

partitionCriterion

string

A partition function.

Default: false

tableType

string

The table type ("STREAMING").

Default: "STREAMING"

ingestionMode

string

The ingestion mode INSERT or UPSERT

Default: "INSERT"

primaryKeyRegex

string

A regular expression to match some record field names to identify the primary keys. The primary keys may be specified in the avro schema and this parameter is only useful when the primary keys are not specified in the avro schema.

Default: ""

in

message

out

message

Messages with the header properties that indicate the commit progress. If the input message does not contain a commit token (i.e., message header message.commit.token), no output will be generated.