com.alibaba.datax.common.element.Record.setColumn()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.4k)|赞(0)|评价(0)|浏览(117)

本文整理了Java中com.alibaba.datax.common.element.Record.setColumn方法的一些代码示例,展示了Record.setColumn的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Record.setColumn方法的具体详情如下:
包路径:com.alibaba.datax.common.element.Record
类名称:Record
方法名:setColumn

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;

相关文章