org.apache.hadoop.hive.llap.io.decode

Class GenericColumnVectorProducer

java.lang.Object

org.apache.hadoop.hive.llap.io.decode.GenericColumnVectorProducer

All Implemented Interfaces:

ColumnVectorProducer

public class GenericColumnVectorProducer
extends Object
implements ColumnVectorProducer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GenericColumnVectorProducer.SerDeStripeMetadata

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.llap.io.decode.ColumnVectorProducer

ColumnVectorProducer.Includes, ColumnVectorProducer.SchemaEvolutionFactory

Constructor Summary

Constructors

Constructor and Description
GenericColumnVectorProducer(SerDeLowLevelCacheImpl serdeCache, BufferUsageManager bufferManager, org.apache.hadoop.conf.Configuration conf, LlapDaemonCacheMetrics cacheMetrics, LlapDaemonIOMetrics ioMetrics, FixedSizedObjectPool<IoTrace> tracePool)

Method Summary

Modifier and Type

Method and Description

ReadPipeline

createReadPipeline(Consumer<ColumnVectorBatch> consumer, org.apache.hadoop.mapred.FileSplit split, ColumnVectorProducer.Includes includes, org.apache.hadoop.hive.ql.io.sarg.SearchArgument sarg, QueryFragmentCounters counters, ColumnVectorProducer.SchemaEvolutionFactory sef, org.apache.hadoop.mapred.InputFormat<?,?> sourceInputFormat, Deserializer sourceSerDe, org.apache.hadoop.mapred.Reporter reporter, org.apache.hadoop.mapred.JobConf job, Map<org.apache.hadoop.fs.Path,PartitionDesc> parts)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericColumnVectorProducer

public GenericColumnVectorProducer(SerDeLowLevelCacheImpl serdeCache,
                                   BufferUsageManager bufferManager,
                                   org.apache.hadoop.conf.Configuration conf,
                                   LlapDaemonCacheMetrics cacheMetrics,
                                   LlapDaemonIOMetrics ioMetrics,
                                   FixedSizedObjectPool<IoTrace> tracePool)

Method Detail

createReadPipeline

public ReadPipeline createReadPipeline(Consumer<ColumnVectorBatch> consumer,
                                       org.apache.hadoop.mapred.FileSplit split,
                                       ColumnVectorProducer.Includes includes,
                                       org.apache.hadoop.hive.ql.io.sarg.SearchArgument sarg,
                                       QueryFragmentCounters counters,
                                       ColumnVectorProducer.SchemaEvolutionFactory sef,
                                       org.apache.hadoop.mapred.InputFormat<?,?> sourceInputFormat,
                                       Deserializer sourceSerDe,
                                       org.apache.hadoop.mapred.Reporter reporter,
                                       org.apache.hadoop.mapred.JobConf job,
                                       Map<org.apache.hadoop.fs.Path,PartitionDesc> parts)
                                throws IOException

Specified by:

createReadPipeline in interface ColumnVectorProducer

Throws:

IOException