import parquet.column.ColumnReader; //导入依赖的package包/类
public RecordFilter bind(Iterable<ColumnReader> readers) {

		return ColumnRecordFilter.column(
			"ORDERDATE",
			ColumnPredicates.applyFunctionToString(new BeforeDate())
		).bind(readers);
	}
 

import parquet.column.ColumnReader; //导入依赖的package包/类
public RecordFilter bind(Iterable<ColumnReader> readers) {

		return ColumnRecordFilter.column(
			"SHIPDATE",
			ColumnPredicates.applyFunctionToString(new AfterDate())
		).bind(readers);
	}
 

import parquet.column.ColumnReader; //导入依赖的package包/类
public static void dump(PrettyPrintWriter out, ColumnReadStoreImpl crstore, ColumnDescriptor column, long page, long total, long offset) throws IOException {
    int dmax = column.getMaxDefinitionLevel();
    ColumnReader creader = crstore.getColumnReader(column);
    out.format("*** row group %d of %d, values %d to %d ***%n", page, total, offset, offset + creader.getTotalValueCount() - 1);

    for (long i = 0, e = creader.getTotalValueCount(); i < e; ++i) {
        int rlvl = creader.getCurrentDefinitionLevel();
        int dlvl = creader.getCurrentDefinitionLevel();

        out.format("value %d: R:%d D:%d V:", offset+i, rlvl, dlvl);
        if (dlvl == dmax) {
            switch (column.getType()) {
            case BINARY:  out.format("%s", binaryToString(creader.getBinary())); break;
            case BOOLEAN: out.format("%s", creader.getBoolean()); break;
            case DOUBLE:  out.format("%s", creader.getDouble()); break;
            case FLOAT:   out.format("%s", creader.getFloat()); break;
            case INT32:   out.format("%s", creader.getInteger()); break;
            case INT64:   out.format("%s", creader.getLong()); break;
            case INT96:   out.format("%s", binaryToBigInteger(creader.getBinary())); break;
            case FIXED_LEN_BYTE_ARRAY: out.format("%s", binaryToString(creader.getBinary())); break;
            }
        } else {
            out.format("<null>");
        }

        out.println();
        creader.consume();
    }
}
 

import parquet.column.ColumnReader; //导入依赖的package包/类
@Override
public RecordFilter bind(Iterable<ColumnReader> readers) {
  return filter.bind(readers);
}
 

import parquet.column.ColumnReader; //导入依赖的package包/类
public RecordFilter bind(Iterable<ColumnReader> readers) {
    return null;
}