Examples of com.alibaba.otter.shared.etl.extend.fileresolver.FileInfo

        // 基本步骤：
        // 1. 获取binlog中的变更字段，比如组成文件有多个字段组成version+path
        // 2. 基于字段内容，构造一个文件路径，目前开源版本只支持本地文件的同步.(如果是网络文件，建议进行NFS mount到ndde机器).
        // 3. 返回FileInfo数组，(目前不支持目录同步，如果是目录需要展开为多个FileInfo的子文件)，如果不需要同步，则返回null.
        String path = rowMap.get("FIELD"); //注意为大写
        FileInfo fileInfo = null;
        if (StringUtils.isNotEmpty(path)) {
            fileInfo = new FileInfo(path);
            return new FileInfo[] { fileInfo };
        } else {
            return null;
        }
    }

public class TestFileResolver extends AbstractFileResolver {


    public FileInfo[] getFileInfo(Map<String, String> rowMap) {
        String labelAddress = rowMap.get("REMARKS");
        String arandaAddress = rowMap.get("REMARKS2");
        FileInfo fileInfo = null;
        if (labelAddress != null && labelAddress.length() != 0) {
            if (arandaAddress != null && arandaAddress.length() != 0) {
                fileInfo = new FileInfo(arandaAddress, labelAddress);
            } else {
                fileInfo = new FileInfo(labelAddress);
            }


            return new FileInfo[] { fileInfo };
        } else {
            return null;

Related Classes of com.alibaba.otter.shared.etl.extend.fileresolver.FileInfo

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.