Documentation ¶
Index ¶
- Variables
- func AnyTablesUdf(table abstract.TableID, schema abstract.TableColumns) bool
- func MakeDebeziumSerDeUdfWithCheck(emitter *debezium.Emitter, receiver *debezium.Receiver) helpers.SimpleTransformerApplyUDF
- func MakeDebeziumSerDeUdfWithoutCheck(emitter *debezium.Emitter, receiver *debezium.Receiver) helpers.SimpleTransformerApplyUDF
- func MakeYdb2YdbDebeziumSerDeUdf(pathOut string, outLastInsert *abstract.ChangeItem, emitter *debezium.Emitter, ...) helpers.SimpleTransformerApplyUDF
Constants ¶
This section is empty.
Variables ¶
View Source
var CountOfProcessedMessage = 0
Functions ¶
func AnyTablesUdf ¶
func AnyTablesUdf(table abstract.TableID, schema abstract.TableColumns) bool
func MakeYdb2YdbDebeziumSerDeUdf ¶
func MakeYdb2YdbDebeziumSerDeUdf(pathOut string, outLastInsert *abstract.ChangeItem, emitter *debezium.Emitter, receiver *debezium.Receiver) helpers.SimpleTransformerApplyUDF
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.