Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W 

A

AbstractPrimitiveTypeInfo - Class in com.huawei.dli.sdk.common
 
AbstractPrimitiveTypeInfo(DataType) - Constructor for class com.huawei.dli.sdk.common.AbstractPrimitiveTypeInfo
 
AbstractPrimitiveTypeInfo() - Constructor for class com.huawei.dli.sdk.common.AbstractPrimitiveTypeInfo
 
addConfItem(String, String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
addPartitionSpec(PartitionSpec) - Method in class com.huawei.dli.sdk.common.DownloadJobParam
 
addPartitionSpecs(List<PartitionSpec>) - Method in class com.huawei.dli.sdk.common.DownloadJobParam
 
AkskAuthentication - Class in com.huawei.dli.sdk.authentication
 
AkskAuthentication(String, String, String) - Constructor for class com.huawei.dli.sdk.authentication.AkskAuthentication
 
AkskAuthentication(String, String, String, String) - Constructor for class com.huawei.dli.sdk.authentication.AkskAuthentication
 
apiExceptionRetryManage(int, String, String, int, boolean) - Method in class com.huawei.dli.sdk.BaseJob
 
appendData(DataBlock) - Method in class com.huawei.dli.sdk.common.DataBlock
 
appendData(byte[]) - Method in class com.huawei.dli.sdk.common.DataBlock
 
applyToParams(String, String, List<Pair>, Map<String, String>, Object) - Method in class com.huawei.dli.sdk.authentication.AkskAuthentication
 
ArrayTypeInfo - Interface in com.huawei.dli.sdk.common.type
 
asyncSubmit() - Method in class com.huawei.dli.sdk.BatchJob
 
asyncSubmit() - Method in class com.huawei.dli.sdk.ImportJob
 
asyncSubmit() - Method in class com.huawei.dli.sdk.SparkJob
Submit a Spark job in async.
asyncSubmit() - Method in class com.huawei.dli.sdk.SQLJob
 
Authentication - Class in com.huawei.dli.sdk.authentication
 
Authentication(AuthenticationMode, DLIInfo) - Constructor for class com.huawei.dli.sdk.authentication.Authentication
 
AuthenticationMode - Enum in com.huawei.dli.sdk.authentication
 
authorizeBucket(ObsBuckets) - Method in class com.huawei.dli.sdk.DLIClient
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等
AvroObsReader - Class in com.huawei.dli.sdk
Read avro file from OBS, the avro files are generated by Spark.
AvroObsReader(DownloadJob, String, String, String, String, String) - Constructor for class com.huawei.dli.sdk.AvroObsReader
Deprecated.
AvroObsReader(DownloadJob, String, String, String, List<ObsObject>) - Constructor for class com.huawei.dli.sdk.AvroObsReader
 
AvroObsWriter - Class in com.huawei.dli.sdk
On dli-avro, TINYINT/SMALLINT/INT is int, DECIMAL is string, DATE/TIMESTAMP is long when write data, but don't support tinyint/smallint when read data, so don't use it.
AvroObsWriter(UploadJob, String, String, String, String, String) - Constructor for class com.huawei.dli.sdk.AvroObsWriter
 

B

BadRecordPolicy - Enum in com.huawei.dli.sdk.common
 
BaseJob - Class in com.huawei.dli.sdk
 
BaseJob(DLIClient) - Constructor for class com.huawei.dli.sdk.BaseJob
 
BaseJob(DLIClient, String) - Constructor for class com.huawei.dli.sdk.BaseJob
 
BatchJob - Class in com.huawei.dli.sdk
 
BatchJob(Cluster, SparkJobInfo) - Constructor for class com.huawei.dli.sdk.BatchJob
 
BatchJob(Cluster, SparkJobInfo, String) - Constructor for class com.huawei.dli.sdk.BatchJob
 
BatchListFilter - Class in com.huawei.dli.sdk.common
 
BatchListFilter() - Constructor for class com.huawei.dli.sdk.common.BatchListFilter
 
beginCommit() - Method in class com.huawei.dli.sdk.UploadJob
 
beginCommit(String) - Method in class com.huawei.dli.sdk.UploadJob
 
BIGINT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
BOOLEAN - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
bucketName - Variable in class com.huawei.dli.sdk.TunnelJob
 

C

cancelExportJob() - Method in class com.huawei.dli.sdk.SQLJob
If exportResult is RUNNING or LAUNCHING,you can cancel it.
cancelJob(String) - Method in class com.huawei.dli.sdk.DLIClient
Cancel LAUNCHING,RUNNING status job, and the job status changes to CANCELLED.
cancelJob() - Method in class com.huawei.dli.sdk.Job
Cancel RUNNING or LAUNCHING status job.
ChargingMode - Enum in com.huawei.dli.sdk.common
 
checkForNoResult(String) - Static method in class com.huawei.dli.sdk.common.utils.SqlUtils
 
checkJobFinish(long, JobResultInfo) - Method in class com.huawei.dli.sdk.Job
 
checkJobFinish(long, JobResultInfo, Long) - Method in class com.huawei.dli.sdk.Job
 
checkJobRunningState() - Method in class com.huawei.dli.sdk.SparkJob
 
checkJobRunningStatus(String) - Method in class com.huawei.dli.sdk.Job
Check job running status by jobId after submit(), when job status is FINISHED,FAILED,CANCELLED,mean job is over.
checkSQL(String) - Method in class com.huawei.dli.sdk.DLIClient
Check the syntax of SQL, if syntax is wrong, it will throw exception.
checkSQL(String, String) - Method in class com.huawei.dli.sdk.DLIClient
Check the syntax of SQL, if syntax is wrong, it will throw exception.
client - Variable in class com.huawei.dli.sdk.BaseJob
 
close() - Method in class com.huawei.dli.sdk.AvroObsReader
 
close() - Method in class com.huawei.dli.sdk.AvroObsWriter
 
close() - Method in class com.huawei.dli.sdk.JsonObsReader
 
close() - Method in class com.huawei.dli.sdk.ObsReader
 
close() - Method in class com.huawei.dli.sdk.ObsWriter
 
close() - Method in interface com.huawei.dli.sdk.Reader
 
close() - Method in class com.huawei.dli.sdk.Writer
 
closed - Variable in class com.huawei.dli.sdk.AvroObsReader
 
closed - Variable in class com.huawei.dli.sdk.AvroObsWriter
 
closed - Variable in class com.huawei.dli.sdk.JsonObsReader
 
closed - Variable in class com.huawei.dli.sdk.ObsReader
 
closeObsClient() - Method in class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
Cluster - Class in com.huawei.dli.sdk
 
Cluster(String, String, int, String, long, String, DLIClient) - Constructor for class com.huawei.dli.sdk.Cluster
 
Column - Class in com.huawei.dli.sdk.common
 
Column(String, DataTypeInfo, String, boolean) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance, Constructor parameters:column name, dataTypeInfo, description, isPartitionColumn.
Column(String, DataTypeInfo, String) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance, Constructor parameters:column name, dataTypeInfo, description.
Column(String, DataTypeInfo) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance,don't need description.
Column(String, DataType, String) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance, Constructor parameters:column name, data type, description.
Column(String, DataType, String, boolean) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance, Constructor parameters:column name, data type, description, isPartitionColumn.
Column(String, DataType) - Constructor for class com.huawei.dli.sdk.common.Column
Create Column instance,don't need description.
com.huawei.dli.sdk - package com.huawei.dli.sdk
 
com.huawei.dli.sdk.authentication - package com.huawei.dli.sdk.authentication
 
com.huawei.dli.sdk.common - package com.huawei.dli.sdk.common
 
com.huawei.dli.sdk.common.type - package com.huawei.dli.sdk.common.type
 
com.huawei.dli.sdk.common.utils - package com.huawei.dli.sdk.common.utils
 
com.huawei.dli.sdk.exception - package com.huawei.dli.sdk.exception
 
CompressType - Enum in com.huawei.dli.sdk.common
 
containsColumn(String) - Method in class com.huawei.dli.sdk.common.TableSchema
 
createCluster(String, int, String) - Method in class com.huawei.dli.sdk.DLIClient
Create a cluster.
createDatabase(String) - Method in class com.huawei.dli.sdk.DLIClient
 
createDatabase(String, String) - Method in class com.huawei.dli.sdk.DLIClient
Create a database,must sure databaseName is not exist, and there are enough quotas.
createDatabase(String, String, String) - Method in class com.huawei.dli.sdk.DLIClient
 
createDLITable(String, String, List<Column>, List<String>) - Method in class com.huawei.dli.sdk.Database
Create DLI table.
createFlinkJarJob(CreateFlinkJarJobRequest) - Method in class com.huawei.dli.sdk.DLIClient
创建一个用户自定义Flink作业 用户自定义作业目前支持jar格式, 运行在独享集群中
createFlinkJobTemplate(CreateFlinkJobTemplateRequest) - Method in class com.huawei.dli.sdk.DLIClient
创建作业模板 Create job template on Data lake insight
createObsTable(String, String, List<Column>, StorageType, String, CsvFormatInfo) - Method in class com.huawei.dli.sdk.Database
Create OBS table.
createQueue(String, int, ChargingMode, String) - Method in class com.huawei.dli.sdk.DLIClient
Create a queue.
createReader() - Method in class com.huawei.dli.sdk.DownloadJob
 
createReaders(int) - Method in class com.huawei.dli.sdk.DownloadJob
Get readers to read data in concurrent, the reader num is calculate by DLI with the expectedMaxConcurrent, that is the reader num is less or equal expectedMaxConcurrent if the data size is small.
createTable(String, String, String, List<Column>, StorageType, String, CsvFormatInfo, List<String>) - Method in class com.huawei.dli.sdk.Database
Create DLI/OBS table
createTsdb(CreateTsdbReq, String) - Method in class com.huawei.dli.sdk.DLIClient
创建时序数据库配置信息
createWriter() - Method in class com.huawei.dli.sdk.UploadJob
 
CsvFormatInfo - Class in com.huawei.dli.sdk.common
 
CsvFormatInfo() - Constructor for class com.huawei.dli.sdk.common.CsvFormatInfo
 

D

data - Variable in class com.huawei.dli.sdk.common.type.SimpleArray
 
data - Variable in class com.huawei.dli.sdk.common.type.SimpleMap
 
data - Variable in class com.huawei.dli.sdk.common.type.SimpleStruct
 
Database - Class in com.huawei.dli.sdk
 
Database(String, String, String, int, DLIClient) - Constructor for class com.huawei.dli.sdk.Database
 
DataBlock - Class in com.huawei.dli.sdk.common
 
DataBlock(int) - Constructor for class com.huawei.dli.sdk.common.DataBlock
 
DataType - Enum in com.huawei.dli.sdk.common
 
DataTypeInfo - Interface in com.huawei.dli.sdk.common
What is the relationship between DataType and DataTypeInfo? Use DataTypeInfo.getDataType() return DataType,DataType.getDataTypeInfo() return DataTypeInfo DataType is only data type,such as DataType.INT corresponding "int", but if dataType with parameters and set "decimal(10,5)",you can use DataTypeInfo; E.g.,DataTypeInfo dataTypeInfo = new DecimalTypeInfo(10, 5);
DATE - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
DateTimeUtils - Class in com.huawei.dli.sdk.common.utils
TIPS: This is copy from Spark, details see [[org.apache.spark.sql.catalyst.util.DateTimeUtils]]
DateTimeUtils() - Constructor for class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
daysToMills(int) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
daysToMills(int, TimeZone) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
DECIMAL - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
DecimalTypeInfo - Class in com.huawei.dli.sdk.common
 
DecimalTypeInfo() - Constructor for class com.huawei.dli.sdk.common.DecimalTypeInfo
 
DecimalTypeInfo(int, int) - Constructor for class com.huawei.dli.sdk.common.DecimalTypeInfo
 
DEFAULT_PRECISION - Static variable in class com.huawei.dli.sdk.common.DecimalTypeInfo
 
DEFAULT_SCALE - Static variable in class com.huawei.dli.sdk.common.DecimalTypeInfo
 
defaultTimeZone() - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
delBatch() - Method in class com.huawei.dli.sdk.BatchJob
delete batchJob (recommend)
delBatch(String) - Method in class com.huawei.dli.sdk.BatchJob
delete batchJob by batchId (deprecated)
delBatchJob(String) - Method in class com.huawei.dli.sdk.DLIClient
Delete batchJob by batchId
deleteCluster() - Method in class com.huawei.dli.sdk.Cluster
Delete this cluster.
deleteDatabase() - Method in class com.huawei.dli.sdk.Database
Delete the current database.
deleteFlinkJobInBatch(DeleteJobInBatchRequest) - Method in class com.huawei.dli.sdk.DLIClient
批量删除作业
deleteFlinkJobTemplate(Long) - Method in class com.huawei.dli.sdk.DLIClient
删除作业模板 当前模板被引用也允许删除模板
deleteJob(Long) - Method in class com.huawei.dli.sdk.DLIClient
删除任何状态的作业
deleteQueue() - Method in class com.huawei.dli.sdk.Queue
Delete this queue.
deleteResource(String) - Method in class com.huawei.dli.sdk.DLIClient
Delete package resources by name.
deleteResource(String, String) - Method in class com.huawei.dli.sdk.DLIClient
Delete package resources by name and group.
deleteTable() - Method in class com.huawei.dli.sdk.Table
Delete current table.
deleteTsdb(String, String) - Method in class com.huawei.dli.sdk.DLIClient
删除时序数据库配置信息 删除时序数据库配置信息
DliArray - Interface in com.huawei.dli.sdk.common.type
 
DLIClient - Class in com.huawei.dli.sdk
 
DLIClient(AuthenticationMode, DLIInfo) - Constructor for class com.huawei.dli.sdk.DLIClient
 
DLIException - Exception in com.huawei.dli.sdk.exception
 
DLIException() - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(String) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(String, Throwable) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(Throwable) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(ApiException) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(String, int, String) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIException(int, String) - Constructor for exception com.huawei.dli.sdk.exception.DLIException
 
DLIInfo - Class in com.huawei.dli.sdk.common
 
DLIInfo(String, String, String) - Constructor for class com.huawei.dli.sdk.common.DLIInfo
 
DLIInfo(String, String, String, String, String) - Constructor for class com.huawei.dli.sdk.common.DLIInfo
 
DLIInfo(String, String, String, String) - Constructor for class com.huawei.dli.sdk.common.DLIInfo
 
DLIInfo() - Constructor for class com.huawei.dli.sdk.common.DLIInfo
 
DliMap - Interface in com.huawei.dli.sdk.common.type
 
DliStruct - Interface in com.huawei.dli.sdk.common.type
 
dliTypeToJavaType(DataType) - Static method in class com.huawei.dli.sdk.common.type.TypeUtils
 
DOUBLE - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
DownloadJob - Class in com.huawei.dli.sdk
 
DownloadJob(Queue, SQLJob) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download query result
DownloadJob(Queue, SQLJob, Integer) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download query result
DownloadJob(Queue, DownloadJobParam) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download data from DLI.
DownloadJob(Queue, String, String) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download data from DLI.
DownloadJob(Queue, String, String, List<String>) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download data from DLI.
DownloadJob(Queue, String, String, BadRecordPolicy) - Constructor for class com.huawei.dli.sdk.DownloadJob
Deprecated.
DownloadJob(Queue, String, String, String) - Constructor for class com.huawei.dli.sdk.DownloadJob
 
DownloadJob(Queue, String, String, String, BadRecordPolicy) - Constructor for class com.huawei.dli.sdk.DownloadJob
Deprecated.
DownloadJob(Queue, String, String, PartitionSpec) - Constructor for class com.huawei.dli.sdk.DownloadJob
Create a download job to download data from DLI.
DownloadJob(Queue, String, String, PartitionSpec, BadRecordPolicy) - Constructor for class com.huawei.dli.sdk.DownloadJob
Deprecated.
DownloadJobParam - Class in com.huawei.dli.sdk.common
 
DownloadJobParam() - Constructor for class com.huawei.dli.sdk.common.DownloadJobParam
 

E

emptyRowValues() - Method in class com.huawei.dli.sdk.DownloadJob
 
ENDPOINT_POSTFIX - Static variable in class com.huawei.dli.sdk.common.DLIInfo
 
EnumSyncInfo - Enum in com.huawei.dli.sdk.common
 
EOF - Static variable in class com.huawei.dli.sdk.common.utils.IterableInputStream
 
exec() - Method in interface com.huawei.dli.sdk.common.IHttpExecAdpter
 
executeCall(IHttpExecAdpter<T>, Class<T>, Function<T, GlobalErrorResponse>, Function<T, String>) - Method in class com.huawei.dli.sdk.BaseJob
 
executeWithRetry(IHttpExecAdpter<T>, Class<T>, Function<T, GlobalErrorResponse>, Function<T, String>) - Method in class com.huawei.dli.sdk.BaseJob
 
ExportJob - Class in com.huawei.dli.sdk
 
ExportJob(Queue, String, String, String) - Constructor for class com.huawei.dli.sdk.ExportJob
 
ExportMode - Enum in com.huawei.dli.sdk.common
 
exportResult(String, StorageType, CompressType, ExportMode, String) - Method in class com.huawei.dli.sdk.SQLJob
Export QUEUE type job result.
exportResult(String, StorageType, CompressType, ExportMode, String, boolean) - Method in class com.huawei.dli.sdk.SQLJob
 
exportResult(String, StorageType, CompressType, ExportMode, String, boolean, Integer) - Method in class com.huawei.dli.sdk.SQLJob
 
exportResult(String, StorageType, CompressType, ExportMode, String, boolean, Integer, String) - Method in class com.huawei.dli.sdk.SQLJob
 
exportResult() - Method in class com.huawei.dli.sdk.SQLJob
Export QUEUE type job result with a iterator
exportResult(Integer) - Method in class com.huawei.dli.sdk.SQLJob
 

F

FLOAT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
flush() - Method in class com.huawei.dli.sdk.AvroObsWriter
 
flush() - Method in class com.huawei.dli.sdk.ObsWriter
 
flush() - Method in class com.huawei.dli.sdk.Writer
 
fromJavaDate(Date) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
Returns the number of days since epoch from java.util.Date.
fromJavaTimestamp(Timestamp) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
Returns the number of micros since epoch from java.sql.Timestamp.
fromName(String) - Static method in enum com.huawei.dli.sdk.common.CompressType
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.DataType
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.ExportMode
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.JobStatus
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.SparkJobStatus
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.StorageType
 
fromName(String) - Static method in enum com.huawei.dli.sdk.common.TableType
 
fromValue(int) - Static method in enum com.huawei.dli.sdk.common.ChargingMode
 

G

get(String) - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
getAppId() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getAppInfo() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getArgs() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getArray(int) - Method in class com.huawei.dli.sdk.common.Row
 
getArrayTypeInfo(DataTypeInfo) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info of a Array Type.
getAuthentication() - Method in class com.huawei.dli.sdk.DLIClient
 
getAuthToken() - Method in class com.huawei.dli.sdk.authentication.Authentication
 
getAuthToken() - Method in class com.huawei.dli.sdk.DLIClient
 
getBadRecordPolicy() - Method in class com.huawei.dli.sdk.DownloadJob
 
getBigDecimal(int) - Method in class com.huawei.dli.sdk.common.Row
 
getBigInteger(int) - Method in class com.huawei.dli.sdk.common.Row
 
getBoolean(int) - Method in class com.huawei.dli.sdk.common.Row
 
getCatalogName() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getClassName() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getClient() - Method in class com.huawei.dli.sdk.Database
 
getClient() - Method in class com.huawei.dli.sdk.Resources
 
getCluster(String) - Method in class com.huawei.dli.sdk.DLIClient
Get a Cluster object by queueName.
getCluster() - Method in class com.huawei.dli.sdk.SparkJob
 
getCluster_name() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
Deprecated.
getClusterName() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getClusterName() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getCode() - Method in exception com.huawei.dli.sdk.exception.DLIException
 
getCols() - Method in class com.huawei.dli.sdk.common.Row
 
getColumn() - Method in class com.huawei.dli.sdk.common.TableSchema
 
getColumn(int) - Method in class com.huawei.dli.sdk.common.TableSchema
 
getColumn(String) - Method in class com.huawei.dli.sdk.common.TableSchema
 
getColumnIdx(String) - Method in class com.huawei.dli.sdk.common.TableSchema
 
getColumnName() - Method in class com.huawei.dli.sdk.common.Column
 
getColumns() - Method in class com.huawei.dli.sdk.common.TableSchema
 
getCommitStatus() - Method in class com.huawei.dli.sdk.UploadJob
Deprecated.
getCompletionTime() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getConf() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getConf() - Method in class com.huawei.dli.sdk.Job
 
getCreateTableSql() - Method in class com.huawei.dli.sdk.common.TableSchema
 
getCreateTime() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getCreateTime() - Method in class com.huawei.dli.sdk.GroupResource
 
getCreateTime() - Method in class com.huawei.dli.sdk.ModuleResource
 
getCreateTime() - Method in class com.huawei.dli.sdk.PackageResource
 
getCreateTime() - Method in class com.huawei.dli.sdk.Table
 
getCsvString() - Method in class com.huawei.dli.sdk.common.Row
 
getCurrentdb() - Method in class com.huawei.dli.sdk.SQLJob
 
getCurrentPage() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getData() - Method in class com.huawei.dli.sdk.common.DataBlock
 
getDatabase(String) - Method in class com.huawei.dli.sdk.DLIClient
 
getDatabaseName() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getDatabaseName() - Method in class com.huawei.dli.sdk.Database
 
getDataLocation() - Method in class com.huawei.dli.sdk.Table
 
getDataType() - Method in class com.huawei.dli.sdk.common.AbstractPrimitiveTypeInfo
 
getDataType() - Method in interface com.huawei.dli.sdk.common.DataTypeInfo
 
getDataType() - Method in class com.huawei.dli.sdk.common.type.SimpleArrayTypeInfo
 
getDataType() - Method in class com.huawei.dli.sdk.common.type.SimpleMapTypeInfo
 
getDataType() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
getDataType() - Method in class com.huawei.dli.sdk.Table
 
getDataTypeInfo() - Method in class com.huawei.dli.sdk.common.Column
 
getDataTypeInfo(DataType, String) - Static method in enum com.huawei.dli.sdk.common.DataType
 
getDataTypeInfo(String) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info form a type string, e.g decimal(10, 0), struct<age:int, name:string>
getDate(int) - Method in class com.huawei.dli.sdk.common.Row
 
getDateFormat() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
getDb() - Method in class com.huawei.dli.sdk.Table
 
getDecimalTypeInfo(int, int) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info of a Decimal.
getDefaultQueue() - Method in class com.huawei.dli.sdk.DLIClient
Get default queue, get a Queue object and queueName is "default"
getDelimiter() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
getDescription() - Method in class com.huawei.dli.sdk.common.Column
 
getDescription() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getDescription() - Method in class com.huawei.dli.sdk.Database
 
getDescription() - Method in class com.huawei.dli.sdk.ModuleResource
 
getDetail() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getDetails() - Method in class com.huawei.dli.sdk.GroupResource
 
getDLIInfo() - Method in class com.huawei.dli.sdk.DLIClient
 
getDouble(int) - Method in class com.huawei.dli.sdk.common.Row
 
getDownloadStatus() - Method in class com.huawei.dli.sdk.DownloadJob
 
getDriverCores() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getDriverLog(int, int, int) - Method in class com.huawei.dli.sdk.BatchJob
 
getDriverLog(int, int, int) - Method in class com.huawei.dli.sdk.SparkJob
Get a Spark job driver log when job is finished.
getDriverLogByJobId(String, int, int, int) - Method in class com.huawei.dli.sdk.BatchJob
 
getDriverLogByJobId(String, int, int, int) - Method in class com.huawei.dli.sdk.SparkJob
 
getDriverMemory() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getDuration() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getDuration() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getElementTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.ArrayTypeInfo
Get the data type info of the element in the Array type.
getElementTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.DliArray
Get the data type info of the element in the Array.
getElementTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleArray
 
getElementTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleArrayTypeInfo
 
getElementValues() - Method in interface com.huawei.dli.sdk.common.type.DliArray
Get the list of the elements in the Array
getElementValues() - Method in class com.huawei.dli.sdk.common.type.SimpleArray
 
getEnd() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getEndTime() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getEnterpriseProjectId() - Method in class com.huawei.dli.sdk.Database
 
getEscapeChar() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
getExecutorCores() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getExecutorMemory() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getExportJobStatus() - Method in class com.huawei.dli.sdk.SQLJob
If execute exportResult,you can get exportJob status.
getFeature() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getFieldCount() - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field number of this struct.
getFieldCount() - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldCount() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
getFieldCount() - Method in interface com.huawei.dli.sdk.common.type.StructTypeInfo
Get the field number of the Struct type info
getFieldName(int) - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field name by the index of the struct
getFieldName(int) - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldNames() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
getFieldNames() - Method in interface com.huawei.dli.sdk.common.type.StructTypeInfo
Get the list of the field names of the Struct type info
getFieldTypeInfo(int) - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field type info by the index of the struct
getFieldTypeInfo(String) - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field type info the field name of the struct
getFieldTypeInfo(int) - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldTypeInfo(String) - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldTypeInfos() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
getFieldTypeInfos() - Method in interface com.huawei.dli.sdk.common.type.StructTypeInfo
Get the list of the field type infos of the Struct type info
getFieldValue(int) - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field value by the index of the struct
getFieldValue(String) - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the field value by the field name of the struct
getFieldValue(int) - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldValue(String) - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFieldValues() - Method in interface com.huawei.dli.sdk.common.type.DliStruct
Get the List of field values of the struct
getFieldValues() - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
getFile() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getFiles() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getFlinkApigSinks(Long) - Method in class com.huawei.dli.sdk.DLIClient
查询作业apig网关服务访问地址 The apig sinks is json format.
getFlinkJobDetail(Long) - Method in class com.huawei.dli.sdk.DLIClient
查询作业详情 Get job detail information.
getFlinkJobExecuteGraph(Long) - Method in class com.huawei.dli.sdk.DLIClient
查询作业执行计划图 The execution graph is json format.
getFlinkJobs(String, String, String, Boolean, Long, Integer, String, Long, String, String, String) - Method in class com.huawei.dli.sdk.DLIClient
查询作业列表 作业列表查询, 支持以下参数: name, status, show_detail, offset, limit, order, root_job_id.
getFlinkJobsMetrics(GetFlinkJobsMetricsBody) - Method in class com.huawei.dli.sdk.DLIClient
查询作业监控信息 查询作业监控信息, 支持同时查询多个作业监控信息
getFlinkJobTemplates(Long, Integer, String) - Method in class com.huawei.dli.sdk.DLIClient
查询作业模板列表
getFloat(int) - Method in class com.huawei.dli.sdk.common.Row
 
getFrom() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getGroupName() - Method in class com.huawei.dli.sdk.GroupResource
 
getGroupResources() - Method in class com.huawei.dli.sdk.Resources
 
getGroups() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getHeartbeatTimeoutInSecond() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getId() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getId() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getImage() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getIndex() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getInputSize() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getInt(int) - Method in class com.huawei.dli.sdk.common.Row
 
getInternalJobId() - Method in class com.huawei.dli.sdk.DownloadJob
 
getInternalJobId() - Method in class com.huawei.dli.sdk.UploadJob
 
getJars() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getJobGroup() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getJobId() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getJobId() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getJobId() - Method in class com.huawei.dli.sdk.Job
 
getJobId() - Method in class com.huawei.dli.sdk.SparkJob
 
getJobMode() - Method in class com.huawei.dli.sdk.SQLJob
 
getJobProgress(String) - Method in class com.huawei.dli.sdk.DLIClient
Obtains the job execution progress based on jobId.
getJobResult() - Method in class com.huawei.dli.sdk.SQLJob
If job type is "QUEUE",you can get this job result.
getJobResult(Integer, Integer) - Method in class com.huawei.dli.sdk.SQLJob
If job type is "QUEUE",you can get this job result.
getJobResultSet() - Method in class com.huawei.dli.sdk.SQLJob
 
getJobStatus() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getJobStatus() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getJobTimeout() - Method in class com.huawei.dli.sdk.Job
 
getJobTimeout() - Method in class com.huawei.dli.sdk.SparkJob
 
getJobType() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getJobType() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getJobType() - Method in class com.huawei.dli.sdk.Job
 
getKey() - Method in enum com.huawei.dli.sdk.common.EnumSyncInfo
 
getKeyTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.DliMap
Get the Type info of the key in the Map
getKeyTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.MapTypeInfo
get the key type info of the Map
getKeyTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleMap
 
getKeyTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleMapTypeInfo
 
getKilledTasksSummary() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getKind() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getKind() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getKv() - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
getLastAccessTime() - Method in class com.huawei.dli.sdk.Table
 
getLength() - Method in class com.huawei.dli.sdk.common.DataBlock
 
getLocation() - Method in class com.huawei.dli.sdk.Table
 
getLog(int, int) - Method in class com.huawei.dli.sdk.BatchJob
 
getLog(int, int) - Method in class com.huawei.dli.sdk.SparkJob
Get a Spark job client log when job is finished.
getLogByJobId(String, int, int) - Method in class com.huawei.dli.sdk.BatchJob
 
getLogByJobId(String, int, int) - Method in class com.huawei.dli.sdk.SparkJob
 
getLong(int) - Method in class com.huawei.dli.sdk.common.Row
 
getMap(int) - Method in class com.huawei.dli.sdk.common.Row
 
getMapTypeInfo(DataTypeInfo, DataTypeInfo) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info of a Map Type.
getMaxRetryTimes() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getMessage() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getModuleName() - Method in class com.huawei.dli.sdk.ModuleResource
 
getModuleResources() - Method in class com.huawei.dli.sdk.Resources
 
getModules() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getModuleType() - Method in class com.huawei.dli.sdk.ModuleResource
 
getName() - Method in enum com.huawei.dli.sdk.common.ChargingMode
 
getName() - Method in enum com.huawei.dli.sdk.common.CompressType
 
getName() - Method in enum com.huawei.dli.sdk.common.DataType
 
getName() - Method in enum com.huawei.dli.sdk.common.ExportMode
 
getName() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getName() - Method in enum com.huawei.dli.sdk.common.JobStatus
 
getName() - Method in enum com.huawei.dli.sdk.common.JobSubmitMode
 
getName() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getName() - Method in class com.huawei.dli.sdk.common.SparkJobResource
 
getName() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getName() - Method in enum com.huawei.dli.sdk.common.SparkJobStatus
 
getName() - Method in enum com.huawei.dli.sdk.common.StorageType
 
getName() - Method in enum com.huawei.dli.sdk.common.TableType
 
getName() - Method in enum com.huawei.dli.sdk.TunnelJob.FileFormat
 
getNumActiveStages() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumActiveTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumCompletedIndices() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumCompletedStages() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumCompletedTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumExecutors() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getNumFailedStages() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumFailedTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumKilledTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumSkippedStages() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumSkippedTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getNumTasks() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getObjectStream(String, String, String, String) - Method in class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
getObsBucket() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getObsClient() - Method in class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
getOrder() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getOwner() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getOwner() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getOwner() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getOwner() - Method in class com.huawei.dli.sdk.Database
 
getOwner() - Method in class com.huawei.dli.sdk.Table
 
getPackageResources() - Method in class com.huawei.dli.sdk.Resources
 
getPageSize() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getPartitionColumns() - Method in class com.huawei.dli.sdk.Table
 
getPartitionDetail(Integer, Integer) - Method in class com.huawei.dli.sdk.Table
Get describes the partition information for the table in specified offset and limit.
getPartitionInfos() - Method in class com.huawei.dli.sdk.common.PartitionSchema
 
getPartitions() - Method in class com.huawei.dli.sdk.Table
Get describes the partition information for the specified table.
GetPartitionTask - Class in com.huawei.dli.sdk
 
GetPartitionTask(String, String, int, int, List<PartitionInfo>, DLIClient, List<String>, CountDownLatch) - Constructor for class com.huawei.dli.sdk.GetPartitionTask
 
getPasswordAuthentication() - Method in class com.huawei.dli.sdk.authentication.ProxyAuthenticator
 
getPrecision() - Method in class com.huawei.dli.sdk.common.DecimalTypeInfo
 
getPrimitiveTypeInfo(DataType) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info of a Primitive Type.
getProgress() - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
getProjectId() - Method in class com.huawei.dli.sdk.authentication.Authentication
 
getProjectId() - Method in class com.huawei.dli.sdk.Database
 
getProjectId() - Method in class com.huawei.dli.sdk.DLIClient
 
getProjectId() - Method in class com.huawei.dli.sdk.Job
 
getProjectId() - Method in class com.huawei.dli.sdk.SparkJob
 
getProxyUser() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getPyFiles() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getQueue(String) - Method in class com.huawei.dli.sdk.DLIClient
Get a Queue object by queueName.Must be sure that the name exists, otherwise throw exception:"There is no Queue named"
getQueue() - Method in class com.huawei.dli.sdk.Job
 
getQueueName() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getQueueName() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getQuoteChar() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
getResource(String) - Method in class com.huawei.dli.sdk.DLIClient
Get a PackageResource object by resourceName.
getResource(String, String) - Method in class com.huawei.dli.sdk.DLIClient
Get a PackageResource object by resourceName.
getResourceId() - Method in class com.huawei.dli.sdk.Database
 
getResourceName() - Method in class com.huawei.dli.sdk.PackageResource
 
getResourceNames() - Method in class com.huawei.dli.sdk.GroupResource
 
getResources() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getResources() - Method in class com.huawei.dli.sdk.ModuleResource
 
getResourceType() - Method in class com.huawei.dli.sdk.PackageResource
 
getResponseBody() - Method in exception com.huawei.dli.sdk.exception.DLIException
 
getRestApi() - Method in class com.huawei.dli.sdk.authentication.Authentication
 
getRestApi() - Method in class com.huawei.dli.sdk.DLIClient
 
getResultCount() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getResultCount() - Method in class com.huawei.dli.sdk.DownloadJob
 
getResultSchema() - Method in class com.huawei.dli.sdk.SQLJob
 
getRow() - Method in class com.huawei.dli.sdk.ResultSet
Get the current row form ResultSet
getRowCount() - Method in class com.huawei.dli.sdk.ResultSet
Get row count of the ResultSet
getRowCount() - Method in class com.huawei.dli.sdk.SQLJob
 
getRowString() - Method in class com.huawei.dli.sdk.common.Row
 
getSc_type() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
Deprecated.
getScale() - Method in class com.huawei.dli.sdk.common.DecimalTypeInfo
 
getSchema() - Method in class com.huawei.dli.sdk.common.Row
 
getSchema() - Method in class com.huawei.dli.sdk.ResultSet
Get the Schema of the ResultSet
getScType() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getScType() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getShort(int) - Method in class com.huawei.dli.sdk.common.Row
 
getSize() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getSortColumns() - Method in class com.huawei.dli.sdk.common.TableSchema
 
getSparkVersion() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
getSql() - Method in class com.huawei.dli.sdk.SQLJob
 
getStageIds() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getStart() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getStartTime() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getState() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getStatement() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getStatus() - Method in class com.huawei.dli.sdk.BatchJob
 
getStatus() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getStatus() - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
getStatus() - Method in class com.huawei.dli.sdk.GroupResource
 
getStatus() - Method in class com.huawei.dli.sdk.Job
Get the latest job status
getStatus() - Method in class com.huawei.dli.sdk.ModuleResource
 
getStatus() - Method in class com.huawei.dli.sdk.PackageResource
 
getStatus() - Method in class com.huawei.dli.sdk.SparkJob
Get a Spark job status, it may be starting, running, dead or success.
getStatusResult(String) - Method in class com.huawei.dli.sdk.Job
Get this job resultInfo: detail,statement,status...
getStatusResult(String) - Method in class com.huawei.dli.sdk.SQLJob
 
getString(int) - Method in class com.huawei.dli.sdk.common.Row
 
getStruct(int) - Method in class com.huawei.dli.sdk.common.Row
 
getStructTypeInfo(List<String>, List<DataTypeInfo>) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoUtils
Get the data type info of a Struct Type.
getSubJobId() - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
getSubJobs() - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
getSubmissionTime() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getSuccess() - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
getSuccess() - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
getSuccess() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getTable(String) - Method in class com.huawei.dli.sdk.Database
Get the table in the current database by table name.
getTableComment() - Method in class com.huawei.dli.sdk.common.TableSchema
 
getTableCount() - Method in class com.huawei.dli.sdk.Database
 
getTableDetail(String) - Method in class com.huawei.dli.sdk.Database
 
getTableDetail() - Method in class com.huawei.dli.sdk.Table
Get describes the metadata information for the specified table.
getTableName() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getTableName() - Method in class com.huawei.dli.sdk.Table
 
getTables() - Method in class com.huawei.dli.sdk.PageTables
 
getTableSize() - Method in class com.huawei.dli.sdk.Table
 
getTableType() - Method in class com.huawei.dli.sdk.Table
 
getTags() - Method in class com.huawei.dli.sdk.common.JobFilter
 
getTags() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getTags() - Method in class com.huawei.dli.sdk.Job
 
getTimestamp(int) - Method in class com.huawei.dli.sdk.common.Row
 
getTimestampFormat() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
getTinyint(int) - Method in class com.huawei.dli.sdk.common.Row
 
getTokenApi() - Method in class com.huawei.dli.sdk.authentication.Authentication
 
getTotalCount() - Method in class com.huawei.dli.sdk.common.PartitionSchema
 
getTotalCount() - Method in class com.huawei.dli.sdk.PageTables
 
getTransactionId() - Method in class com.huawei.dli.sdk.BaseJob
 
getTransactionKeyName() - Method in class com.huawei.dli.sdk.BaseJob
 
getTransactionKeyName() - Method in class com.huawei.dli.sdk.BatchJob
 
getTransactionKeyName() - Method in class com.huawei.dli.sdk.Job
 
getTsdbById(String, Long) - Method in class com.huawei.dli.sdk.DLIClient
查询时序数据库配置信息详情 根据时序数据库ID,查询时序数据库详情
getTsdbList(String, Integer, Integer) - Method in class com.huawei.dli.sdk.DLIClient
查询时序数据库配置信息列表
getType() - Method in class com.huawei.dli.sdk.common.Column
 
getType() - Method in class com.huawei.dli.sdk.common.SparkJobResource
 
getTypeInfoFromTypeString(String) - Static method in class com.huawei.dli.sdk.common.type.TypeInfoParser
 
getTypeName() - Method in class com.huawei.dli.sdk.common.type.SimpleArrayTypeInfo
 
getTypeName() - Method in class com.huawei.dli.sdk.common.type.SimpleMapTypeInfo
 
getTypeName() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
getUnderlyingName() - Method in class com.huawei.dli.sdk.PackageResource
 
getUpdateTime() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
getUpdateTime() - Method in class com.huawei.dli.sdk.GroupResource
 
getUpdateTime() - Method in class com.huawei.dli.sdk.ModuleResource
 
getUpdateTime() - Method in class com.huawei.dli.sdk.PackageResource
 
getUploadResultCount() - Method in class com.huawei.dli.sdk.UploadJob
 
getUploadStatus() - Method in class com.huawei.dli.sdk.UploadJob
 
getValue() - Method in enum com.huawei.dli.sdk.common.ChargingMode
 
getValue() - Method in enum com.huawei.dli.sdk.common.CompressType
 
getValue() - Method in enum com.huawei.dli.sdk.common.DataType
 
getValue() - Method in enum com.huawei.dli.sdk.common.ExportMode
 
getValue() - Method in enum com.huawei.dli.sdk.common.JobStatus
 
getValue() - Method in enum com.huawei.dli.sdk.common.SparkJobStatus
 
getValue() - Method in enum com.huawei.dli.sdk.common.StorageType
 
getValue() - Method in enum com.huawei.dli.sdk.common.TableType
 
getValues() - Method in interface com.huawei.dli.sdk.common.type.DliMap
Get the key and value of the Map
getValues() - Method in class com.huawei.dli.sdk.common.type.SimpleMap
 
getValueTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.DliMap
Get the Type info of the value in the Map
getValueTypeInfo() - Method in interface com.huawei.dli.sdk.common.type.MapTypeInfo
get the value type info of the Map
getValueTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleMap
 
getValueTypeInfo() - Method in class com.huawei.dli.sdk.common.type.SimpleMapTypeInfo
 
getWithColumnHeader() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
getWriterDataBlockSize() - Method in class com.huawei.dli.sdk.UploadJob
 
GroupResource - Class in com.huawei.dli.sdk
 
GroupResource(GroupResourceInfo) - Constructor for class com.huawei.dli.sdk.GroupResource
 

H

hasNext() - Method in class com.huawei.dli.sdk.AvroObsReader
 
hasNext() - Method in class com.huawei.dli.sdk.JsonObsReader
 
hasNext() - Method in class com.huawei.dli.sdk.ObsReader
 
hasNext() - Method in interface com.huawei.dli.sdk.Reader
 

I

IAM_ENDPOINT_PREFIX - Static variable in class com.huawei.dli.sdk.common.DLIInfo
 
IHttpExecAdpter<V> - Interface in com.huawei.dli.sdk.common
 
ImportJob - Class in com.huawei.dli.sdk
 
ImportJob(Queue, String, String, String) - Constructor for class com.huawei.dli.sdk.ImportJob
 
ImportJob(Queue, String, String, String, String, Boolean) - Constructor for class com.huawei.dli.sdk.ImportJob
 
ImportJob(Queue, String, String, String, PartitionSpec, Boolean) - Constructor for class com.huawei.dli.sdk.ImportJob
 
INT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
isAutoRecovery() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
isClosed() - Method in class com.huawei.dli.sdk.AvroObsReader
 
isClosed() - Method in class com.huawei.dli.sdk.AvroObsWriter
 
isClosed() - Method in class com.huawei.dli.sdk.JsonObsReader
 
isClosed() - Method in class com.huawei.dli.sdk.ObsReader
 
isClosed() - Method in class com.huawei.dli.sdk.ObsWriter
 
isClosed() - Method in interface com.huawei.dli.sdk.Reader
 
isClosed() - Method in class com.huawei.dli.sdk.Writer
 
isEmpty() - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
isFulled() - Method in class com.huawei.dli.sdk.common.DataBlock
 
isPartitionColumn() - Method in class com.huawei.dli.sdk.common.Column
 
isQuery(String) - Static method in class com.huawei.dli.sdk.common.utils.SqlUtils
 
isServiceInsideError(int, String) - Method in class com.huawei.dli.sdk.BaseJob
 
isSync(String) - Static method in enum com.huawei.dli.sdk.common.EnumSyncInfo
 
isWithColumnHeader() - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
IterableInputStream<T> - Class in com.huawei.dli.sdk.common.utils
 
IterableInputStream(Iterator<T>, Function<T, byte[]>, Function<T, Integer>) - Constructor for class com.huawei.dli.sdk.common.utils.IterableInputStream
 

J

Job - Class in com.huawei.dli.sdk
 
Job(Queue) - Constructor for class com.huawei.dli.sdk.Job
 
JOB_TIMEOUT_SECOND - Static variable in class com.huawei.dli.sdk.Job
 
JOB_TRANSACTION_ERROR_CODE - Static variable in class com.huawei.dli.sdk.BaseJob
 
JobFilter - Class in com.huawei.dli.sdk.common
 
JobFilter() - Constructor for class com.huawei.dli.sdk.common.JobFilter
 
JobProgressInfo - Class in com.huawei.dli.sdk.common
 
JobProgressInfo(JobProgressListInfo) - Constructor for class com.huawei.dli.sdk.common.JobProgressInfo
 
JobProgressResultInfo - Class in com.huawei.dli.sdk.common
 
JobProgressResultInfo(Boolean, String, Integer, Double, List<JobProgressInfo>) - Constructor for class com.huawei.dli.sdk.common.JobProgressResultInfo
 
JobResultInfo - Class in com.huawei.dli.sdk.common
 
JobResultInfo(StatusResult) - Constructor for class com.huawei.dli.sdk.common.JobResultInfo
 
JobResultInfo(JobListInfo) - Constructor for class com.huawei.dli.sdk.common.JobResultInfo
 
JobStatus - Enum in com.huawei.dli.sdk.common
 
JobSubmitMode - Enum in com.huawei.dli.sdk.common
 
JobType - Enum in com.huawei.dli.sdk.common
 
JsonObsReader - Class in com.huawei.dli.sdk
 
JsonObsReader(DownloadJob, String, String, String, String, String) - Constructor for class com.huawei.dli.sdk.JsonObsReader
Deprecated.
JsonObsReader(DownloadJob, String, String, String, List<ObsObject>) - Constructor for class com.huawei.dli.sdk.JsonObsReader
 
jsonToObject(String, Class<T>) - Static method in class com.huawei.dli.sdk.common.utils.JsonUtils
 
JsonUtils - Class in com.huawei.dli.sdk.common.utils
 
JsonUtils() - Constructor for class com.huawei.dli.sdk.common.utils.JsonUtils
 

K

keys() - Method in class com.huawei.dli.sdk.common.PartitionSpec
 

L

listAllBatchJobs(String, int, int) - Method in class com.huawei.dli.sdk.DLIClient
Lists the currently user-owned Spark batch jobs.
listAllBatchJobs(BatchListFilter) - Method in class com.huawei.dli.sdk.DLIClient
GET /v2.0/{project_id}/batches Lists the currently user-owned Spark batch jobs.
listAllClusters() - Method in class com.huawei.dli.sdk.DLIClient
Lists the currently user-owned Clusters.
listAllDatabases() - Method in class com.huawei.dli.sdk.DLIClient
List the currently user-owned all databases .
listAllJobs() - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllJobs(JobType) - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllJobs(Long, Long, JobType) - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllJobs(Integer, Integer, JobType) - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllJobs(Integer, Integer, Long, Long, JobType) - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllJobs(JobFilter) - Method in class com.huawei.dli.sdk.DLIClient
Get all JobsResultInfo list below the current project.
listAllQueues() - Method in class com.huawei.dli.sdk.DLIClient
Lists the currently user-owned Queues.
listAllResources() - Method in class com.huawei.dli.sdk.DLIClient
Lists the currently user-owned Resources.
listAllSQLJobs(JobFilter) - Method in class com.huawei.dli.sdk.DLIClient
Query all the information of the recently executed sql job submitted in the edit box under the current project.
listAllTables() - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listAllTables(String) - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listAllTables(boolean) - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listAllTables(TableType) - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listAllTables(String, boolean) - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listAllTables(String, boolean, TableType) - Method in class com.huawei.dli.sdk.Database
List all tables in the current database.
listJobsByPage(JobFilter) - Method in class com.huawei.dli.sdk.DLIClient
Get specify page and pageSize JobsResultInfo list below the current project.
listObjects(String, String, String, String) - Method in class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
listSQLJobs() - Method in class com.huawei.dli.sdk.DLIClient
Query the information of the recently executed job submitted in the edit box under the current project.
listSQLJobs(Integer, Integer) - Method in class com.huawei.dli.sdk.DLIClient
Query the information of the recently executed job submitted in the edit box under the current project.
listSQLJobsByPage(JobFilter) - Method in class com.huawei.dli.sdk.DLIClient
Query the information of the recently executed job submitted in the edit box under the current project.
listTableByPage(String, boolean, Integer, Integer, TableType) - Method in class com.huawei.dli.sdk.Database
List tables by page in the current database.
LONG - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 

M

makeArray(ArrayTypeInfo, String) - Static method in class com.huawei.dli.sdk.common.type.TypeUtils
Make a DliArray object form the JSON string
makeMap(MapTypeInfo, String) - Static method in class com.huawei.dli.sdk.common.type.TypeUtils
Make a DliMap object form the JSON string
makeStruct(StructTypeInfo, String) - Static method in class com.huawei.dli.sdk.common.type.TypeUtils
Make a DliStruct object form the JSON string
MapTypeInfo - Interface in com.huawei.dli.sdk.common.type
 
millisToDays(long) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
millisToDays(long, TimeZone) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
 
ModuleResource - Class in com.huawei.dli.sdk
 
ModuleResource(ModuleResourceInfo) - Constructor for class com.huawei.dli.sdk.ModuleResource
 

N

newRow() - Method in class com.huawei.dli.sdk.TunnelJob
 
next() - Method in class com.huawei.dli.sdk.ResultSet
Moves the cursor forward one row from its current position.
NULL_VALUE_FOR_CSV - Static variable in class com.huawei.dli.sdk.common.Row
 
nullValue - Variable in class com.huawei.dli.sdk.TunnelJob
 

O

objectPrefix - Variable in class com.huawei.dli.sdk.TunnelJob
 
objToJson(Object) - Static method in class com.huawei.dli.sdk.common.utils.JsonUtils
 
OBS_ENDPOINT - Static variable in class com.huawei.dli.sdk.common.DLIInfo
 
ObsClientUtils - Class in com.huawei.dli.sdk.common.utils
 
ObsClientUtils(String) - Constructor for class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
ObsClientUtils(String, String, String) - Constructor for class com.huawei.dli.sdk.common.utils.ObsClientUtils
 
ObsReader - Class in com.huawei.dli.sdk
 
ObsReader(DownloadJob, String, String, String, String, String) - Constructor for class com.huawei.dli.sdk.ObsReader
Deprecated.
ObsReader(DownloadJob, String, String, String, List<ObsObject>) - Constructor for class com.huawei.dli.sdk.ObsReader
 
ObsWriter - Class in com.huawei.dli.sdk
 
ObsWriter(UploadJob, String, String, String, String, String, TunnelJob.FileFormat) - Constructor for class com.huawei.dli.sdk.ObsWriter
 
openReader() - Method in class com.huawei.dli.sdk.AvroObsReader
 
openReader() - Method in class com.huawei.dli.sdk.JsonObsReader
 
openReader() - Method in class com.huawei.dli.sdk.ObsReader
 
openReader() - Method in interface com.huawei.dli.sdk.Reader
 

P

PackageResource - Class in com.huawei.dli.sdk
 
PackageResource(PkgResourceInfo) - Constructor for class com.huawei.dli.sdk.PackageResource
 
PackageResource(String) - Constructor for class com.huawei.dli.sdk.PackageResource
 
PageTables - Class in com.huawei.dli.sdk
 
PageTables() - Constructor for class com.huawei.dli.sdk.PageTables
 
partCols - Variable in class com.huawei.dli.sdk.TunnelJob
 
PartitionSchema - Class in com.huawei.dli.sdk.common
 
PartitionSchema() - Constructor for class com.huawei.dli.sdk.common.PartitionSchema
 
PartitionSpec - Class in com.huawei.dli.sdk.common
 
PartitionSpec() - Constructor for class com.huawei.dli.sdk.common.PartitionSpec
 
PartitionSpec(String) - Constructor for class com.huawei.dli.sdk.common.PartitionSpec
 
prepare(Queue, String, String, String) - Method in class com.huawei.dli.sdk.TunnelJob
 
prepare(Queue, TableSchema) - Method in class com.huawei.dli.sdk.TunnelJob
 
previewJobResult() - Method in class com.huawei.dli.sdk.SQLJob
If job type is "QUEUE",you can get this job result Just get top 1000
ProxyAuthenticator - Class in com.huawei.dli.sdk.authentication
 
ProxyAuthenticator(String, String) - Constructor for class com.huawei.dli.sdk.authentication.ProxyAuthenticator
 
putColumn(Column) - Method in class com.huawei.dli.sdk.common.TableSchema
 

Q

queryJobResultInfo(String) - Method in class com.huawei.dli.sdk.DLIClient
Queue the JobResultInfo by job id.
Queue - Class in com.huawei.dli.sdk
 
Queue(String, String, int, String, long, ChargingMode, DLIClient) - Constructor for class com.huawei.dli.sdk.Queue
 
Queue(String, String, String, int, String, long, ChargingMode, DLIClient) - Constructor for class com.huawei.dli.sdk.Queue
 
Queue(String, DLIClient) - Constructor for class com.huawei.dli.sdk.Queue
 
queueAction(String, QueueActionRequest) - Method in class com.huawei.dli.sdk.DLIClient
队列操作

R

read() - Method in class com.huawei.dli.sdk.AvroObsReader
 
read() - Method in class com.huawei.dli.sdk.common.utils.IterableInputStream
 
read() - Method in class com.huawei.dli.sdk.JsonObsReader
 
read() - Method in class com.huawei.dli.sdk.ObsReader
 
read() - Method in interface com.huawei.dli.sdk.Reader
 
Reader - Interface in com.huawei.dli.sdk
 
resetCommitted() - Method in class com.huawei.dli.sdk.UploadJob
 
Resources - Class in com.huawei.dli.sdk
 
Resources(PackageResource[], ModuleResource[], GroupResource[], DLIClient) - Constructor for class com.huawei.dli.sdk.Resources
 
ResultSet - Class in com.huawei.dli.sdk
 
ResultSet(SQLJob) - Constructor for class com.huawei.dli.sdk.ResultSet
 
ResultSet(SQLJob, List<Row>) - Constructor for class com.huawei.dli.sdk.ResultSet
 
Row - Class in com.huawei.dli.sdk.common
 
Row(TableSchema) - Constructor for class com.huawei.dli.sdk.common.Row
 
run() - Method in class com.huawei.dli.sdk.GetPartitionTask
 
runFlinkJob(RunFlinkJobRequest) - Method in class com.huawei.dli.sdk.DLIClient
批量运行作业 触发运行作业

S

SERVER_ENDPOINT_PREFIX - Static variable in class com.huawei.dli.sdk.common.DLIInfo
 
SERVER_NAME - Static variable in class com.huawei.dli.sdk.common.DLIInfo
 
set(String, String) - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
setAccessKey(String) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setAccessKey(String) - Method in class com.huawei.dli.sdk.DLIClient
 
setArgs(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setArray(int, DliArray) - Method in class com.huawei.dli.sdk.common.Row
 
setAuthToken(String) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setAuthToken(String) - Method in class com.huawei.dli.sdk.DLIClient
 
setAutoRecovery(boolean) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setBigDecimal(int, BigDecimal) - Method in class com.huawei.dli.sdk.common.Row
 
setBigInteger(int, BigInteger) - Method in class com.huawei.dli.sdk.common.Row
 
setBoolean(int, Boolean) - Method in class com.huawei.dli.sdk.common.Row
 
setCatalogName(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setClassName(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setCluster_name(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
Deprecated.
setClusterName(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setCols(List<Object>) - Method in class com.huawei.dli.sdk.common.Row
 
setColumns(List<Column>) - Method in class com.huawei.dli.sdk.common.TableSchema
 
setCompletionTime(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setCompressType(CompressType) - Method in class com.huawei.dli.sdk.ExportJob
 
setConf(Map<String, String>) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setConf(List<Map<String, Object>>) - Method in class com.huawei.dli.sdk.Job
 
setConnectTimeout(int) - Method in class com.huawei.dli.sdk.DLIClient
Set the default connect timeout for new connections.
setCreateTableSql(String) - Method in class com.huawei.dli.sdk.common.TableSchema
 
setCsvFormatInfo(CsvFormatInfo) - Method in class com.huawei.dli.sdk.ImportJob
 
setCurrentPage(Integer) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setDate(int, Date) - Method in class com.huawei.dli.sdk.common.Row
 
setDateFormat(String) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setDelimiter(String) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setDescription(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setDouble(int, Double) - Method in class com.huawei.dli.sdk.common.Row
 
setDriverCores(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setDriverMemory(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setEnd(Long) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setEnterpriseProjectId(String) - Method in class com.huawei.dli.sdk.Database
 
setEscapeChar(String) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setExecutorCores(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setExecutorMemory(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setExportMode(ExportMode) - Method in class com.huawei.dli.sdk.ExportJob
 
setFeature(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setFile(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setFiles(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setFloat(int, Float) - Method in class com.huawei.dli.sdk.common.Row
 
setFrom(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setGroups(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setHasRenameCol(boolean) - Method in class com.huawei.dli.sdk.AvroObsReader
A flag used to determine whether to read AVRO data based on the name of c$i.
setHasRenameCol(boolean) - Method in class com.huawei.dli.sdk.JsonObsReader
A flag used to determine whether to read JSON data based on the name of c$i.
setHeartbeatTimeoutInSecond(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setHttpClient(OkHttpClient) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setHttpClient(OkHttpClient) - Method in class com.huawei.dli.sdk.DLIClient
Set httpClient for new connections.
setId(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setImage(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setIndex(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setInt(int, Integer) - Method in class com.huawei.dli.sdk.common.Row
 
setJars(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setJobGroup(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setJobId(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setJobId(String) - Method in class com.huawei.dli.sdk.Job
 
setJobStatus(String) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setJobTimeout(int) - Method in class com.huawei.dli.sdk.Job
Set job timeout, default 300s
setJobTimeout(int) - Method in class com.huawei.dli.sdk.SparkJob
 
setJobType(JobType) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setJobType(JobType) - Method in class com.huawei.dli.sdk.Job
 
setKilledTasksSummary(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setKind(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setLong(int, Long) - Method in class com.huawei.dli.sdk.common.Row
 
setMap(int, DliMap) - Method in class com.huawei.dli.sdk.common.Row
 
setMaxCharsPerColumn(int) - Method in class com.huawei.dli.sdk.DownloadJob
Deprecated.
setMaxCharsPerColumn(int) - Method in class com.huawei.dli.sdk.ObsReader
Deprecated.
setMaxRetryTimes(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setModules(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setName(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setName(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setName(String) - Method in class com.huawei.dli.sdk.common.SparkJobResource
 
setNullValue(String) - Method in class com.huawei.dli.sdk.ObsReader
 
setNumActiveStages(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumActiveTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumCompletedIndices(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumCompletedStages(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumCompletedTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumExecutors(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setNumFailedStages(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumFailedTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumKilledTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumSkippedStages(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumSkippedTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setNumTasks(Long) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setObsBucket(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setOrder(String) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setOverWrite(Boolean) - Method in class com.huawei.dli.sdk.ImportJob
 
setOwner(String) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setPageSize(Integer) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setPartitionInfos(List<PartitionInfo>) - Method in class com.huawei.dli.sdk.common.PartitionSchema
 
setPartitionSpec(PartitionSpec) - Method in class com.huawei.dli.sdk.ImportJob
 
setProgress(Double) - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
setProxy(String, int) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setProxy(String, int, String, String) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setProxy(String, int) - Method in class com.huawei.dli.sdk.common.DLIInfo
 
setProxy(String, int, String, String) - Method in class com.huawei.dli.sdk.common.DLIInfo
 
setProxy(String, int) - Method in class com.huawei.dli.sdk.DLIClient
Set proxy for new connections.
setPyFiles(String[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setQueueName(String) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setQuoteChar(String) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setReadTimeout(int) - Method in class com.huawei.dli.sdk.DLIClient
Set the default read timeout for new connections.
setResourceId(String) - Method in class com.huawei.dli.sdk.Database
 
setResources(SparkJobResource[]) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setSc_type(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
Deprecated.
setScType(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setSecretKey(String) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setSecretKey(String) - Method in class com.huawei.dli.sdk.DLIClient
 
setSecurityToken(String) - Method in class com.huawei.dli.sdk.authentication.Authentication
 
setSecurityToken(String) - Method in class com.huawei.dli.sdk.DLIClient
 
setShort(int, Short) - Method in class com.huawei.dli.sdk.common.Row
 
setSize(int) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setSortColumns(List<String>) - Method in class com.huawei.dli.sdk.common.TableSchema
 
setSparkVersion(String) - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
setSql(String) - Method in class com.huawei.dli.sdk.SQLJob
 
setStageIds(List<Long>) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setStart(Long) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setStatus(JobStatus) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setStatus(String) - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
setStorageType(StorageType) - Method in class com.huawei.dli.sdk.ExportJob
 
setStorageType(StorageType) - Method in class com.huawei.dli.sdk.ImportJob
 
setString(int, String) - Method in class com.huawei.dli.sdk.common.Row
 
setStruct(int, DliStruct) - Method in class com.huawei.dli.sdk.common.Row
 
setSubJobId(Integer) - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
setSubJobs(List<JobProgressInfo>) - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
setSubmissionTime(String) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setSuccess(Boolean) - Method in class com.huawei.dli.sdk.common.JobProgressInfo
 
setSuccess(Boolean) - Method in class com.huawei.dli.sdk.common.JobProgressResultInfo
 
setTableComment(String) - Method in class com.huawei.dli.sdk.common.TableSchema
 
setTables(List<Table>) - Method in class com.huawei.dli.sdk.PageTables
 
setTags(String) - Method in class com.huawei.dli.sdk.common.JobFilter
 
setTags(Map<String, String>) - Method in class com.huawei.dli.sdk.Job
 
setTimestamp(int, Timestamp) - Method in class com.huawei.dli.sdk.common.Row
 
setTimestampFormat(String) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setTinyint(int, Byte) - Method in class com.huawei.dli.sdk.common.Row
 
setTotalCount(int) - Method in class com.huawei.dli.sdk.common.PartitionSchema
 
setTotalCount(int) - Method in class com.huawei.dli.sdk.PageTables
 
setTransactionId(String) - Method in class com.huawei.dli.sdk.BaseJob
 
setType(String) - Method in class com.huawei.dli.sdk.common.SparkJobResource
 
setWithColumnHeader(boolean) - Method in class com.huawei.dli.sdk.common.CsvFormatInfo
 
setWriterDataBlockSize(int) - Method in class com.huawei.dli.sdk.UploadJob
 
SHORT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
showPartitions(String, String, Integer, Integer) - Method in class com.huawei.dli.sdk.DLIClient
Get describes the partition information for the table in specified offset and limit.
showPartitions(String, String) - Method in class com.huawei.dli.sdk.DLIClient
Get describes the partition information for the specified table
SimpleArray - Class in com.huawei.dli.sdk.common.type
 
SimpleArrayTypeInfo - Class in com.huawei.dli.sdk.common.type
 
SimpleMap - Class in com.huawei.dli.sdk.common.type
 
SimpleMapTypeInfo - Class in com.huawei.dli.sdk.common.type
 
SimplePrimitiveTypeInfo - Class in com.huawei.dli.sdk.common
 
SimplePrimitiveTypeInfo(DataType) - Constructor for class com.huawei.dli.sdk.common.SimplePrimitiveTypeInfo
 
SimpleStruct - Class in com.huawei.dli.sdk.common.type
 
SimpleStructTypeInfo - Class in com.huawei.dli.sdk.common.type
 
SMALLINT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
SparkJob - Class in com.huawei.dli.sdk
 
SparkJob(Cluster) - Constructor for class com.huawei.dli.sdk.SparkJob
 
SparkJob(Cluster, String) - Constructor for class com.huawei.dli.sdk.SparkJob
 
SparkJobInfo - Class in com.huawei.dli.sdk.common
 
SparkJobInfo() - Constructor for class com.huawei.dli.sdk.common.SparkJobInfo
 
SparkJobResource - Class in com.huawei.dli.sdk.common
 
SparkJobResource() - Constructor for class com.huawei.dli.sdk.common.SparkJobResource
 
SparkJobResultInfo - Class in com.huawei.dli.sdk.common
 
SparkJobResultInfo(SessionInfo) - Constructor for class com.huawei.dli.sdk.common.SparkJobResultInfo
 
SparkJobStatus - Enum in com.huawei.dli.sdk.common
 
SQLJob - Class in com.huawei.dli.sdk
 
SQLJob(Queue, String) - Constructor for class com.huawei.dli.sdk.SQLJob
 
SQLJob(Queue, String, String) - Constructor for class com.huawei.dli.sdk.SQLJob
 
SQLJob(Queue, String, String, String) - Constructor for class com.huawei.dli.sdk.SQLJob
 
SqlUtils - Class in com.huawei.dli.sdk.common.utils
 
SqlUtils() - Constructor for class com.huawei.dli.sdk.common.utils.SqlUtils
 
stopFlinkJob(StopFlinkJobRequest) - Method in class com.huawei.dli.sdk.DLIClient
批量停止作业
stopSingleFlinkJob(Long, Boolean) - Method in class com.huawei.dli.sdk.DLIClient
取消flink自定义作业
StorageType - Enum in com.huawei.dli.sdk.common
 
STRING - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
StructTypeInfo - Interface in com.huawei.dli.sdk.common.type
 
submit() - Method in class com.huawei.dli.sdk.BatchJob
 
submit() - Method in class com.huawei.dli.sdk.ExportJob
Submit export job.
submit() - Method in class com.huawei.dli.sdk.ImportJob
Submit import job
submit() - Method in class com.huawei.dli.sdk.Job
 
submit() - Method in class com.huawei.dli.sdk.SparkJob
Submit a Spark job.
submit() - Method in class com.huawei.dli.sdk.SQLJob
Submit SQL job
submitFlinkSqlJob(SubmitFlinkSqlJobRequest) - Method in class com.huawei.dli.sdk.DLIClient
提交流式SQL作业到DLI服务 通过POST方式, 提交流式SQL作业, 请求体为JSON格式
submitQuery() - Method in class com.huawei.dli.sdk.SQLJob
Submit a SQL job, which returns a ResultSet object.

T

Table - Class in com.huawei.dli.sdk
 
Table(Database, String, String, TableType) - Constructor for class com.huawei.dli.sdk.Table
 
Table(Database, String, String, long, long, String, String, long, TableType, List<String>, String) - Constructor for class com.huawei.dli.sdk.Table
 
Table() - Constructor for class com.huawei.dli.sdk.Table
 
TableSchema - Class in com.huawei.dli.sdk.common
 
TableSchema() - Constructor for class com.huawei.dli.sdk.common.TableSchema
 
TableType - Enum in com.huawei.dli.sdk.common
 
tblSchema - Variable in class com.huawei.dli.sdk.TunnelJob
 
TIMESTAMP - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
TINYINT - Static variable in class com.huawei.dli.sdk.common.type.TypeInfoUtils
 
toJavaDate(int) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
Returns a java.util.Date from the number of days since epoch.
toJavaTimestamp(long) - Static method in class com.huawei.dli.sdk.common.utils.DateTimeUtils
Returns a java.sql.Timestamp from number of micros since epoch.
toJson() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
toJsonObj() - Method in class com.huawei.dli.sdk.common.SparkJobInfo
 
toString() - Method in class com.huawei.dli.sdk.Cluster
 
toString() - Method in class com.huawei.dli.sdk.common.AbstractPrimitiveTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.Column
 
toString() - Method in interface com.huawei.dli.sdk.common.DataTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.DecimalTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.JobResultInfo
 
toString() - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
toString(boolean, boolean) - Method in class com.huawei.dli.sdk.common.PartitionSpec
 
toString() - Method in class com.huawei.dli.sdk.common.SimplePrimitiveTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.SparkJobResultInfo
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleArray
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleArrayTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleMap
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleMapTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleStruct
 
toString() - Method in class com.huawei.dli.sdk.common.type.SimpleStructTypeInfo
 
toString() - Method in class com.huawei.dli.sdk.Database
 
toString() - Method in class com.huawei.dli.sdk.PackageResource
 
toString() - Method in class com.huawei.dli.sdk.Queue
 
toString() - Method in class com.huawei.dli.sdk.Table
 
transform(String, DataTypeInfo) - Static method in class com.huawei.dli.sdk.common.type.TypeUtils
Transform the data value from string to real data type in java
TunnelJob - Class in com.huawei.dli.sdk
 
TunnelJob() - Constructor for class com.huawei.dli.sdk.TunnelJob
 
TunnelJob.FileFormat - Enum in com.huawei.dli.sdk
 
typeInfo - Variable in class com.huawei.dli.sdk.common.type.SimpleArray
 
typeInfo - Variable in class com.huawei.dli.sdk.common.type.SimpleMap
 
typeInfo - Variable in class com.huawei.dli.sdk.common.type.SimpleStruct
 
TypeInfoParser - Class in com.huawei.dli.sdk.common.type
 
TypeInfoUtils - Class in com.huawei.dli.sdk.common.type
 
TypeUtils - Class in com.huawei.dli.sdk.common.type
 
TypeUtils() - Constructor for class com.huawei.dli.sdk.common.type.TypeUtils
 

U

updateAkSkAuth() - Method in class com.huawei.dli.sdk.authentication.Authentication
 
updateFlinkJarJob(UpdateFlinkJarJobRequest, Long) - Method in class com.huawei.dli.sdk.DLIClient
更新用户自定义Flink作业 目前仅支持Jar格式, 运行在独享集群中
updateFlinkJobTemplate(UpdateFlinkJobTemplateRequest, Long) - Method in class com.huawei.dli.sdk.DLIClient
更新作业模板 Update job template on Data lake insight
updateFlinkSqlJob(UpdateFlinkSqlJobRequest, Long) - Method in class com.huawei.dli.sdk.DLIClient
更新流式SQL作业 流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
updateResourceOrGroupOwner(UpdateResourceOwner) - Method in class com.huawei.dli.sdk.DLIClient
Update resource or group owner
updateTsdb(String, String, UpdateTsdbReq) - Method in class com.huawei.dli.sdk.DLIClient
修改时序数据库配置信息 修改时序数据库配置信息
UploadJob - Class in com.huawei.dli.sdk
 
UploadJob(Queue, String, String) - Constructor for class com.huawei.dli.sdk.UploadJob
Deprecated.
UploadJob(Queue, String, String, Boolean) - Constructor for class com.huawei.dli.sdk.UploadJob
Create a upload job to upload data to DLI.
UploadJob(Queue, String, String, String, Boolean) - Constructor for class com.huawei.dli.sdk.UploadJob
 
UploadJob(Queue, String, String, PartitionSpec, Boolean) - Constructor for class com.huawei.dli.sdk.UploadJob
Create a upload job to upload data to DLI.
uploadResources(String, String[], String) - Method in class com.huawei.dli.sdk.DLIClient
Upload resources sync.
uploadResources(String, String, String[], String) - Method in class com.huawei.dli.sdk.DLIClient
Upload resources sync.
uploadResourcesAsync(String, String[], String) - Method in class com.huawei.dli.sdk.DLIClient
Upload resources async.
uploadResourcesAsync(String, String, String[], String) - Method in class com.huawei.dli.sdk.DLIClient
Upload resources async.

V

validPartSpec(PartitionSpec) - Method in class com.huawei.dli.sdk.TunnelJob
 
valueOf(String) - Static method in enum com.huawei.dli.sdk.authentication.AuthenticationMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.BadRecordPolicy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.ChargingMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.CompressType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.DataType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.EnumSyncInfo
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.ExportMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.JobStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.JobSubmitMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.JobType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.SparkJobStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.StorageType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.common.TableType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.huawei.dli.sdk.TunnelJob.FileFormat
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.huawei.dli.sdk.authentication.AuthenticationMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.BadRecordPolicy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.ChargingMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.CompressType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.DataType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.EnumSyncInfo
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.ExportMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.JobStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.JobSubmitMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.JobType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.SparkJobStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.StorageType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.huawei.dli.sdk.common.TableType
Returns an array containing the constants of this enum type, in the order they are declared.
values - Variable in class com.huawei.dli.sdk.common.type.SimpleArray
 
values - Variable in class com.huawei.dli.sdk.common.type.SimpleMap
 
values - Variable in class com.huawei.dli.sdk.common.type.SimpleStruct
 
values() - Static method in enum com.huawei.dli.sdk.TunnelJob.FileFormat
Returns an array containing the constants of this enum type, in the order they are declared.

W

write(Row) - Method in class com.huawei.dli.sdk.AvroObsWriter
 
write(Row) - Method in class com.huawei.dli.sdk.ObsWriter
 
write(Row) - Method in class com.huawei.dli.sdk.Writer
 
Writer - Class in com.huawei.dli.sdk
 
Writer() - Constructor for class com.huawei.dli.sdk.Writer
 
A B C D E F G H I J K L M N O P Q R S T U V W 
Skip navigation links

Copyright © 2023. All rights reserved.