comment

Author: sishu@dtstack.com

hbase/hbase-side/src/main/java/com/dtstack/flink/sql/side/hbase/ReplaceOperator.java

@@ -49,7 +49,7 @@ public String replaceStr(Map<String, Object> refData){
     }
 
     /**
-     * 根据函数提供自定义的处理
+     * The processing function to provide custom
      * @param replaceStr
      * @return
      */

hbase/hbase-side/src/main/java/com/dtstack/flink/sql/side/hbase/RowKeyBuilder.java

@@ -30,7 +30,7 @@
 import java.util.regex.Pattern;
 
 /**
- * rowkey 生成规则
+ * rowkey rule
  * Date: 2018/8/23
  * Company: www.dtstack.com
  * @author xuchao

hbase/hbase-side/src/main/java/com/dtstack/flink/sql/side/hbase/table/HbaseSideParser.java

@@ -32,7 +32,7 @@
 import static com.dtstack.flink.sql.table.TableInfo.PARALLELISM_KEY;
 
 /**
- * 定义的hbase 字段信息必须包含别名-->sql里面不允许出现“:”
+ * hbase field information must include the definition of an alias -> sql which does not allow ":"
  * Date: 2018/8/21
  * Company: www.dtstack.com
  * @author xuchao

hbase/hbase-side/src/main/java/com/dtstack/flink/sql/side/hbase/table/HbaseSideTableInfo.java

@@ -28,7 +28,7 @@
 import java.util.Map;
 
 /**
- * hbase 维表填写的属性
+ * hbase-dimensional form of property
  * Date: 2018/8/21
  * Company: www.dtstack.com
  * @author xuchao

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java

@@ -35,7 +35,11 @@
 import org.apache.flink.table.sinks.TableSink;
 import org.apache.flink.types.Row;
 
-
+/**
+ * Date: 2018/09/14
+ * Company: www.dtstack.com
+ * @author sishu.yss
+ */
 public class HbaseSink implements RetractStreamTableSink<Row>, IStreamSinkGener<HbaseSink> {
 
     protected String[] fieldNames;

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseSinkParser.java

@@ -29,6 +29,11 @@
 
 import static com.dtstack.flink.sql.table.TableInfo.PARALLELISM_KEY;
 
+/**
+ * Date: 2018/09/14
+ * Company: www.dtstack.com
+ * @author sishu.yss
+ */
 public class HbaseSinkParser extends AbsTableParser {
 
 

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseTableInfo.java

@@ -23,9 +23,13 @@
 
 import com.dtstack.flink.sql.table.TargetTableInfo;
 import org.apache.flink.calcite.shaded.com.google.common.base.Preconditions;
-
 import java.util.Map;
 
+/**
+ * Date: 2018/09/14
+ * Company: www.dtstack.com
+ * @author sishu.yss
+ */
 public class HbaseTableInfo extends TargetTableInfo {
 
     private static final String CURR_TYPE = "hbase";

kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka09/CustomerJsonDeserialization.java

@@ -34,7 +34,7 @@
 import java.util.Iterator;
 
 /**
- * 自定义的json字符串解析
+ * json string parsing custom
  * Date: 2017/5/28
  * Company: www.dtstack.com
  * @author xuchao

launcher/src/main/java/com/dtstack/flink/sql/launcher/LauncherMain.java

@@ -32,6 +32,12 @@
 import static com.dtstack.flink.sql.launcher.LauncherOptions.OPTION_LOCAL_SQL_PLUGIN_PATH;
 import static com.dtstack.flink.sql.launcher.LauncherOptions.OPTION_MODE;
 
+/**
+ * Date: 2017/2/20
+ * Company: www.dtstack.com
+ * @author xuchao
+ */
+
 public class LauncherMain {
 
     private static final String CORE_JAR = "core.jar";

mysql/mysql-side/src/main/java/com/dtstack/flink/sql/side/mysql/MysqlAsyncReqRow.java

@@ -69,7 +69,6 @@ public class MysqlAsyncReqRow extends AsyncReqRow {
 
     private final static String MYSQL_DRIVER = "com.mysql.jdbc.Driver";
 
-    //TODO 这三个参数应该如何设置？
     private final static int DEFAULT_VERTX_EVENT_LOOP_POOL_SIZE = 10;
 
     private final static int DEFAULT_VERTX_WORKER_POOL_SIZE = 20;
@@ -252,7 +251,7 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
 
         mySQLClient.getConnection(conn -> {
             if (conn.failed()) {
-                //处理失败情况
+                //Treatment failures
                 resultFuture.completeExceptionally(conn.cause());
                 return;
             }