本文整理了Java中com.alibaba.datax.common.element.Record.toString
方法的一些代码示例,展示了Record.toString
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Record.toString
方法的具体详情如下:
包路径:com.alibaba.datax.common.element.Record
类名称:Record
方法名:toString
暂无
代码示例来源:origin: ECNU-1X/DataX-Masking
private void rowsToSender(List<Row> rows, RecordSender sender, List<OTSColumn> columns) {
for (Row row : rows) {
Record line = sender.createRecord();
line = Common.parseRowToLine(row, columns, line);
LOG.debug("Reader send record : {}", line.toString());
sender.sendToWriter(line);
}
}
代码示例来源:origin: ECNU-1X/DataX-Masking
Record oneRecord = buildOneRecord(recordSender, kafkarecord.value());
System.out.println("send to writer " + oneRecord.toString());
recordSender.sendToWriter(oneRecord);
}catch (Exception e){
代码示例来源:origin: ECNU-1X/DataX-Masking
} catch (IllegalArgumentException e) {
if(e.getMessage().equals("No columns to insert") && nullMode.equals(NullModeType.Skip)){
LOG.info(String.format("record is empty, 您配置nullMode为[skip],将会忽略这条记录,record[%s]", record.toString()));
continue;
}else {
代码示例来源:origin: ECNU-1X/DataX-Masking
public void startWriter(RecordReceiver lineReceiver,TaskPluginCollector taskPluginCollector){
Record record;
try {
while ((record = lineReceiver.getFromReader()) != null) {
Put put;
try {
put = convertRecordToPut(record);
} catch (Exception e) {
taskPluginCollector.collectDirtyRecord(record, e);
continue;
}
try {
this.htable.put(put);
} catch (IllegalArgumentException e) {
if(e.getMessage().equals("No columns to insert") && nullMode.equals(NullModeType.Skip)){
LOG.info(String.format("record is empty, 您配置nullMode为[skip],将会忽略这条记录,record[%s]", record.toString()));
continue;
}else {
taskPluginCollector.collectDirtyRecord(record, e);
continue;
}
}
}
}catch (IOException e){
throw DataXException.asDataXException(Hbase094xWriterErrorCode.PUT_HBASE_ERROR,e);
}finally {
Hbase094xHelper.closeTable(this.htable);
}
}
代码示例来源:origin: ECNU-1X/DataX-Masking
LOG.debug("read data " + record.toString()
+ " occur exception:", e);
代码示例来源:origin: ECNU-1X/DataX-Masking
LOG.debug("read data " + record.toString()
+ " occur exception:", e);
代码示例来源:origin: ECNU-1X/DataX-Masking
LOG.debug("read data " + record.toString()
+ " occur exception:", e);
代码示例来源:origin: ECNU-1X/DataX-Masking
Record record;
while ((record = recordReceiver.getFromReader()) != null) {
LOG.debug("Record Raw: {}", record.toString());
内容来源于网络,如有侵权,请联系作者删除!