A C G I N O S W
All Classes All Packages

A

AbstractOrcNoHiveVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.

C

create(FSDataOutputStream) - Method in class org.apache.flink.orc.nohive.OrcNoHiveBulkWriterFactory

createBatchWrapper(TypeDescription, int) - Method in class org.apache.flink.orc.nohive.shim.OrcNoHiveShim

createFlinkVector(ColumnVector) - Static method in class org.apache.flink.orc.nohive.vector.AbstractOrcNoHiveVector

createFlinkVectorFromConstant(LogicalType, Object, int) - Static method in class org.apache.flink.orc.nohive.vector.AbstractOrcNoHiveVector

Create flink vector by hive vector from constant.

createPartitionedFormat(Configuration, RowType, List<String>, PartitionFieldExtractor<SplitT>, int[], List<OrcFilters.Predicate>, int, Function<RowType, TypeInformation<RowData>>) - Static method in class org.apache.flink.orc.nohive.OrcNoHiveColumnarRowInputFormat

Create a partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.

createRecordReader(Configuration, TypeDescription, int[], List<OrcFilters.Predicate>, Path, long, long) - Method in class org.apache.flink.orc.nohive.shim.OrcNoHiveShim

G

genPartColumnarRowReader(Configuration, String[], DataType[], Map<String, Object>, int[], List<OrcFilters.Predicate>, int, Path, long, long) - Static method in class org.apache.flink.orc.nohive.OrcNoHiveSplitReaderUtil

Util for generating partitioned OrcColumnarRowSplitReader.

getBatch() - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveBatchWrapper

getBoolean(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

getByte(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

getBytes(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveBytesVector

getDecimal(int, int, int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveDecimalVector

getDouble(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveDoubleVector

getFloat(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveDoubleVector

getInt(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

getLong(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

getShort(int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

getTimestamp(int, int) - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveTimestampVector

I

isNullAt(int) - Method in class org.apache.flink.orc.nohive.vector.AbstractOrcNoHiveVector

N

nextBatch(RecordReader, VectorizedRowBatch) - Method in class org.apache.flink.orc.nohive.shim.OrcNoHiveShim

NoHivePhysicalWriterImpl - Class in org.apache.flink.orc.nohive.writer

Protobuf is relocated in orc-core-nohive, therefore method calls involving PB classes need to use the relocated class names here.

NoHivePhysicalWriterImpl(FSDataOutputStream, OrcFile.WriterOptions) - Constructor for class org.apache.flink.orc.nohive.writer.NoHivePhysicalWriterImpl

O

OrcNoHiveBatchWrapper - Class in org.apache.flink.orc.nohive.vector

Wrap VectorizedRowBatch orc batch.

OrcNoHiveBatchWrapper(VectorizedRowBatch) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveBatchWrapper

OrcNoHiveBulkWriterFactory - Class in org.apache.flink.orc.nohive

A BulkWriter.Factory from orc no-hive version.

OrcNoHiveBulkWriterFactory(Configuration, String, LogicalType[]) - Constructor for class org.apache.flink.orc.nohive.OrcNoHiveBulkWriterFactory

OrcNoHiveBytesVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's BytesColumnVector to Flink's BytesColumnVector.

OrcNoHiveBytesVector(BytesColumnVector) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveBytesVector

OrcNoHiveColumnarRowInputFormat - Class in org.apache.flink.orc.nohive

Helper class to create OrcColumnarRowInputFormat for no-hive.

OrcNoHiveDecimalVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's DecimalColumnVector to Flink's DecimalColumnVector.

OrcNoHiveDecimalVector(DecimalColumnVector) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveDecimalVector

OrcNoHiveDoubleVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's DoubleColumnVector to Flink's float and double ColumnVector.

OrcNoHiveDoubleVector(DoubleColumnVector) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveDoubleVector

OrcNoHiveLongVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's LongColumnVector to Flink's boolean, byte, short, int and long ColumnVector.

OrcNoHiveLongVector(LongColumnVector) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveLongVector

OrcNoHiveShim - Class in org.apache.flink.orc.nohive.shim

Shim for orc reader without hive dependents.

OrcNoHiveShim() - Constructor for class org.apache.flink.orc.nohive.shim.OrcNoHiveShim

OrcNoHiveSplitReaderUtil - Class in org.apache.flink.orc.nohive

Util for generating OrcSplitReader.

OrcNoHiveSplitReaderUtil() - Constructor for class org.apache.flink.orc.nohive.OrcNoHiveSplitReaderUtil

OrcNoHiveTimestampVector - Class in org.apache.flink.orc.nohive.vector

This column vector is used to adapt hive's TimestampColumnVector to Flink's TimestampColumnVector.

OrcNoHiveTimestampVector(TimestampColumnVector) - Constructor for class org.apache.flink.orc.nohive.vector.OrcNoHiveTimestampVector

org.apache.flink.orc.nohive - package org.apache.flink.orc.nohive

org.apache.flink.orc.nohive.shim - package org.apache.flink.orc.nohive.shim

org.apache.flink.orc.nohive.vector - package org.apache.flink.orc.nohive.vector

org.apache.flink.orc.nohive.writer - package org.apache.flink.orc.nohive.writer

S

size() - Method in class org.apache.flink.orc.nohive.vector.OrcNoHiveBatchWrapper

W

writeFileFooter(OrcProto.Footer) - Method in class org.apache.flink.orc.nohive.writer.NoHivePhysicalWriterImpl

writeMetadata(OrcProto.Metadata) - Method in class org.apache.flink.orc.nohive.writer.NoHivePhysicalWriterImpl

writeStripeFooter(OrcProto.StripeFooter) - Method in class org.apache.flink.orc.nohive.writer.NoHivePhysicalWriterImpl

A C G I N O S W
All Classes All Packages