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

Class CreateIngestionJobsOptions

java.lang.Object

com.ibm.cloud.sdk.core.service.model.GenericModel

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

All Implemented Interfaces:

com.ibm.cloud.sdk.core.service.model.ObjectModel

public class CreateIngestionJobsOptions
extends com.ibm.cloud.sdk.core.service.model.GenericModel

The createIngestionJobs options.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CreateIngestionJobsOptions.Builder	Builder.
static interface	CreateIngestionJobsOptions.SourceFileType	Source file types (parquet or csv or json).

Method Summary

Modifier and Type	Method	Description
java.lang.String	authInstanceId()	Gets the authInstanceId.
java.lang.Boolean	createIfNotExist()	Gets the createIfNotExist.
IngestionJobPrototypeCsvProperty	csvProperty()	Gets the csvProperty.
java.lang.String	engineId()	Gets the engineId.
IngestionJobPrototypeExecuteConfig	executeConfig()	Gets the executeConfig.
java.lang.String	jobId()	Gets the jobId.
CreateIngestionJobsOptions.Builder	newBuilder()	New builder.
java.lang.String	partitionBy()	Gets the partitionBy.
java.lang.String	schema()	Gets the schema.
java.lang.String	sourceDataFiles()	Gets the sourceDataFiles.
java.lang.String	sourceFileType()	Gets the sourceFileType.
java.lang.String	targetTable()	Gets the targetTable.
java.lang.String	username()	Gets the username.
java.lang.Boolean	validateCsvHeader()	Gets the validateCsvHeader.

Methods inherited from class com.ibm.cloud.sdk.core.service.model.GenericModel

equals, hashCode, toString

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Method Detail

newBuilder

public CreateIngestionJobsOptions.Builder newBuilder()

New builder.

Returns:

a CreateIngestionJobsOptions builder

authInstanceId

public java.lang.String authInstanceId()

Gets the authInstanceId. watsonx.data instance ID.

Returns:

the authInstanceId

jobId

public java.lang.String jobId()

Gets the jobId. Job ID of the job.

Returns:

the jobId

sourceDataFiles

public java.lang.String sourceDataFiles()

Gets the sourceDataFiles. Comma separated source file or directory path.

Returns:

the sourceDataFiles

targetTable

public java.lang.String targetTable()

Gets the targetTable. Target table name in format catalog.schema.table.

Returns:

the targetTable

username

public java.lang.String username()

Gets the username. User submitting ingestion job.

Returns:

the username

createIfNotExist

public java.lang.Boolean createIfNotExist()

Gets the createIfNotExist. Create new target table (if True); Insert into pre-existing target table (if False).

Returns:

the createIfNotExist

csvProperty

public IngestionJobPrototypeCsvProperty csvProperty()

Gets the csvProperty. Ingestion CSV properties.

Returns:

the csvProperty

engineId

public java.lang.String engineId()

Gets the engineId. ID of the spark engine to be used for ingestion.

Returns:

the engineId

executeConfig

public IngestionJobPrototypeExecuteConfig executeConfig()

Gets the executeConfig. Ingestion engine configuration.

Returns:

the executeConfig

partitionBy

public java.lang.String partitionBy()

Gets the partitionBy. Partition by expression of the target table.

Returns:

the partitionBy

schema

public java.lang.String schema()

Gets the schema. Schema definition of the source table.

Returns:

the schema

sourceFileType

public java.lang.String sourceFileType()

Gets the sourceFileType. Source file types (parquet or csv or json).

Returns:

the sourceFileType

validateCsvHeader

public java.lang.Boolean validateCsvHeader()

Gets the validateCsvHeader. Validate CSV header if the target table exist.

Returns:

the validateCsvHeader