Package com.ibm.cloud.watsonxdata.watsonx_data.v2.model

Class IngestionJob

  • All Implemented Interfaces:
    com.ibm.cloud.sdk.core.service.model.ObjectModel
    public class IngestionJob
extends com.ibm.cloud.sdk.core.service.model.GenericModel
    Ingestion job.

    • Method Detail

      • isCreateIfNotExist

        public java.lang.Boolean isCreateIfNotExist()
        Gets the createIfNotExist. Create new target table (if True); Insert into pre-existing target table (if False).
        Returns:
        the createIfNotExist

      • getCsvProperty

        public IngestionJobCsvProperty getCsvProperty()
        Gets the csvProperty. Ingestion CSV properties.
        Returns:
        the csvProperty

      • getDetails

        public java.lang.String getDetails()
        Gets the details. Error messages of failed ingestion job.
        Returns:
        the details

      • getEndTimestamp

        public java.lang.String getEndTimestamp()
        Gets the endTimestamp. Unix timestamp of ingestion job completing.
        Returns:
        the endTimestamp

      • getEngineId

        public java.lang.String getEngineId()
        Gets the engineId. ID of the spark engine to be used for ingestion.
        Returns:
        the engineId

      • getEngineName

        public java.lang.String getEngineName()
        Gets the engineName. Name of the spark engine to be used for ingestion.
        Returns:
        the engineName

      • getExecuteConfig

        public IngestionJobExecuteConfig getExecuteConfig()
        Gets the executeConfig. Ingestion engine configuration.
        Returns:
        the executeConfig

      • getInstanceId

        public java.lang.String getInstanceId()
        Gets the instanceId. Instance ID of the lakehouse where ingestion job is executed.
        Returns:
        the instanceId

      • getJobId

        public java.lang.String getJobId()
        Gets the jobId. Job ID of the ingestion job.
        Returns:
        the jobId

      • getPartitionBy

        public java.lang.String getPartitionBy()
        Gets the partitionBy. partition by expression of the target table.
        Returns:
        the partitionBy

      • getSchema

        public java.lang.String getSchema()
        Gets the schema. Schema definition of the source table.
        Returns:
        the schema

      • getSourceDataFiles

        public java.lang.String getSourceDataFiles()
        Gets the sourceDataFiles. Source data location of the ingestion job.
        Returns:
        the sourceDataFiles

      • getSourceFileType

        public java.lang.String getSourceFileType()
        Gets the sourceFileType. Source file types (parquet or csv).
        Returns:
        the sourceFileType

      • getStartTimestamp

        public java.lang.String getStartTimestamp()
        Gets the startTimestamp. Unix timestamp of ingestion job starting.
        Returns:
        the startTimestamp

      • getStatus

        public java.lang.String getStatus()
        Gets the status. Current state of ingestion job.
        Returns:
        the status

      • getTargetTable

        public java.lang.String getTargetTable()
        Gets the targetTable. Target table name in format catalog.schema.table.
        Returns:
        the targetTable

      • getUsername

        public java.lang.String getUsername()
        Gets the username. Ingestion job user.
        Returns:
        the username

      • isValidateCsvHeader

        public java.lang.Boolean isValidateCsvHeader()
        Gets the validateCsvHeader. Validate CSV header if the target table exist.
        Returns:
        the validateCsvHeader