/AWS1/CL_GLUCATALOGKAFKASOURCE¶
Specifies an Apache Kafka data store in the Data Catalog.
CONSTRUCTOR¶
IMPORTING¶
Required arguments:¶
iv_name TYPE /AWS1/GLUNODENAME /AWS1/GLUNODENAME¶
The name of the data store.
iv_table TYPE /AWS1/GLUENCLOSEDINSTRINGPRP /AWS1/GLUENCLOSEDINSTRINGPRP¶
The name of the table in the database to read from.
iv_database TYPE /AWS1/GLUENCLOSEDINSTRINGPRP /AWS1/GLUENCLOSEDINSTRINGPRP¶
The name of the database to read from.
Optional arguments:¶
iv_windowsize TYPE /AWS1/GLUBOXEDPOSITIVEINT /AWS1/GLUBOXEDPOSITIVEINT¶
The amount of time to spend processing each micro batch.
iv_detectschema TYPE /AWS1/GLUBOXEDBOOLEAN /AWS1/GLUBOXEDBOOLEAN¶
Whether to automatically determine the schema from the incoming data.
io_streamingoptions TYPE REF TO /AWS1/CL_GLUKAFKASTRMINGSRCO00 /AWS1/CL_GLUKAFKASTRMINGSRCO00¶
Specifies the streaming options.
io_datapreviewoptions TYPE REF TO /AWS1/CL_GLUSTRMINGDATAPREVI00 /AWS1/CL_GLUSTRMINGDATAPREVI00¶
Specifies options related to data preview for viewing a sample of your data.
Queryable Attributes¶
Name¶
The name of the data store.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_NAME() |
Getter for NAME, with configurable default |
ASK_NAME() |
Getter for NAME w/ exceptions if field has no value |
HAS_NAME() |
Determine if NAME has a value |
WindowSize¶
The amount of time to spend processing each micro batch.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_WINDOWSIZE() |
Getter for WINDOWSIZE, with configurable default |
ASK_WINDOWSIZE() |
Getter for WINDOWSIZE w/ exceptions if field has no value |
HAS_WINDOWSIZE() |
Determine if WINDOWSIZE has a value |
DetectSchema¶
Whether to automatically determine the schema from the incoming data.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_DETECTSCHEMA() |
Getter for DETECTSCHEMA, with configurable default |
ASK_DETECTSCHEMA() |
Getter for DETECTSCHEMA w/ exceptions if field has no value |
HAS_DETECTSCHEMA() |
Determine if DETECTSCHEMA has a value |
Table¶
The name of the table in the database to read from.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_TABLE() |
Getter for TABLE, with configurable default |
ASK_TABLE() |
Getter for TABLE w/ exceptions if field has no value |
HAS_TABLE() |
Determine if TABLE has a value |
Database¶
The name of the database to read from.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_DATABASE() |
Getter for DATABASE, with configurable default |
ASK_DATABASE() |
Getter for DATABASE w/ exceptions if field has no value |
HAS_DATABASE() |
Determine if DATABASE has a value |
StreamingOptions¶
Specifies the streaming options.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_STREAMINGOPTIONS() |
Getter for STREAMINGOPTIONS |
DataPreviewOptions¶
Specifies options related to data preview for viewing a sample of your data.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_DATAPREVIEWOPTIONS() |
Getter for DATAPREVIEWOPTIONS |