org.kitesdk.morphline.api.Record.toString()方法的使用及代码示例

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

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

Record.toString介绍

暂无

代码示例

代码示例来源:origin: sequenceiq/sequenceiq-samples

@Override
public boolean process(Record record) {
  line.set(record.toString());
  try {
    context.write(line, null);
  } catch (Exception e) {
    LOGGER.warn("Cannot write record to context", e);
  }
  return true;
}

代码示例来源:origin: kite-sdk/kite

private void evaluate2(int from, Record record, StringBuilder buf, ArrayList<Object> results) {
 if (from >= fields.size()) {
  results.add(buf.toString());
  return;
 }
 
 Object item = fields.get(from);
 if (item instanceof String) {
  buf.append(item);
  evaluate2(from + 1, record, buf, results);
 } else {
  String ref = ((Field) item).getName();
  if (ref.length() == 0) {
   buf.append(record.toString()); // @{} means dump string representation of entire record
   evaluate2(from + 1, record, buf, results);
  } else {
   List resolvedValues = record.get(ref);
   for (Object value : resolvedValues) {
    StringBuilder buf2 = new StringBuilder(buf);
    buf2.append(value.toString());
    evaluate2(from + 1, record, buf2, results);
   }
  }
 }
}

代码示例来源:origin: org.kitesdk/kite-morphlines-core

private void evaluate2(int from, Record record, StringBuilder buf, ArrayList<Object> results) {
 if (from >= fields.size()) {
  results.add(buf.toString());
  return;
 }
 
 Object item = fields.get(from);
 if (item instanceof String) {
  buf.append(item);
  evaluate2(from + 1, record, buf, results);
 } else {
  String ref = ((Field) item).getName();
  if (ref.length() == 0) {
   buf.append(record.toString()); // @{} means dump string representation of entire record
   evaluate2(from + 1, record, buf, results);
  } else {
   List resolvedValues = record.get(ref);
   for (Object value : resolvedValues) {
    StringBuilder buf2 = new StringBuilder(buf);
    buf2.append(value.toString());
    evaluate2(from + 1, record, buf2, results);
   }
  }
 }
}

代码示例来源:origin: kite-sdk/kite

private String resolveExpressionSimple(String expr, Record record) {
 Matcher matcher = PATTERN.matcher(expr);    
 StringBuilder buf = new StringBuilder();
 int from = 0;
 while (matcher.find()) {
  int start = matcher.start();
  int end = matcher.end();
  buf.append(expr.substring(from, start));
  String ref = expr.substring(start + "@{".length(), end - "}".length());
  if (ref.length() == 0) {
   buf.append(record.toString()); // @{} means dump string representation of entire record 
  } else {
   List resolvedValues = record.getFields().get(ref);
   Joiner.on(" ").appendTo(buf, resolvedValues);
  }
  from = end;
 }
 buf.append(expr.substring(from, expr.length()));
 return buf.toString();
}

代码示例来源:origin: kite-sdk/kite

private String toString(GenericData.Record avroRecord) {
 Record record = new Record();
 for (Field field : avroRecord.getSchema().getFields()) {
  record.put(field.name(), avroRecord.get(field.pos()));
 }
 return record.toString(); // prints sorted by key for human readability
}

相关文章