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

Record.getFields介绍

[英]Returns the fields that are stored in this record.
[中]返回存储在此记录中的字段。

代码示例

代码示例来源：origin: apache/flume

private Event toEvent(Record record) {
 Map<String, String> headers = new HashMap();
 Map<String, Collection<Object>> recordMap = record.getFields().asMap();
 byte[] body = null;
 for (Map.Entry<String, Collection<Object>> entry : recordMap.entrySet()) {

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

private boolean hasAtLeastOneAttachment(Record record) {
 if (!record.getFields().containsKey(Fields.ATTACHMENT_BODY)) {
  LOG.debug("Command failed because of missing attachment for record: {}", record);
  return false;
 }
 return true;
}

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

private boolean hasAtLeastOneMimeType(Record record) {
 if (!record.getFields().containsKey(Fields.ATTACHMENT_MIME_TYPE)) {
  LOG.debug("Command failed because of missing MIME type for record: {}", record);
  return false;
 }  
 return true;
}

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

@Override
public boolean equals(Object other) {
 if (other instanceof Record) {
  return fields.equals(((Record)other).getFields());
 }
 return false;
}

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

private boolean hasAtLeastOneMimeType(Record record) {
 if (!record.getFields().containsKey(Fields.ATTACHMENT_MIME_TYPE)) {
  LOG.debug("Command failed because of missing MIME type for record: {}", record);
  return false;
 }  
 return true;
}

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

private boolean hasAtLeastOneAttachment(Record record) {
 if (!record.getFields().containsKey(Fields.ATTACHMENT_BODY)) {
  LOG.debug("Command failed because of missing attachment for record: {}", record);
  return false;
 }
 return true;
}

代码示例来源：origin: org.apache.solr/solr-morphlines-cell

private boolean hasAtLeastOneMimeType(Record record) {
 if (!record.getFields().containsKey(Fields.ATTACHMENT_MIME_TYPE)) {
  LOG.debug("Command failed because of missing MIME type for record: {}", record);
  return false;
 }  
 return true;
}

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

@Override
public boolean equals(Object other) {
 if (other instanceof Record) {
  return fields.equals(((Record)other).getFields());
 }
 return false;
}

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

private void doProcessSlow(Record record) {
 Iterator<String> iter = record.getFields().asMap().keySet().iterator();
 while (iter.hasNext()) {
  if (nameMatcher.matches(iter.next())) {
   iter.remove();
  }
 }
}

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

private void doProcessSlow(Record record) {
 Iterator<String> iter = record.getFields().asMap().keySet().iterator();
 while (iter.hasNext()) {
  if (nameMatcher.matches(iter.next())) {
   iter.remove();
  }
 }
}

代码示例来源：origin: NGDATA/hbase-indexer

private SolrInputDocument convert(Record record) {
  Map<String, Collection<Object>> map = record.getFields().asMap();
  SolrInputDocument doc = new SolrInputDocument(new HashMap(2 * map.size()));
  for (Map.Entry<String, Collection<Object>> entry : map.entrySet()) {
    doc.setField(entry.getKey(), entry.getValue());
  }
  return doc;
}

代码示例来源：origin: org.apache.solr/solr-morphlines-core

private SolrInputDocument convert(Record record) {
 Map<String, Collection<Object>> map = record.getFields().asMap();
 SolrInputDocument doc = new SolrInputDocument(new HashMap(2 * map.size()));
 for (Map.Entry<String, Collection<Object>> entry : map.entrySet()) {
  String key = entry.getKey();
  doc.setField(key, entry.getValue(), getBoost(key));
 }
 return doc;
}

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

@Override
protected boolean doProcess(Record record) {      
 if (preserveExisting && record.getFields().containsKey(fieldName)) {
  // we must preserve the existing timestamp
 } else {
  record.replaceValues(fieldName, System.currentTimeMillis());
 }
 
 // pass record to next command in chain:
 return super.doProcess(record);
}

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

private Record toRecord(SolrInputDocument doc) {
 Record record = new Record();
 for (Entry<String, SolrInputField> entry : doc.entrySet()) {
  record.getFields().putAll(entry.getKey(), entry.getValue().getValues());        
 }
 return record;
}

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

private List resolveReference(String reference, Record record, Config config) {
 Matcher matcher = PATTERN.matcher(reference);
 if (!matcher.matches()) {
  throw new MorphlineCompilationException("Invalid variable reference", config);
 }
 String value = reference.substring("@{".length(), reference.length() - "}".length());
 List resolvedValues = record.getFields().get(value);
 return resolvedValues;
}

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

@Override
protected boolean doProcess(Record record) {      
 if (preserveExisting && record.getFields().containsKey(fieldName)) {
  ; // we must preserve the existing id
 } else {
  record.replaceValues(fieldName, generateUUID());
 }
 
 // pass record to next command in chain:
 return super.doProcess(record);
}

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

protected ListMultimap<String, Object> next(Iterator<SolrDocument> iter) {
 SolrDocument doc = iter.next();
 Record record = toRecord(doc);
 record.removeAll("_version_"); // the values of this field are unknown and internal to solr
 return record.getFields();    
}

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

private Record createEvent(InputStream in, ListMultimap<String, Object> headers) {
 Record record = new Record();
 record.getFields().putAll(headers);
 record.replaceValues(Fields.ATTACHMENT_BODY, in);
 return record;
}

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

@Override
protected boolean doProcess(Record record) {
 if (preserveExisting && record.getFields().containsKey(fieldName)) {
  // we must preserve the existing id
 } else {
  record.replaceValues(fieldName, seqNum++);
 }
 return super.doProcess(record);
}

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

private Record toRecord(SolrDocument doc) {
 Record record = new Record();
 for (String key : doc.keySet()) {
  record.getFields().replaceValues(key, doc.getFieldValues(key));        
 }
 return record;
}