本文整理了Java中com.alibaba.datax.common.element.Record.setColumn
方法的一些代码示例,展示了Record.setColumn
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Record.setColumn
方法的具体详情如下:
包路径:com.alibaba.datax.common.element.Record
类名称:Record
方法名:setColumn
暂无
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(columnIndex, new StringColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(columnIndex, new StringColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(columnIndex, new StringColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
@Override
public Record evaluate(Record record, Object... paras) {
try {
if (paras.length < 2) {
throw new RuntimeException("dx_enum transformer缺少参数");
}
columnIndex = (Integer) paras[0];
key = String.valueOf(paras[1]);
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
}
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();
if(oriValue == null){
return record;
}
int offset = Integer.parseInt(key);
double newValue = EnumerateMasker.mask(column.asLong(), offset);
record.setColumn(columnIndex, new DoubleColumn(newValue));
} catch (Exception e){
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(),e);
}
return record;
}
}
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(columnIndex, new StringColumn(newValue));
record.setColumn(columnIndex, new LongColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
EpsilonDifferentialPrivacyImpl masker = new EpsilonDifferentialPrivacyImpl();
newValue = masker.maskOne(Double.parseDouble(oriValue), Double.parseDouble(key));
record.setColumn(columnIndex, new DoubleColumn(newValue));
EpsilonDifferentialPrivacyImpl masker = new EpsilonDifferentialPrivacyImpl();
newValue = masker.maskOne(Long.valueOf(oriValue), Double.parseDouble(key));
record.setColumn(columnIndex, new LongColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
@Override
public Record evaluate(Record record, Object... paras) {
try {
if (paras.length < 1) {
throw new RuntimeException("dx_md5 transformer缺少参数");
}
columnIndex = (Integer) paras[0];
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
}
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();
if (oriValue == null) {
return record;
}
if(column.getType() == Column.Type.STRING) {
MD5EncryptionImpl masker = new MD5EncryptionImpl();
String newValue = masker.execute(oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
}
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(), e);
}
return record;
}
}
代码示例来源:origin: ECNU-1X/DataX-Masking
AES masker = new AES(key);
newValue = masker.encode(oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
AES masker = new AES(key);
newValue = masker.decode(oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
record.setColumn(columnIndex, new StringColumn(newValue));
String newValue = "";
newValue = masker.publicEncrypt(masker.getPublicKey(), oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
String newValue = "";
newValue = masker.privateDecrypt(masker.getPrivateKey(), oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(columnIndex, new DateColumn(newValue));
} else if (column.getType() == Column.Type.LONG || column.getType() == Column.Type.INT) {
int mod = 0;
record.setColumn(columnIndex, new LongColumn(newValue));
} else if (column.getType() == Column.Type.DOUBLE) {
Double newValue = FloorMasker.mask(column.asDouble());
record.setColumn(columnIndex, new DoubleColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
if(column.getType() == Column.Type.STRING){
String newValue = masker.mask(column.asString());
record.setColumn(columnIndex, new StringColumn(newValue));
record.setColumn(columnIndex, new DateColumn(newValue));
record.setColumn(columnIndex, new LongColumn(newValue));
record.setColumn(columnIndex, new BoolColumn(newValue));
record.setColumn(columnIndex, new DoubleColumn(newValue));
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(0, new StringColumn(Bytes.toStringBinary(result.getRow())));
throw e;
代码示例来源:origin: ECNU-1X/DataX-Masking
record.setColumn(0, new StringColumn(Bytes.toStringBinary(result.getRow())));
throw e;
内容来源于网络,如有侵权,请联系作者删除!