| 程序包 | 说明 |
|---|---|
| com.dtstack.dtcenter.loader.client | |
| com.dtstack.dtcenter.loader.client.hdfs | |
| com.dtstack.dtcenter.loader.client.sql | |
| com.dtstack.dtcenter.loader.downloader |
| 限定符和类型 | 方法和说明 |
|---|---|
IDownloader |
IClient.getDownloader(ISourceDTO source,
SqlQueryDTO queryDTO)
获取对应的downloader
|
IDownloader |
IClient.getDownloader(ISourceDTO source,
String sql,
Integer pageSize)
根据执行 sql 下载数据
|
IDownloader |
IHdfsFile.getDownloaderByFormat(ISourceDTO source,
String tableLocation,
List<String> columnNames,
String fieldDelimiter,
String fileFormat)
根据文件格式获取对应的downlaoder
|
IDownloader |
IHdfsFile.getFileDownloader(ISourceDTO iSource,
String path)
文件下载器
|
IDownloader |
IHdfsFile.getLogDownloader(ISourceDTO iSource,
SqlQueryDTO queryDTO)
日志下载器
|
| 限定符和类型 | 方法和说明 |
|---|---|
IDownloader |
HdfsFileProxy.getDownloaderByFormat(ISourceDTO source,
String tableLocation,
List<String> columnNames,
String fieldDelimiter,
String fileFormat) |
IDownloader |
HdfsFileProxy.getFileDownloader(ISourceDTO source,
String path) |
IDownloader |
HdfsFileProxy.getLogDownloader(ISourceDTO source,
SqlQueryDTO queryDTO) |
| 限定符和类型 | 方法和说明 |
|---|---|
IDownloader |
DataSourceClientProxy.getDownloader(ISourceDTO source,
SqlQueryDTO queryDTO) |
IDownloader |
DataSourceClientProxy.getDownloader(ISourceDTO source,
String sql,
Integer pageSize) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DownloaderProxy
IDownloader代理类
若不加此代理类,由于获取到IDownloader后,当前线程的ContextClassLoader会被设置成旧的ClassLoader
这样在执行IDownloader中方法的时候如果方法中有对线程ContextClassLoader进行获取操作则会导致ClassLoader不一致
|
| 构造器和说明 |
|---|
DownloaderProxy(IDownloader targetDownloader) |
Copyright © 2022. All rights reserved.