public class ImportJob extends Job
JOB_TIMEOUT_SECOND
client, JOB_TRANSACTION_ERROR_CODE
Constructor and Description |
---|
ImportJob(Queue queue,
String databaseName,
String tableName,
String dataPath) |
ImportJob(Queue queue,
String databaseName,
String tableName,
String dataPath,
PartitionSpec partitionSpec,
Boolean isOverWrite) |
ImportJob(Queue queue,
String databaseName,
String tableName,
String dataPath,
String partitionSpec,
Boolean isOverWrite) |
Modifier and Type | Method and Description |
---|---|
void |
asyncSubmit() |
void |
setCsvFormatInfo(CsvFormatInfo csvFormatInfo) |
void |
setOverWrite(Boolean overWrite) |
void |
setPartitionSpec(PartitionSpec partitionSpec) |
void |
setStorageType(StorageType storageType) |
void |
submit()
Submit import job
|
cancelJob, checkJobFinish, checkJobFinish, checkJobRunningStatus, getConf, getJobId, getJobTimeout, getJobType, getProjectId, getQueue, getStatus, getStatusResult, getTags, getTransactionKeyName, setConf, setJobId, setJobTimeout, setJobType, setTags
apiExceptionRetryManage, executeCall, executeWithRetry, getTransactionId, isServiceInsideError, setTransactionId
public ImportJob(Queue queue, String databaseName, String tableName, String dataPath, String partitionSpec, Boolean isOverWrite)
public void setStorageType(StorageType storageType)
public void setCsvFormatInfo(CsvFormatInfo csvFormatInfo)
public void setOverWrite(Boolean overWrite)
public void setPartitionSpec(PartitionSpec partitionSpec)
public void submit() throws DLIException
submit
in class Job
DLIException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic void asyncSubmit() throws DLIException
DLIException
Copyright © 2023. All rights reserved.