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

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

AddFinalRowBatch()impala::HdfsScannerprotected
AttachPool(MemPool *pool, bool commit_batch)impala::HdfsScannerinlineprotected
batch_impala::HdfsScannerprotected
batch_start_ptr_impala::HdfsTextScannerprivate
boundary_column_impala::HdfsTextScannerprivate
boundary_pool_impala::HdfsTextScannerprivate
boundary_row_impala::HdfsTextScannerprivate
byte_buffer_end_impala::HdfsTextScannerprotected
byte_buffer_ptr_impala::HdfsTextScannerprotected
byte_buffer_read_size_impala::HdfsTextScannerprotected
Close()impala::HdfsTextScannervirtual
Codegen(HdfsScanNode *, const std::vector< ExprContext * > &conjunct_ctxs)impala::HdfsTextScannerstatic
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
CopyBoundaryField(FieldLocation *data, MemPool *pool)impala::HdfsTextScannerprivate
data_buffer_pool_impala::HdfsScannerprotected
decompress_timer_impala::HdfsScannerprotected
decompression_type_impala::HdfsScannerprotected
decompressor_impala::HdfsScannerprotected
delimited_text_parser_impala::HdfsTextScannerprivate
error_in_row_impala::HdfsTextScannerprivate
EvalConjuncts(TupleRow *row)impala::HdfsScannerinlineprotected
field_locations_impala::HdfsTextScannerprivate
FILE_BLOCK_SIZEimpala::HdfsScannerstatic
FillByteBuffer(bool *eosr, int num_bytes=0)impala::HdfsTextScannerprivatevirtual
FillByteBufferCompressedFile(bool *eosr)impala::HdfsTextScannerprivate
FillByteBufferGzip(bool *eosr)impala::HdfsTextScannerprivate
FindFirstTuple(bool *tuple_found)impala::HdfsTextScannerprivate
FinishScanRange()impala::HdfsTextScannerprivate
GetConjunctCtx(int idx) const impala::HdfsScannerprotected
GetMemory(MemPool **pool, Tuple **tuple_mem, TupleRow **tuple_row_mem)impala::HdfsScannerprotected
HdfsScanner(HdfsScanNode *scan_node, RuntimeState *state)impala::HdfsScanner
HdfsTextScanner(HdfsScanNode *scan_node, RuntimeState *state)impala::HdfsTextScanner
InitializeWriteTuplesFn(HdfsPartitionDescriptor *partition, THdfsFileFormat::type type, const std::string &scanner_name)impala::HdfsScannerprotected
InitNewRange()impala::HdfsTextScannerprivatevirtual
InitTuple(Tuple *template_tuple, Tuple *tuple)impala::HdfsScannerinlineprotected
IssueInitialRanges(HdfsScanNode *scan_node, const std::vector< HdfsFileDesc * > &files)impala::HdfsTextScannerstatic
LLVM_CLASS_NAMEimpala::HdfsTextScannerstatic
LogRowParseError(int row_idx, std::stringstream *)impala::HdfsTextScannerprivatevirtual
LZO_INDEX_SUFFIXimpala::HdfsTextScannerstatic
NEXT_BLOCK_READ_SIZEimpala::HdfsTextScannerprivatestatic
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::HdfsTextScannerprotected
parse_delimiter_timer_impala::HdfsTextScannerprivate
parse_status_impala::HdfsScannerprotected
partial_tuple_impala::HdfsTextScannerprivate
partial_tuple_empty_impala::HdfsTextScannerprivate
Prepare(ScannerContext *context)impala::HdfsTextScannervirtual
ProcessRange(int *num_tuples, bool past_scan_range)impala::HdfsTextScannerprivate
ProcessSplit()impala::HdfsTextScannervirtual
ReportColumnParseError(const SlotDescriptor *desc, const char *data, int len)impala::HdfsScannerprotected
ReportTupleParseError(FieldLocation *fields, uint8_t *errors, int row_idx)impala::HdfsScannerprotected
ResetScanner()impala::HdfsTextScannerprotected
row_end_locations_impala::HdfsTextScannerprivate
scan_node_impala::HdfsScannerprotected
slot_idx_impala::HdfsTextScannerprivate
StartNewRowBatch()impala::HdfsScannerprotected
state_impala::HdfsScannerprotected
stream_impala::HdfsScannerprotected
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
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
WriteFields(MemPool *, TupleRow *tuple_row_mem, int num_fields, int num_tuples)impala::HdfsTextScannerprivate
WritePartialTuple(FieldLocation *, int num_fields, bool copy_strings)impala::HdfsTextScannerprivate
WriteTuplesFn typedefimpala::HdfsScannerprotected
~HdfsScanner()impala::HdfsScannervirtual
~HdfsTextScanner()impala::HdfsTextScannervirtual