KafkaTable¶

KafkaTable is a Table with read and write support for 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:

• BATCH_READ
• BATCH_WRITE
• MICRO_BATCH_READ
• CONTINUOUS_READ
• STREAMING_WRITE
• ACCEPT_ANY_SCHEMA

Creating ScanBuilder¶

newScanBuilder(
  options: CaseInsensitiveStringMap): ScanBuilder

newScanBuilder is part of the SupportsRead abstraction.

newScanBuilder creates a ScanBuilder that can create 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.