Package | Description |
---|---|
com.huawei.dli.sdk |
Modifier and Type | Method and Description |
---|---|
Queue |
DLIClient.createQueue(String queueName,
int cuCount,
ChargingMode chargingMode,
String description)
Create a queue.
|
Queue |
DLIClient.getDefaultQueue()
Get default queue,
get a Queue object and queueName is "default"
|
Queue |
Job.getQueue() |
Queue |
DLIClient.getQueue(String queueName)
Get a Queue object by queueName.Must be sure that the name exists,
otherwise throw exception:"There is no Queue named"
|
Modifier and Type | Method and Description |
---|---|
List<Queue> |
DLIClient.listAllQueues()
Lists the currently user-owned Queues.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TunnelJob.prepare(Queue queue,
String dbName,
String tblName,
String opType) |
protected void |
TunnelJob.prepare(Queue queue,
TableSchema tblSchema) |
Constructor and Description |
---|
DownloadJob(Queue queue,
DownloadJobParam jobParam)
Create a download job to download data from DLI.
|
DownloadJob(Queue queue,
SQLJob job)
Create a download job to download query result
|
DownloadJob(Queue queue,
SQLJob job,
Integer limit)
Create a download job to download query result
|
DownloadJob(Queue queue,
String dbName,
String tblName)
Create a download job to download data from DLI.
|
DownloadJob(Queue queue,
String dbName,
String tblName,
BadRecordPolicy badRecordPolicy)
Deprecated.
|
DownloadJob(Queue queue,
String dbName,
String tblName,
List<String> partitionSpecs)
Create a download job to download data from DLI.
|
DownloadJob(Queue queue,
String dbName,
String tblName,
PartitionSpec partitionSpec)
Create a download job to download data from DLI.
|
DownloadJob(Queue queue,
String dbName,
String tblName,
PartitionSpec partitionSpec,
BadRecordPolicy badRecordPolicy)
Deprecated.
|
DownloadJob(Queue queue,
String dbName,
String tblName,
String partitionSpec) |
DownloadJob(Queue queue,
String dbName,
String tblName,
String partitionSpec,
BadRecordPolicy badRecordPolicy)
Deprecated.
|
ExportJob(Queue queue,
String databaseName,
String tableName,
String dataPath) |
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) |
Job(Queue queue) |
SQLJob(Queue queue,
String sql) |
SQLJob(Queue queue,
String currentdb,
String sql) |
SQLJob(Queue queue,
String currentdb,
String sql,
String transactionId) |
UploadJob(Queue queue,
String dbName,
String tableName)
Deprecated.
|
UploadJob(Queue queue,
String dbName,
String tableName,
Boolean isOverwrite)
Create a upload job to upload data to DLI.
|
UploadJob(Queue queue,
String dbName,
String tableName,
PartitionSpec partitionSpec,
Boolean isOverwrite)
Create a upload job to upload data to DLI.
|
UploadJob(Queue queue,
String dbName,
String tableName,
String partitionSpec,
Boolean isOverwrite) |
Copyright © 2023. All rights reserved.