AddFinalRowBatch() | impala::HdfsScanner | protected |
AllocateFileHeader() | impala::HdfsRCFileScanner | privatevirtual |
AttachPool(MemPool *pool, bool commit_batch) | impala::HdfsScanner | inlineprotected |
BaseSequenceScanner(HdfsScanNode *, RuntimeState *) | impala::BaseSequenceScanner | protected |
batch_ | impala::HdfsScanner | protected |
Close() | impala::BaseSequenceScanner | virtual |
CodegenWriteAlignedTuples(HdfsScanNode *, LlvmCodeGen *, llvm::Function *write_tuple_fn) | impala::HdfsScanner | protectedstatic |
CodegenWriteCompleteTuple(HdfsScanNode *, LlvmCodeGen *, const std::vector< ExprContext * > &conjunct_ctxs) | impala::HdfsScanner | protectedstatic |
columns_ | impala::HdfsRCFileScanner | private |
CommitRows(int num_rows) | impala::HdfsScanner | protected |
compressed_key_length_ | impala::HdfsRCFileScanner | private |
conjunct_ctxs_ | impala::HdfsScanner | protected |
context_ | impala::HdfsScanner | protected |
data_buffer_pool_ | impala::HdfsScanner | protected |
DebugString(int indentation_level, std::stringstream *out) const | impala::HdfsRCFileScanner | |
decompress_timer_ | impala::HdfsScanner | protected |
decompression_type_ | impala::HdfsScanner | protected |
decompressor_ | impala::HdfsScanner | protected |
EvalConjuncts(TupleRow *row) | impala::HdfsScanner | inlineprotected |
FILE_BLOCK_SIZE | impala::HdfsScanner | static |
file_format() const | impala::HdfsRCFileScanner | inlineprivatevirtual |
finished() | impala::BaseSequenceScanner | inlineprotected |
GetConjunctCtx(int idx) const | impala::HdfsScanner | protected |
GetCurrentKeyBuffer(int col_idx, bool skip_col_data, uint8_t **key_buf_ptr) | impala::HdfsRCFileScanner | private |
GetMemory(MemPool **pool, Tuple **tuple_mem, TupleRow **tuple_row_mem) | impala::HdfsScanner | protected |
HdfsRCFileScanner(HdfsScanNode *scan_node, RuntimeState *state) | impala::HdfsRCFileScanner | |
HdfsScanner(HdfsScanNode *scan_node, RuntimeState *state) | impala::HdfsScanner | |
header_ | impala::BaseSequenceScanner | protected |
HEADER_SIZE | impala::BaseSequenceScanner | protectedstatic |
InitializeWriteTuplesFn(HdfsPartitionDescriptor *partition, THdfsFileFormat::type type, const std::string &scanner_name) | impala::HdfsScanner | protected |
InitNewRange() | impala::HdfsRCFileScanner | privatevirtual |
InitTuple(Tuple *template_tuple, Tuple *tuple) | impala::HdfsScanner | inlineprotected |
IssueInitialRanges(HdfsScanNode *scan_node, const std::vector< HdfsFileDesc * > &files) | impala::BaseSequenceScanner | static |
key_buffer_ | impala::HdfsRCFileScanner | private |
key_length_ | impala::HdfsRCFileScanner | private |
LLVM_CLASS_NAME | impala::HdfsScanner | static |
LogRowParseError(int row_idx, std::stringstream *) | impala::HdfsScanner | protectedvirtual |
next_row(TupleRow *r) const | impala::HdfsScanner | inlineprotected |
next_tuple(Tuple *t) const | impala::HdfsScanner | inlineprotected |
NextField(int col_idx) | impala::HdfsRCFileScanner | inlineprivate |
NextRow() | impala::HdfsRCFileScanner | inlineprivate |
num_errors_in_file_ | impala::HdfsScanner | protected |
num_null_bytes_ | impala::HdfsScanner | protected |
num_rows_ | impala::HdfsRCFileScanner | private |
only_parsing_header_ | impala::BaseSequenceScanner | protected |
parse_status_ | impala::HdfsScanner | protected |
Prepare(ScannerContext *context) | impala::HdfsRCFileScanner | virtual |
ProcessRange() | impala::HdfsRCFileScanner | privatevirtual |
ProcessSplit() | impala::BaseSequenceScanner | virtual |
RCF1 enum value | impala::HdfsRCFileScanner | private |
RCFILE_KEY_CLASS_NAME | impala::HdfsRCFileScanner | privatestatic |
RCFILE_METADATA_KEY_NUM_COLS | impala::HdfsRCFileScanner | privatestatic |
RCFILE_VALUE_CLASS_NAME | impala::HdfsRCFileScanner | privatestatic |
RCFILE_VERSION_HEADER | impala::HdfsRCFileScanner | privatestatic |
ReadColumnBuffers() | impala::HdfsRCFileScanner | private |
ReadFileHeader() | impala::HdfsRCFileScanner | privatevirtual |
ReadKeyBuffers() | impala::HdfsRCFileScanner | private |
ReadNumColumnsMetadata() | impala::HdfsRCFileScanner | private |
ReadRowGroup() | impala::HdfsRCFileScanner | private |
ReadRowGroupHeader() | impala::HdfsRCFileScanner | private |
ReadSync() | impala::BaseSequenceScanner | protected |
ReportColumnParseError(const SlotDescriptor *desc, const char *data, int len) | impala::HdfsScanner | protected |
ReportTupleParseError(FieldLocation *fields, uint8_t *errors, int row_idx) | impala::HdfsScanner | protected |
ResetRowGroup() | impala::HdfsRCFileScanner | private |
reuse_row_group_buffer_ | impala::HdfsRCFileScanner | private |
row_group_buffer_ | impala::HdfsRCFileScanner | private |
row_group_buffer_size_ | impala::HdfsRCFileScanner | private |
row_group_length_ | impala::HdfsRCFileScanner | private |
row_pos_ | impala::HdfsRCFileScanner | private |
scan_node_ | impala::HdfsScanner | protected |
SEQ6 enum value | impala::HdfsRCFileScanner | private |
SkipToSync(const uint8_t *sync, int sync_size) | impala::BaseSequenceScanner | protected |
StartNewRowBatch() | impala::HdfsScanner | protected |
state_ | impala::HdfsScanner | protected |
stream_ | impala::HdfsScanner | protected |
SYNC_HASH_SIZE | impala::BaseSequenceScanner | protectedstatic |
SYNC_MARKER | impala::BaseSequenceScanner | protectedstatic |
template_tuple_ | impala::HdfsScanner | protected |
text_converter_ | impala::HdfsScanner | protected |
tuple_ | impala::HdfsScanner | protected |
tuple_byte_size_ | impala::HdfsScanner | protected |
tuple_mem_ | impala::HdfsScanner | protected |
UpdateDecompressor(const THdfsCompression::type &compression) | impala::HdfsScanner | protected |
UpdateDecompressor(const std::string &codec) | impala::HdfsScanner | protected |
Version enum name | impala::HdfsRCFileScanner | private |
write_tuples_fn_ | impala::HdfsScanner | protected |
WriteAlignedTuples(MemPool *pool, TupleRow *tuple_row_mem, int row_size, FieldLocation *fields, int num_tuples, int max_added_tuples, int slots_per_tuple, int row_start_indx) | impala::HdfsScanner | protected |
WriteCompleteTuple(MemPool *pool, FieldLocation *fields, Tuple *tuple, TupleRow *tuple_row, Tuple *template_tuple, uint8_t *error_fields, uint8_t *error_in_row) | impala::HdfsScanner | protected |
WriteEmptyTuples(RowBatch *row_batch, int num_tuples) | impala::HdfsScanner | protected |
WriteEmptyTuples(ScannerContext *context, TupleRow *tuple_row, int num_tuples) | impala::HdfsScanner | protected |
WriteTuplesFn typedef | impala::HdfsScanner | protected |
~BaseSequenceScanner() | impala::BaseSequenceScanner | virtual |
~HdfsRCFileScanner() | impala::HdfsRCFileScanner | virtual |
~HdfsScanner() | impala::HdfsScanner | virtual |