Skip to content

KafkaTable

KafkaTable is a Table that supports read and write in kafka data source.

Name

KafkaTable uses KafkaTable name.

Capabilities

capabilities(): ju.Set[TableCapability]

capabilities is part of the Table abstraction.

capabilities is the following table capabilities:

Creating ScanBuilder

newScanBuilder(
  options: CaseInsensitiveStringMap): ScanBuilder

newScanBuilder is part of the SupportsRead abstraction.

newScanBuilder creates a KafkaScan.

Creating WriteBuilder

newWriteBuilder(
  info: LogicalWriteInfo): WriteBuilder

newWriteBuilder is part of the SupportsWrite abstraction.

newWriteBuilder creates a custom WriteBuilder with support for truncate and update.

buildForBatch

buildForBatch(): BatchWrite

buildForBatch is part of the WriteBuilder abstraction.

buildForBatch creates a KafkaBatchWrite.


Last update: 2020-11-13