Interface | Description |
---|---|
AsyncPbRpcProxy.ExecuteRequestCallback<T extends com.google.protobuf.Message> | |
ConsumerFeedback<T> |
Consumer feedback typically used by Consumer
|
Class | Description |
---|---|
AsyncPbRpcProxy<ProtocolType,TokenType extends org.apache.hadoop.security.token.TokenIdentifier> | |
AsyncPbRpcProxy.CallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message> | |
AsyncPbRpcProxy.NodeCallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message> | |
AsyncPbRpcProxy.RequestManager | |
ChannelOutputStream |
OutputStream to write to the Netty Channel
|
DaemonId | |
DebugUtils |
A class that contains debug methods; also allows enabling the logging of various
trace messages with low runtime cost, in order to investigate reproducible bugs.
|
FieldDesc | |
LlapArrowBatchRecordReader | |
LlapArrowRecordWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> |
Writes Arrow batches to an
ArrowStreamWriter . |
LlapArrowRowInputFormat | |
LlapArrowRowRecordReader |
Buffers a batch for reading one row at a time.
|
LlapBaseInputFormat<V extends org.apache.hadoop.io.WritableComparable<?>> |
Base LLAP input format to handle requesting of splits and communication with LLAP daemon.
|
LlapBaseRecordReader<V extends org.apache.hadoop.io.WritableComparable> |
Base LLAP RecordReader to handle receiving of the data from the LLAP daemon.
|
LlapBaseRecordReader.ReaderEvent |
Define success/error events which are passed to the reader from a different thread.
|
LlapCacheAwareFs |
This is currently only used by Parquet; however, a generally applicable approach is used -
you pass in a set of offset pairs for a file, and the file is cached with these boundaries.
|
LlapDump |
Utility to test query and data retrieval via the LLAP input format.
|
LlapInputSplit | |
LlapNodeId | |
LlapOutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> | |
LlapOutputFormatService |
Responsible for sending back result set data to the connections
made by external clients via the LLAP input format.
|
LlapRecordWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.WritableComparable> | |
LlapRowInputFormat | |
LlapRowRecordReader |
Row-based record reader for LLAP.
|
LlapStorageHandler | |
LlapUtil | |
LlapUtil.StatisticsData | |
NotTezEventHelper |
See NotTezEvent class/.proto comment.
|
Row | |
Schema | |
SubmitWorkInfo | |
WritableByteChannelAdapter |
Provides an adapter between
WritableByteChannel
and ChannelHandlerContext . |
Enum | Description |
---|---|
LlapBaseRecordReader.ReaderEvent.EventType | |
LlapDaemonInfo |
Copyright © 2022 The Apache Software Foundation. All rights reserved.