com.alibaba.datax.common.util.Configuration.toJSON()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(215)

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

Configuration.toJSON介绍

[英]将Configuration作为JSON输出
[中]将配置作为JSON输出

代码示例

代码示例来源:origin: ECNU-1X/DataX-Masking

@Override
public String toString() {
  return this.toJSON();
}

代码示例来源:origin: ECNU-1X/DataX-Masking

public void init(Configuration originalConfig) {
  OriginalConfPretreatmentUtil.doPretreatment(originalConfig, this.dataBaseType);
  LOG.debug("After job init(), originalConfig now is:[\n{}\n]",
      originalConfig.toJSON());
}

代码示例来源:origin: ECNU-1X/DataX-Masking

public void init(Configuration originalConfig) {
  OriginalConfPretreatmentUtil.doPretreatment(originalConfig);
  LOG.debug("After job init(), job config now is:[\n{}\n]",
      originalConfig.toJSON());
}

代码示例来源:origin: ECNU-1X/DataX-Masking

LOG.debug(configuration.toJSON());

代码示例来源:origin: ECNU-1X/DataX-Masking

@Override
public void init() {
  startTime = System.currentTimeMillis();
  this.originalConfig = super.getPluginJobConf();
  this.writeMode = this.originalConfig.getString(Key.WRITE_MODE);
  if(null == this.writeMode) {
    LOG.warn("您未指定[writeMode]参数,  默认采用load模式, load模式只能用于离线表");
    this.writeMode = Constant.LOADMODE;
    this.originalConfig.set(Key.WRITE_MODE, "load");
  }
  if(Constant.LOADMODE.equalsIgnoreCase(this.writeMode)) {
    AdsUtil.checkNecessaryConfig(this.originalConfig, this.writeMode);
    loadModeInit();
  } else if(Constant.INSERTMODE.equalsIgnoreCase(this.writeMode) || Constant.STREAMMODE.equalsIgnoreCase(this.writeMode)) {
    AdsUtil.checkNecessaryConfig(this.originalConfig, this.writeMode);
    List<String> allColumns = AdsInsertUtil.getAdsTableColumnNames(originalConfig);
    AdsInsertUtil.dealColumnConf(originalConfig, allColumns);
    LOG.debug("After job init(), originalConfig now is:[\n{}\n]",
        originalConfig.toJSON());
  } else {
    throw DataXException.asDataXException(AdsWriterErrorCode.INVALID_CONFIG_VALUE, "writeMode 必须为 'load' 或者 'insert' 或者 'stream'");
  }
}

代码示例来源:origin: ECNU-1X/DataX-Masking

dealedColumns.add(eachColumnConfig.toJSON());

代码示例来源:origin: ECNU-1X/DataX-Masking

logger.debug("After job prepare(), originalConfig now is:[\n{}\n]", writerSliceConfig.toJSON());

代码示例来源:origin: ECNU-1X/DataX-Masking

originalConfig.toJSON());

代码示例来源:origin: ECNU-1X/DataX-Masking

String functionName = configuration.getString("name");
if (StringUtils.isEmpty(functionName)) {
  throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_CONFIGURATION_ERROR, "config=" + configuration.toJSON());

代码示例来源:origin: ECNU-1X/DataX-Masking

this.originalConfig.toJSON());

相关文章