0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018 package org.apache.spark.sql.execution.datasources.parquet;
0019
0020 import org.apache.spark.sql.execution.vectorized.WritableColumnVector;
0021
0022 import org.apache.parquet.io.api.Binary;
0023
0024
0025
0026
0027
0028 public interface VectorizedValuesReader {
0029 boolean readBoolean();
0030 byte readByte();
0031 int readInteger();
0032 long readLong();
0033 float readFloat();
0034 double readDouble();
0035 Binary readBinary(int len);
0036
0037
0038
0039
0040 void readBooleans(int total, WritableColumnVector c, int rowId);
0041 void readBytes(int total, WritableColumnVector c, int rowId);
0042 void readIntegers(int total, WritableColumnVector c, int rowId);
0043 void readIntegersWithRebase(int total, WritableColumnVector c, int rowId, boolean failIfRebase);
0044 void readLongs(int total, WritableColumnVector c, int rowId);
0045 void readLongsWithRebase(int total, WritableColumnVector c, int rowId, boolean failIfRebase);
0046 void readFloats(int total, WritableColumnVector c, int rowId);
0047 void readDoubles(int total, WritableColumnVector c, int rowId);
0048 void readBinary(int total, WritableColumnVector c, int rowId);
0049 }