Skip to content

Commit

Permalink
fix some typos
Browse files Browse the repository at this point in the history
Signed-off-by: cuishuang <[email protected]>
  • Loading branch information
cuishuang committed Jun 18, 2022
1 parent 894b57b commit a66a1b5
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ public static byte convertToDataType(String type) throws IllegalArgumentExceptio
} else if ("datetime".equals(type)) {
return DATETIME;
} else {
throw new IllegalArgumentException("unkown type: " + type);
throw new IllegalArgumentException("unknown type: " + type);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ public Record evaluate(Record record, Object... paras) {
} else if (code.equalsIgnoreCase("<=")) {
return doLess(record, value, column, true);
} else {
throw new RuntimeException("dx_filter can't suport code:" + code);
throw new RuntimeException("dx_filter can't support code:" + code);
}
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(), e);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ public List<Configuration> doSplit(int adviceNumber) {
if (querySql == null || querySql.isEmpty()) {
// 如果splitPoints为空,则根据splitKey自动切分,不过这种切分方式无法保证数据均分,且只支持整形和字符型列
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);
if (null == minMaxPK) {
throw DataXException.asDataXException(HBase20xSQLReaderErrorCode.ILLEGAL_SPLIT_PK,
Expand Down Expand Up @@ -208,7 +208,7 @@ public List<Configuration> doSplit(int adviceNumber) {
}

} else {
LOG.info("Split accoring splitPoints...");
LOG.info("Split according splitPoints...");
// 根据指定splitPoints进行切分
rangeList = buildSplitRange();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ public static Record parseRowToLine(Row row, List<OTSColumn> columns, Record lin
case BOOLEAN: line.addColumn(new BoolColumn(v.asBoolean())); break;
case BINARY: line.addColumn(new BytesColumn(v.asBinary())); break;
default:
throw new IllegalArgumentException("Unsuporrt tranform the type: " + col.getValue().getType() + ".");
throw new IllegalArgumentException("Unsupported transform the type: " + col.getValue().getType() + ".");
}
}
}
Expand Down

0 comments on commit a66a1b5

Please sign in to comment.