Commit 864ce4d4 authored by 韵成's avatar 韵成

change package structure

parent 6f798436
......@@ -21,7 +21,7 @@ import static com.alibaba.datax.plugin.rdbms.util.DBUtilErrorCode.*;
import static com.alibaba.datax.plugin.rdbms.util.DataBaseType.PostgreSQL;
/**
* Created by yuncheng on 07/13/2019.
* @author yuncheng
*/
public class AdbpgWriter extends Writer {
private static final DataBaseType DATABASE_TYPE = DataBaseType.PostgreSQL;
......
......@@ -23,7 +23,7 @@ import java.sql.Types;
import java.util.ArrayList;
import java.util.List;
/**
* Created by yuncheng on 07/15/2019.
* @author yuncheng
*/
public class Adb4pgClientProxy implements AdbProxy {
private static final Logger LOG = LoggerFactory.getLogger(Adb4pgClientProxy.class);
......
......@@ -4,7 +4,7 @@ import com.alibaba.datax.common.plugin.RecordReceiver;
import java.sql.Connection;
/**
* Created by yuncheng on 07/15/2019.
* @author yuncheng
*/
public interface AdbProxy {
public abstract void startWriteWithConnection(RecordReceiver recordReceiver, Connection connection);
......
......@@ -23,7 +23,7 @@ import java.util.*;
import static com.alibaba.datax.plugin.rdbms.util.DBUtilErrorCode.COLUMN_SPLIT_ERROR;
/**
* Created by yuncheng on 07/13/2019.
* @author yuncheng
*/
public class Adb4pgUtil {
......
package com.alibaba.datax.plugin.writer.adbpgwriter.util;
/**
* Created by yuncheng on 07/13/2019.
* @author yuncheng
*/
public class Constant {
public static final int DEFAULT_RETRY_TIMES = 3;
......
package com.alibaba.datax.plugin.writer.adbpgwriter.util;
/**
* Created by yuncheng on 07/13/2019.
* @author yuncheng
*/
public class Key {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment