github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 04:59:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix some typos

Browse Source 
Signed-off-by: cuishuang <imcusg@gmail.com>
This commit is contained in:
cuishuang 2022-06-18 13:18:53 +08:00
parent 894b57bd3d
commit a66a1b5df8
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/odps/DataType.java
View File

@ -70,7 +70,7 @@ public class DataType {
} else if ("datetime".equals(type)) { } else if ("datetime".equals(type)) {
return DATETIME; return DATETIME;
} else { } else {
throw new IllegalArgumentException("unkown type: " + type); throw new IllegalArgumentException("unknown type: " + type);
} }
} }

2
core/src/main/java/com/alibaba/datax/core/transport/transformer/FilterTransformer.java
View File

@ -61,7 +61,7 @@ public class FilterTransformer extends Transformer {
} else if (code.equalsIgnoreCase("<=")) { } else if (code.equalsIgnoreCase("<=")) {
return doLess(record, value, column, true); return doLess(record, value, column, true);
} else { } else {
throw new RuntimeException("dx_filter can't suport code:" + code); throw new RuntimeException("dx_filter can't support code:" + code);
} }
} catch (Exception e) { } catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(), e); throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(), e);

4
hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20SQLReaderHelper.java
View File

@ -175,7 +175,7 @@ public class HBase20SQLReaderHelper {
if (querySql == null || querySql.isEmpty()) { if (querySql == null || querySql.isEmpty()) {
// 如果splitPoints为空，则根据splitKey自动切分，不过这种切分方式无法保证数据均分，且只支持整形和字符型列 // 如果splitPoints为空，则根据splitKey自动切分，不过这种切分方式无法保证数据均分，且只支持整形和字符型列
if (splitPoints == null || splitPoints.isEmpty()) { if (splitPoints == null || splitPoints.isEmpty()) {
LOG.info("Split accoring min and max value of splitColumn..."); LOG.info("Split according min and max value of splitColumn...");
Pair<Object, Object> minMaxPK = getPkRange(configuration); Pair<Object, Object> minMaxPK = getPkRange(configuration);
if (null == minMaxPK) { if (null == minMaxPK) {
throw DataXException.asDataXException(HBase20xSQLReaderErrorCode.ILLEGAL_SPLIT_PK, throw DataXException.asDataXException(HBase20xSQLReaderErrorCode.ILLEGAL_SPLIT_PK,
@ -208,7 +208,7 @@ public class HBase20SQLReaderHelper {
} }
} else { } else {
LOG.info("Split accoring splitPoints..."); LOG.info("Split according splitPoints...");
// 根据指定splitPoints进行切分 // 根据指定splitPoints进行切分
rangeList = buildSplitRange(); rangeList = buildSplitRange();
} }

2
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/Common.java
View File

@ -119,7 +119,7 @@ public class Common {
case BOOLEAN: line.addColumn(new BoolColumn(v.asBoolean())); break; case BOOLEAN: line.addColumn(new BoolColumn(v.asBoolean())); break;
case BINARY: line.addColumn(new BytesColumn(v.asBinary())); break; case BINARY: line.addColumn(new BytesColumn(v.asBinary())); break;
default: default:
throw new IllegalArgumentException("Unsuporrt tranform the type: " + col.getValue().getType() + "."); throw new IllegalArgumentException("Unsupported transform the type: " + col.getValue().getType() + ".");
} }
} }
} }