| 程序包 | 说明 |
|---|---|
| com.dtstack.dtcenter.loader.client | |
| com.dtstack.dtcenter.loader.client.hdfs |
| 限定符和类型 | 方法和说明 |
|---|---|
int |
IHdfsFile.writeByName(ISourceDTO source,
HdfsWriterDTO hdfsWriterDTO)
从文件中读取行,根据提供的分隔符号分割,再根据提供的hdfs分隔符合并,写入hdfs
---需要根据column信息判断导入的数据是否符合要求
|
int |
IHdfsFile.writeByPos(ISourceDTO source,
HdfsWriterDTO hdfsWriterDTO)
按位置写入
|
| 限定符和类型 | 方法和说明 |
|---|---|
int |
HdfsFileProxy.writeByName(ISourceDTO source,
HdfsWriterDTO hdfsWriterDTO) |
int |
HdfsFileProxy.writeByPos(ISourceDTO source,
HdfsWriterDTO hdfsWriterDTO) |
Copyright © 2022. All rights reserved.