import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
public FilteringGroupConverter(
    GroupConverter delegate,
    List<Integer> indexFieldPath,
    Map<ColumnPath, List<ValueInspector>> valueInspectorsByColumn, Map<List<Integer>,
    PrimitiveColumnIO> columnIOsByIndexFieldPath) {

  this.delegate = checkNotNull(delegate, "delegate");
  this.indexFieldPath = checkNotNull(indexFieldPath, "indexFieldPath");
  this.columnIOsByIndexFieldPath = checkNotNull(columnIOsByIndexFieldPath, "columnIOsByIndexFieldPath");
  this.valueInspectorsByColumn = checkNotNull(valueInspectorsByColumn, "valueInspectorsByColumn");
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
private State(int id, PrimitiveColumnIO primitiveColumnIO, ColumnReader column, int[] nextLevel, GroupConverter[] groupConverterPath, PrimitiveConverter primitiveConverter) {
  this.id = id;
  this.primitiveColumnIO = primitiveColumnIO;
  this.maxDefinitionLevel = primitiveColumnIO.getDefinitionLevel();
  this.maxRepetitionLevel = primitiveColumnIO.getRepetitionLevel();
  this.column = column;
  this.nextLevel = nextLevel;
  this.groupConverterPath = groupConverterPath;
  this.primitiveConverter = primitiveConverter;
  this.primitive = primitiveColumnIO.getType().asPrimitiveType().getPrimitiveTypeName();
  this.fieldPath = primitiveColumnIO.getFieldPath();
  this.primitiveField = fieldPath[fieldPath.length - 1];
  this.indexFieldPath = primitiveColumnIO.getIndexFieldPath();
  this.primitiveFieldIndex = indexFieldPath[indexFieldPath.length - 1];
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
public GroupFieldhandler(GroupConverter delegate, final ThriftField field, List<TProtocol> events) {
  this.delegate = delegate;
  this.events = events;
  this.readFieldBegin = new ParquetProtocol("readFieldBegin()") {
    @Override
    public TField readFieldBegin() throws TException {
      return new TField(field.getName(), field.getType().getType().getThriftType(), field.getFieldId());
    }
  };
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override
public GroupConverter getRootConverter() {
  return root;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override
public GroupConverter getRootConverter()
{
    return root;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override
public GroupConverter getRootConverter() {
    return this.root;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override
public GroupConverter getRootConverter() {
  return _converter;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override
public GroupConverter getRootConverter() {
  return rootConverter;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
public ConverterConsumer(GroupConverter recordConsumer, MessageType schema) {
  this.root = recordConsumer;
  this.schema = schema;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
public GroupCounter(GroupConverter delegate) {
  this.delegate = delegate;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
/**
 * Returns the root converter.
 *
 * @return The root converter
 */
@Override
public GroupConverter getRootConverter() {
  return root;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
/**
 *
 * {@inheritDoc}
 * @see org.apache.parquet.io.api.RecordMaterializer#getRootConverter()
 */
@Override
public GroupConverter getRootConverter() {
  return structConverter;
}
 

import org.apache.parquet.io.api.GroupConverter; //导入依赖的package包/类
@Override public GroupConverter asGroupConverter() { return new DumpGroupConverter(); }