|
Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
This is the complete list of members for impala::HdfsAvroScanner, including all inherited members.
| AddFinalRowBatch() | impala::HdfsScanner | protected |
| AllocateFileHeader() | impala::HdfsAvroScanner | protectedvirtual |
| AttachPool(MemPool *pool, bool commit_batch) | impala::HdfsScanner | inlineprotected |
| AVRO_CODEC_KEY | impala::HdfsAvroScanner | privatestatic |
| AVRO_DEFLATE_CODEC | impala::HdfsAvroScanner | privatestatic |
| avro_header_ | impala::HdfsAvroScanner | private |
| AVRO_NULL_CODEC | impala::HdfsAvroScanner | privatestatic |
| AVRO_SCHEMA_KEY | impala::HdfsAvroScanner | privatestatic |
| AVRO_SNAPPY_CODEC | impala::HdfsAvroScanner | privatestatic |
| AVRO_VERSION_HEADER | impala::HdfsAvroScanner | static |
| BaseSequenceScanner(HdfsScanNode *, RuntimeState *) | impala::BaseSequenceScanner | protected |
| batch_ | impala::HdfsScanner | protected |
| Close() | impala::BaseSequenceScanner | virtual |
| Codegen(HdfsScanNode *, const std::vector< ExprContext * > &conjunct_ctxs) | impala::HdfsAvroScanner | static |
| codegend_decode_avro_data_ | impala::HdfsAvroScanner | private |
| CodegenDecodeAvroData(RuntimeState *state, llvm::Function *materialize_tuple_fn, const std::vector< ExprContext * > &conjunct_ctxs) | impala::HdfsAvroScanner | privatestatic |
| CodegenMaterializeTuple(HdfsScanNode *node, LlvmCodeGen *codegen) | impala::HdfsAvroScanner | privatestatic |
| CodegenWriteAlignedTuples(HdfsScanNode *, LlvmCodeGen *, llvm::Function *write_tuple_fn) | impala::HdfsScanner | protectedstatic |
| CodegenWriteCompleteTuple(HdfsScanNode *, LlvmCodeGen *, const std::vector< ExprContext * > &conjunct_ctxs) | impala::HdfsScanner | protectedstatic |
| CommitRows(int num_rows) | impala::HdfsScanner | protected |
| conjunct_ctxs_ | impala::HdfsScanner | protected |
| context_ | impala::HdfsScanner | protected |
| ConvertSchema(const avro_schema_t &schema) | impala::HdfsAvroScanner | privatestatic |
| data_buffer_pool_ | impala::HdfsScanner | protected |
| DecodeAvroData(int max_tuples, MemPool *pool, uint8_t **data, Tuple *tuple, TupleRow *tuple_row) | impala::HdfsAvroScanner | private |
| DecodeAvroDataFn typedef | impala::HdfsAvroScanner | private |
| 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::HdfsAvroScanner | inlineprotectedvirtual |
| finished() | impala::BaseSequenceScanner | inlineprotected |
| GetConjunctCtx(int idx) const | impala::HdfsScanner | protected |
| GetMemory(MemPool **pool, Tuple **tuple_mem, TupleRow **tuple_row_mem) | impala::HdfsScanner | protected |
| HdfsAvroScanner(HdfsScanNode *scan_node, RuntimeState *state) | impala::HdfsAvroScanner | |
| 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::HdfsAvroScanner | protectedvirtual |
| InitTuple(Tuple *template_tuple, Tuple *tuple) | impala::HdfsScanner | inlineprotected |
| IssueInitialRanges(HdfsScanNode *scan_node, const std::vector< HdfsFileDesc * > &files) | impala::BaseSequenceScanner | static |
| LLVM_CLASS_NAME | impala::HdfsAvroScanner | privatestatic |
| LogRowParseError(int row_idx, std::stringstream *) | impala::HdfsScanner | protectedvirtual |
| MaterializeTuple(MemPool *pool, uint8_t **data, Tuple *tuple) | impala::HdfsAvroScanner | private |
| next_row(TupleRow *r) const | impala::HdfsScanner | inlineprotected |
| next_tuple(Tuple *t) const | impala::HdfsScanner | inlineprotected |
| num_errors_in_file_ | impala::HdfsScanner | protected |
| num_null_bytes_ | impala::HdfsScanner | protected |
| only_parsing_header_ | impala::BaseSequenceScanner | protected |
| parse_status_ | impala::HdfsScanner | protected |
| ParseMetadata() | impala::HdfsAvroScanner | private |
| Prepare(ScannerContext *context) | impala::BaseSequenceScanner | virtual |
| ProcessRange() | impala::HdfsAvroScanner | protectedvirtual |
| ProcessSplit() | impala::BaseSequenceScanner | virtual |
| ReadAvroBoolean(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroChar(PrimitiveType type, int max_len, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroDecimal(int slot_byte_size, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroDouble(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroFloat(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroInt32(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroInt64(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroString(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadAvroVarchar(PrimitiveType type, int max_len, uint8_t **data, bool write_slot, void *slot, MemPool *pool) | impala::HdfsAvroScanner | private |
| ReadFileHeader() | impala::HdfsAvroScanner | protectedvirtual |
| ReadSync() | impala::BaseSequenceScanner | protected |
| ReadUnionType(int null_union_position, uint8_t **data) | impala::HdfsAvroScanner | private |
| ReportColumnParseError(const SlotDescriptor *desc, const char *data, int len) | impala::HdfsScanner | protected |
| ReportTupleParseError(FieldLocation *fields, uint8_t *errors, int row_idx) | impala::HdfsScanner | protected |
| ResolveSchemas(const avro_schema_t &table_root, const avro_schema_t &file_root) | impala::HdfsAvroScanner | private |
| scan_node_ | impala::HdfsScanner | protected |
| 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 |
| VerifyTypesMatch(SlotDescriptor *slot_desc, avro_obj_t *schema) | impala::HdfsAvroScanner | 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 |
| ~HdfsScanner() | impala::HdfsScanner | virtual |