import org.apache.trevni.avro.HadoopInput; //导入依赖的package包/类
@Override
public  Schema getAvroSchema(Path p, final Job job) throws IOException {

  FileSystem fs = FileSystem.get(p.toUri(), job.getConfiguration());
  FileStatus[] statusArray = fs.globStatus(p, VISIBLE_FILES);

  if (statusArray == null) {
    throw new IOException("Path " + p.toString() + " does not exist.");
  }
  
  if (statusArray.length == 0) {
    throw new IOException("No path matches pattern " + p.toString());
  }

  Path filePath = depthFirstSearchForFile(statusArray, fs);
  
  if (filePath == null) {
    throw new IOException("No path matches pattern " + p.toString());
  }

  AvroColumnReader.Params params =
      new AvroColumnReader.Params(
          new HadoopInput(filePath, job.getConfiguration()));
  AvroColumnReader<GenericData.Record> reader =
      new AvroColumnReader<GenericData.Record>(params);
  Schema s = reader.getFileSchema();
  reader.close();
  return s;
  }
 

import org.apache.trevni.avro.HadoopInput; //导入依赖的package包/类
@Override
public  Schema getAvroSchema(Path p[], final Job job) throws IOException {

  ArrayList<FileStatus> statusList = new ArrayList<FileStatus>();
  FileSystem fs = FileSystem.get(p[0].toUri(), job.getConfiguration());
  for (Path temp : p) {
    for (FileStatus tempf : fs.globStatus(temp, Utils.VISIBLE_FILES)) {
      statusList.add(tempf);
    }
  }
  FileStatus[] statusArray = (FileStatus[]) statusList
      .toArray(new FileStatus[statusList.size()]);

  if (statusArray == null) {
    throw new IOException("Path " + p.toString() + " does not exist.");
  }
  
  if (statusArray.length == 0) {
    throw new IOException("No path matches pattern " + p.toString());
  }

  Path filePath = Utils.depthFirstSearchForFile(statusArray, fs);
  
  if (filePath == null) {
    throw new IOException("No path matches pattern " + p.toString());
  }

  AvroColumnReader.Params params =
      new AvroColumnReader.Params(
          new HadoopInput(filePath, job.getConfiguration()));
  AvroColumnReader<GenericData.Record> reader =
      new AvroColumnReader<GenericData.Record>(params);
  Schema s = reader.getFileSchema();
  reader.close();
  return s;
  }
 

import org.apache.trevni.avro.HadoopInput; //导入依赖的package包/类
public TrevniScanner(Configuration conf, Schema schema, TableMeta meta, FileFragment fragment) throws IOException {
  super(conf, schema, meta, fragment);
  reader = new ColumnFileReader(new HadoopInput(fragment.getPath(), conf));
}