Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::HdfsAvroScanner Member List

This is the complete list of members for impala::HdfsAvroScanner, including all inherited members.

AddFinalRowBatch()impala::HdfsScannerprotected
AllocateFileHeader()impala::HdfsAvroScannerprotectedvirtual
AttachPool(MemPool *pool, bool commit_batch)impala::HdfsScannerinlineprotected
AVRO_CODEC_KEYimpala::HdfsAvroScannerprivatestatic
AVRO_DEFLATE_CODECimpala::HdfsAvroScannerprivatestatic
avro_header_impala::HdfsAvroScannerprivate
AVRO_NULL_CODECimpala::HdfsAvroScannerprivatestatic
AVRO_SCHEMA_KEYimpala::HdfsAvroScannerprivatestatic
AVRO_SNAPPY_CODECimpala::HdfsAvroScannerprivatestatic
AVRO_VERSION_HEADERimpala::HdfsAvroScannerstatic
BaseSequenceScanner(HdfsScanNode *, RuntimeState *)impala::BaseSequenceScannerprotected
batch_impala::HdfsScannerprotected
Close()impala::BaseSequenceScannervirtual
Codegen(HdfsScanNode *, const std::vector< ExprContext * > &conjunct_ctxs)impala::HdfsAvroScannerstatic
codegend_decode_avro_data_impala::HdfsAvroScannerprivate
CodegenDecodeAvroData(RuntimeState *state, llvm::Function *materialize_tuple_fn, const std::vector< ExprContext * > &conjunct_ctxs)impala::HdfsAvroScannerprivatestatic
CodegenMaterializeTuple(HdfsScanNode *node, LlvmCodeGen *codegen)impala::HdfsAvroScannerprivatestatic
CodegenWriteAlignedTuples(HdfsScanNode *, LlvmCodeGen *, llvm::Function *write_tuple_fn)impala::HdfsScannerprotectedstatic
CodegenWriteCompleteTuple(HdfsScanNode *, LlvmCodeGen *, const std::vector< ExprContext * > &conjunct_ctxs)impala::HdfsScannerprotectedstatic
CommitRows(int num_rows)impala::HdfsScannerprotected
conjunct_ctxs_impala::HdfsScannerprotected
context_impala::HdfsScannerprotected
ConvertSchema(const avro_schema_t &schema)impala::HdfsAvroScannerprivatestatic
data_buffer_pool_impala::HdfsScannerprotected
DecodeAvroData(int max_tuples, MemPool *pool, uint8_t **data, Tuple *tuple, TupleRow *tuple_row)impala::HdfsAvroScannerprivate
DecodeAvroDataFn typedefimpala::HdfsAvroScannerprivate
decompress_timer_impala::HdfsScannerprotected
decompression_type_impala::HdfsScannerprotected
decompressor_impala::HdfsScannerprotected
EvalConjuncts(TupleRow *row)impala::HdfsScannerinlineprotected
FILE_BLOCK_SIZEimpala::HdfsScannerstatic
file_format() const impala::HdfsAvroScannerinlineprotectedvirtual
finished()impala::BaseSequenceScannerinlineprotected
GetConjunctCtx(int idx) const impala::HdfsScannerprotected
GetMemory(MemPool **pool, Tuple **tuple_mem, TupleRow **tuple_row_mem)impala::HdfsScannerprotected
HdfsAvroScanner(HdfsScanNode *scan_node, RuntimeState *state)impala::HdfsAvroScanner
HdfsScanner(HdfsScanNode *scan_node, RuntimeState *state)impala::HdfsScanner
header_impala::BaseSequenceScannerprotected
HEADER_SIZEimpala::BaseSequenceScannerprotectedstatic
InitializeWriteTuplesFn(HdfsPartitionDescriptor *partition, THdfsFileFormat::type type, const std::string &scanner_name)impala::HdfsScannerprotected
InitNewRange()impala::HdfsAvroScannerprotectedvirtual
InitTuple(Tuple *template_tuple, Tuple *tuple)impala::HdfsScannerinlineprotected
IssueInitialRanges(HdfsScanNode *scan_node, const std::vector< HdfsFileDesc * > &files)impala::BaseSequenceScannerstatic
LLVM_CLASS_NAMEimpala::HdfsAvroScannerprivatestatic
LogRowParseError(int row_idx, std::stringstream *)impala::HdfsScannerprotectedvirtual
MaterializeTuple(MemPool *pool, uint8_t **data, Tuple *tuple)impala::HdfsAvroScannerprivate
next_row(TupleRow *r) const impala::HdfsScannerinlineprotected
next_tuple(Tuple *t) const impala::HdfsScannerinlineprotected
num_errors_in_file_impala::HdfsScannerprotected
num_null_bytes_impala::HdfsScannerprotected
only_parsing_header_impala::BaseSequenceScannerprotected
parse_status_impala::HdfsScannerprotected
ParseMetadata()impala::HdfsAvroScannerprivate
Prepare(ScannerContext *context)impala::BaseSequenceScannervirtual
ProcessRange()impala::HdfsAvroScannerprotectedvirtual
ProcessSplit()impala::BaseSequenceScannervirtual
ReadAvroBoolean(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroChar(PrimitiveType type, int max_len, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroDecimal(int slot_byte_size, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroDouble(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroFloat(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroInt32(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroInt64(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroString(PrimitiveType type, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadAvroVarchar(PrimitiveType type, int max_len, uint8_t **data, bool write_slot, void *slot, MemPool *pool)impala::HdfsAvroScannerprivate
ReadFileHeader()impala::HdfsAvroScannerprotectedvirtual
ReadSync()impala::BaseSequenceScannerprotected
ReadUnionType(int null_union_position, uint8_t **data)impala::HdfsAvroScannerprivate
ReportColumnParseError(const SlotDescriptor *desc, const char *data, int len)impala::HdfsScannerprotected
ReportTupleParseError(FieldLocation *fields, uint8_t *errors, int row_idx)impala::HdfsScannerprotected
ResolveSchemas(const avro_schema_t &table_root, const avro_schema_t &file_root)impala::HdfsAvroScannerprivate
scan_node_impala::HdfsScannerprotected
SkipToSync(const uint8_t *sync, int sync_size)impala::BaseSequenceScannerprotected
StartNewRowBatch()impala::HdfsScannerprotected
state_impala::HdfsScannerprotected
stream_impala::HdfsScannerprotected
SYNC_HASH_SIZEimpala::BaseSequenceScannerprotectedstatic
SYNC_MARKERimpala::BaseSequenceScannerprotectedstatic
template_tuple_impala::HdfsScannerprotected
text_converter_impala::HdfsScannerprotected
tuple_impala::HdfsScannerprotected
tuple_byte_size_impala::HdfsScannerprotected
tuple_mem_impala::HdfsScannerprotected
UpdateDecompressor(const THdfsCompression::type &compression)impala::HdfsScannerprotected
UpdateDecompressor(const std::string &codec)impala::HdfsScannerprotected
VerifyTypesMatch(SlotDescriptor *slot_desc, avro_obj_t *schema)impala::HdfsAvroScannerprivate
write_tuples_fn_impala::HdfsScannerprotected
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::HdfsScannerprotected
WriteCompleteTuple(MemPool *pool, FieldLocation *fields, Tuple *tuple, TupleRow *tuple_row, Tuple *template_tuple, uint8_t *error_fields, uint8_t *error_in_row)impala::HdfsScannerprotected
WriteEmptyTuples(RowBatch *row_batch, int num_tuples)impala::HdfsScannerprotected
WriteEmptyTuples(ScannerContext *context, TupleRow *tuple_row, int num_tuples)impala::HdfsScannerprotected
WriteTuplesFn typedefimpala::HdfsScannerprotected
~BaseSequenceScanner()impala::BaseSequenceScannervirtual
~HdfsScanner()impala::HdfsScannervirtual