Skip to content

/AWS1/CL_GLUS3HUDICATALOGTGT

Specifies a target that writes to a Hudi data source in the Glue Data Catalog.

CONSTRUCTOR

IMPORTING

Required arguments:

iv_name TYPE /AWS1/GLUNODENAME /AWS1/GLUNODENAME

The name of the data target.

it_inputs TYPE /AWS1/CL_GLUONEINPUT_W=>TT_ONEINPUT TT_ONEINPUT

The nodes that are inputs to the data target.

iv_table TYPE /AWS1/GLUENCLOSEDINSTRINGPRP /AWS1/GLUENCLOSEDINSTRINGPRP

The name of the table in the database to write to.

iv_database TYPE /AWS1/GLUENCLOSEDINSTRINGPRP /AWS1/GLUENCLOSEDINSTRINGPRP

The name of the database to write to.

it_additionaloptions TYPE /AWS1/CL_GLUADDLOPTIONS_W=>TT_ADDITIONALOPTIONS TT_ADDITIONALOPTIONS

Specifies additional connection options for the connector.

Optional arguments:

it_partitionkeys TYPE /AWS1/CL_GLUENCLOSEDINSTRPRP00=>TT_GLUESTUDIOPATHLIST TT_GLUESTUDIOPATHLIST

Specifies native partitioning using a sequence of keys.

io_schemachangepolicy TYPE REF TO /AWS1/CL_GLUCATALOGSCHCHANGE00 /AWS1/CL_GLUCATALOGSCHCHANGE00

A policy that specifies update behavior for the crawler.

io_autodataquality TYPE REF TO /AWS1/CL_GLUAUTODATAQUALITY /AWS1/CL_GLUAUTODATAQUALITY

Specifies whether to automatically enable data quality evaluation for the S3 Hudi catalog target. When set to true, data quality checks are performed automatically during the write operation.

it_outputschemas TYPE /AWS1/CL_GLUGLUESCHEMA=>TT_GLUESCHEMAS TT_GLUESCHEMAS

Specifies the data schema for the S3 Hudi catalog target.


Queryable Attributes

Name

The name of the data target.

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

Inputs

The nodes that are inputs to the data target.

Accessible with the following methods

Method Description
GET_INPUTS() Getter for INPUTS, with configurable default
ASK_INPUTS() Getter for INPUTS w/ exceptions if field has no value
HAS_INPUTS() Determine if INPUTS has a value

PartitionKeys

Specifies native partitioning using a sequence of keys.

Accessible with the following methods

Method Description
GET_PARTITIONKEYS() Getter for PARTITIONKEYS, with configurable default
ASK_PARTITIONKEYS() Getter for PARTITIONKEYS w/ exceptions if field has no value
HAS_PARTITIONKEYS() Determine if PARTITIONKEYS has a value

Table

The name of the table in the database to write to.

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 write to.

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

AdditionalOptions

Specifies additional connection options for the connector.

Accessible with the following methods

Method Description
GET_ADDITIONALOPTIONS() Getter for ADDITIONALOPTIONS, with configurable default
ASK_ADDITIONALOPTIONS() Getter for ADDITIONALOPTIONS w/ exceptions if field has no v
HAS_ADDITIONALOPTIONS() Determine if ADDITIONALOPTIONS has a value

SchemaChangePolicy

A policy that specifies update behavior for the crawler.

Accessible with the following methods

Method Description
GET_SCHEMACHANGEPOLICY() Getter for SCHEMACHANGEPOLICY

AutoDataQuality

Specifies whether to automatically enable data quality evaluation for the S3 Hudi catalog target. When set to true, data quality checks are performed automatically during the write operation.

Accessible with the following methods

Method Description
GET_AUTODATAQUALITY() Getter for AUTODATAQUALITY

OutputSchemas

Specifies the data schema for the S3 Hudi catalog target.

Accessible with the following methods

Method Description
GET_OUTPUTSCHEMAS() Getter for OUTPUTSCHEMAS, with configurable default
ASK_OUTPUTSCHEMAS() Getter for OUTPUTSCHEMAS w/ exceptions if field has no value
HAS_OUTPUTSCHEMAS() Determine if OUTPUTSCHEMAS has a value