| 程序包 | 说明 |
|---|---|
| com.dtstack.dtcenter.loader.client | |
| com.dtstack.dtcenter.loader.client.hdfs | |
| com.dtstack.dtcenter.loader.client.sql |
| 限定符和类型 | 方法和说明 |
|---|---|
List<ColumnMetaDTO> |
IHdfsFile.getColumnList(ISourceDTO source,
SqlQueryDTO queryDTO,
String fileFormat)
获取hdfs上存储文件的字段信息
|
List<ColumnMetaDTO> |
IClient.getColumnMetaData(ISourceDTO source,
SqlQueryDTO queryDTO)
获取表字段属性
字段名若不填则默认全部, 是否过滤分区字段 不填默认不过滤
|
List<ColumnMetaDTO> |
IClient.getColumnMetaDataWithSql(ISourceDTO source,
SqlQueryDTO queryDTO)
根据自定义sql获取表字段属性
|
List<ColumnMetaDTO> |
IClient.getFlinkColumnMetaData(ISourceDTO source,
SqlQueryDTO queryDTO)
获取flinkSql字段名称
|
List<ColumnMetaDTO> |
IClient.getPartitionColumn(ISourceDTO source,
SqlQueryDTO queryDTO)
获取分区字段
|
| 限定符和类型 | 方法和说明 |
|---|---|
List<ColumnMetaDTO> |
HdfsFileProxy.getColumnList(ISourceDTO source,
SqlQueryDTO queryDTO,
String fileFormat) |
| 限定符和类型 | 方法和说明 |
|---|---|
List<ColumnMetaDTO> |
DataSourceClientProxy.getColumnMetaData(ISourceDTO source,
SqlQueryDTO queryDTO) |
List<ColumnMetaDTO> |
DataSourceClientProxy.getColumnMetaDataWithSql(ISourceDTO source,
SqlQueryDTO queryDTO) |
List<ColumnMetaDTO> |
DataSourceClientProxy.getFlinkColumnMetaData(ISourceDTO source,
SqlQueryDTO queryDTO) |
List<ColumnMetaDTO> |
DataSourceClientProxy.getPartitionColumn(ISourceDTO source,
SqlQueryDTO queryDTO) |
Copyright © 2022. All rights reserved.