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

AvroUtils.getFieldHelper介绍

[英]Helper method that does the actual work for #getFieldValue(GenericRecord,String)
[中]为#getFieldValue（GenericRecord，String）执行实际工作的Helper方法

代码示例

代码示例来源：origin: apache/incubator-gobblin

public static Map<String, Object> getMultiFieldValue(GenericRecord record, String fieldLocation) {
 Preconditions.checkNotNull(record);
 Preconditions.checkArgument(!Strings.isNullOrEmpty(fieldLocation));
 Splitter splitter = Splitter.on(FIELD_LOCATION_DELIMITER).omitEmptyStrings().trimResults();
 List<String> pathList = splitter.splitToList(fieldLocation);
 if (pathList.size() == 0) {
  return Collections.emptyMap();
 }
 HashMap<String, Object> retVal = new HashMap<String, Object>();
 AvroUtils.getFieldHelper(retVal, record, pathList, 0);
 return retVal;
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Given a GenericRecord, this method will return the field specified by the path parameter. The
 * fieldLocation parameter is an ordered string specifying the location of the nested field to retrieve. For example,
 * field1.nestedField1 takes field "field1", and retrieves "nestedField1" from it.
 * @param schema is the record to retrieve the schema from
 * @param fieldLocation is the location of the field
 * @return the field
 */
public static Optional<Field> getField(Schema schema, String fieldLocation) {
 Preconditions.checkNotNull(schema);
 Preconditions.checkArgument(!Strings.isNullOrEmpty(fieldLocation));
 Splitter splitter = Splitter.on(FIELD_LOCATION_DELIMITER).omitEmptyStrings().trimResults();
 List<String> pathList = Lists.newArrayList(splitter.split(fieldLocation));
 if (pathList.size() == 0) {
  return Optional.absent();
 }
 return AvroUtils.getFieldHelper(schema, pathList, 0);
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Helper method that does the actual work for {@link #getField(Schema, String)}
 * @param schema passed from {@link #getFieldSchema(Schema, String)}
 * @param pathList passed from {@link #getFieldSchema(Schema, String)}
 * @param field keeps track of the index used to access the list pathList
 * @return the field
 */
private static Optional<Field> getFieldHelper(Schema schema, List<String> pathList, int field) {
 Field curField = schema.getField(pathList.get(field));
 if (field + 1 == pathList.size()) {
  return Optional.fromNullable(curField);
 }
 Schema fieldSchema = curField.schema();
 switch (fieldSchema.getType()) {
  case UNION:
   throw new AvroRuntimeException("Union of complex types cannot be handled : " + schema);
  case MAP:
   return AvroUtils.getFieldHelper(fieldSchema.getValueType(), pathList, ++field);
  case RECORD:
   return AvroUtils.getFieldHelper(fieldSchema, pathList, ++field);
  default:
   throw new AvroRuntimeException("Invalid type in schema : " + schema);
 }
}

代码示例来源：origin: apache/incubator-gobblin

AvroUtils.getFieldHelper(retVal, getObjectFromMap((Map) data, pathList.get(field)), pathList, ++field);
 return;
   List<String> newPathList = new ArrayList<>(pathList);
   newPathList.set(field, String.valueOf(i));
   AvroUtils.getFieldHelper(retVal, val, newPathList, field + 1);
   i++;
    .getFieldHelper(retVal, getObjectFromArray((List) data, Integer.parseInt(pathList.get(field))), pathList, ++field);
AvroUtils.getFieldHelper(retVal, ((Record) data).get(pathList.get(field)), pathList, ++field);
return;

代码示例来源：origin: org.apache.gobblin/gobblin-utility

public static Map<String, Object> getMultiFieldValue(GenericRecord record, String fieldLocation) {
 Preconditions.checkNotNull(record);
 Preconditions.checkArgument(!Strings.isNullOrEmpty(fieldLocation));
 Splitter splitter = Splitter.on(FIELD_LOCATION_DELIMITER).omitEmptyStrings().trimResults();
 List<String> pathList = splitter.splitToList(fieldLocation);
 if (pathList.size() == 0) {
  return Collections.emptyMap();
 }
 HashMap<String, Object> retVal = new HashMap<String, Object>();
 AvroUtils.getFieldHelper(retVal, record, pathList, 0);
 return retVal;
}

代码示例来源：origin: org.apache.gobblin/gobblin-utility

/**
 * Given a GenericRecord, this method will return the field specified by the path parameter. The
 * fieldLocation parameter is an ordered string specifying the location of the nested field to retrieve. For example,
 * field1.nestedField1 takes field "field1", and retrieves "nestedField1" from it.
 * @param schema is the record to retrieve the schema from
 * @param fieldLocation is the location of the field
 * @return the field
 */
public static Optional<Field> getField(Schema schema, String fieldLocation) {
 Preconditions.checkNotNull(schema);
 Preconditions.checkArgument(!Strings.isNullOrEmpty(fieldLocation));
 Splitter splitter = Splitter.on(FIELD_LOCATION_DELIMITER).omitEmptyStrings().trimResults();
 List<String> pathList = Lists.newArrayList(splitter.split(fieldLocation));
 if (pathList.size() == 0) {
  return Optional.absent();
 }
 return AvroUtils.getFieldHelper(schema, pathList, 0);
}

代码示例来源：origin: org.apache.gobblin/gobblin-utility

/**
 * Helper method that does the actual work for {@link #getField(Schema, String)}
 * @param schema passed from {@link #getFieldSchema(Schema, String)}
 * @param pathList passed from {@link #getFieldSchema(Schema, String)}
 * @param field keeps track of the index used to access the list pathList
 * @return the field
 */
private static Optional<Field> getFieldHelper(Schema schema, List<String> pathList, int field) {
 Field curField = schema.getField(pathList.get(field));
 if (field + 1 == pathList.size()) {
  return Optional.fromNullable(curField);
 }
 Schema fieldSchema = curField.schema();
 switch (fieldSchema.getType()) {
  case UNION:
   throw new AvroRuntimeException("Union of complex types cannot be handled : " + schema);
  case MAP:
   return AvroUtils.getFieldHelper(fieldSchema.getValueType(), pathList, ++field);
  case RECORD:
   return AvroUtils.getFieldHelper(fieldSchema, pathList, ++field);
  default:
   throw new AvroRuntimeException("Invalid type in schema : " + schema);
 }
}

代码示例来源：origin: org.apache.gobblin/gobblin-utility

AvroUtils.getFieldHelper(retVal, getObjectFromMap((Map) data, pathList.get(field)), pathList, ++field);
 return;
   List<String> newPathList = new ArrayList<>(pathList);
   newPathList.set(field, String.valueOf(i));
   AvroUtils.getFieldHelper(retVal, val, newPathList, field + 1);
   i++;
    .getFieldHelper(retVal, getObjectFromArray((List) data, Integer.parseInt(pathList.get(field))), pathList, ++field);
AvroUtils.getFieldHelper(retVal, ((Record) data).get(pathList.get(field)), pathList, ++field);
return;