AppendRowBatch(RowBatch *rows, const std::vector< int32_t > &row_group_indices, bool *new_file) | impala::HdfsSequenceTableWriter | virtual |
approx_block_size_ | impala::HdfsSequenceTableWriter | private |
Close() | impala::HdfsSequenceTableWriter | inlinevirtual |
codec_name_ | impala::HdfsSequenceTableWriter | private |
compress_flag_ | impala::HdfsSequenceTableWriter | private |
compressor_ | impala::HdfsSequenceTableWriter | private |
ConsumeRow(TupleRow *row) | impala::HdfsSequenceTableWriter | inlineprivate |
default_block_size() const | impala::HdfsSequenceTableWriter | inlinevirtual |
EncodeRow(TupleRow *row, WriteStream *buf) | impala::HdfsSequenceTableWriter | inlineprivate |
escape_char_ | impala::HdfsSequenceTableWriter | private |
field_delim_ | impala::HdfsSequenceTableWriter | private |
file_extension() const | impala::HdfsSequenceTableWriter | inlinevirtual |
Finalize() | impala::HdfsSequenceTableWriter | inlinevirtual |
Flush() | impala::HdfsSequenceTableWriter | private |
HDFS_FLUSH_WRITE_SIZE | impala::HdfsTableWriter | protectedstatic |
HdfsSequenceTableWriter(HdfsTableSink *parent, RuntimeState *state, OutputPartition *output, const HdfsPartitionDescriptor *partition, const HdfsTableDescriptor *table_desc, const std::vector< ExprContext * > &output_exprs) | impala::HdfsSequenceTableWriter | |
HdfsTableWriter(HdfsTableSink *parent, RuntimeState *state, OutputPartition *output_partition, const HdfsPartitionDescriptor *partition_desc, const HdfsTableDescriptor *table_desc, const std::vector< ExprContext * > &output_expr_ctxs) | impala::HdfsTableWriter | |
Init() | impala::HdfsSequenceTableWriter | virtual |
InitNewFile() | impala::HdfsSequenceTableWriter | inlinevirtual |
mem_pool_ | impala::HdfsSequenceTableWriter | private |
neg1_sync_marker_ | impala::HdfsSequenceTableWriter | private |
out_ | impala::HdfsSequenceTableWriter | private |
output_ | impala::HdfsTableWriter | protected |
output_expr_ctxs_ | impala::HdfsTableWriter | protected |
parent_ | impala::HdfsTableWriter | protected |
record_compression_ | impala::HdfsSequenceTableWriter | private |
row_buf_ | impala::HdfsSequenceTableWriter | private |
SEQ6_CODE | impala::HdfsSequenceTableWriter | privatestatic |
state_ | impala::HdfsTableWriter | protected |
stats() | impala::HdfsTableWriter | inline |
stats_ | impala::HdfsTableWriter | protected |
sync_marker_ | impala::HdfsSequenceTableWriter | private |
table_desc_ | impala::HdfsTableWriter | protected |
unflushed_rows_ | impala::HdfsSequenceTableWriter | private |
VALUE_CLASS_NAME | impala::HdfsSequenceTableWriter | privatestatic |
Write(const char *data, int32_t len) | impala::HdfsTableWriter | inlineprotected |
Write(const uint8_t *data, int32_t len) | impala::HdfsTableWriter | protected |
Write(T v) | impala::HdfsTableWriter | inlineprotected |
WriteCompressedBlock() | impala::HdfsSequenceTableWriter | private |
WriteEscapedString(const StringValue *str_val, WriteStream *buf) | impala::HdfsSequenceTableWriter | inlineprivate |
WriteFileHeader() | impala::HdfsSequenceTableWriter | private |
~HdfsSequenceTableWriter() | impala::HdfsSequenceTableWriter | inline |
~HdfsTableWriter() | impala::HdfsTableWriter | inlinevirtual |