AppendField(const ColumnType &type, const void *value) | impala::HdfsAvroTableWriter | inlineprivate |
AppendRowBatch(RowBatch *rows, const std::vector< int32_t > &row_group_indices, bool *new_file) | impala::HdfsAvroTableWriter | virtual |
Close() | impala::HdfsAvroTableWriter | inlinevirtual |
codec_name_ | impala::HdfsAvroTableWriter | private |
codec_type_ | impala::HdfsAvroTableWriter | private |
compressor_ | impala::HdfsAvroTableWriter | private |
ConsumeRow(TupleRow *row) | impala::HdfsAvroTableWriter | private |
default_block_size() const | impala::HdfsAvroTableWriter | inlinevirtual |
file_extension() const | impala::HdfsAvroTableWriter | inlinevirtual |
Finalize() | impala::HdfsAvroTableWriter | inlinevirtual |
Flush() | impala::HdfsAvroTableWriter | private |
HDFS_FLUSH_WRITE_SIZE | impala::HdfsTableWriter | protectedstatic |
HdfsAvroTableWriter(HdfsTableSink *parent, RuntimeState *state, OutputPartition *output, const HdfsPartitionDescriptor *partition, const HdfsTableDescriptor *table_desc, const std::vector< ExprContext * > &output_exprs) | impala::HdfsAvroTableWriter | |
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::HdfsAvroTableWriter | virtual |
InitNewFile() | impala::HdfsAvroTableWriter | inlinevirtual |
mem_pool_ | impala::HdfsAvroTableWriter | private |
out_ | impala::HdfsAvroTableWriter | private |
output_ | impala::HdfsTableWriter | protected |
output_expr_ctxs_ | impala::HdfsTableWriter | protected |
parent_ | impala::HdfsTableWriter | protected |
state_ | impala::HdfsTableWriter | protected |
stats() | impala::HdfsTableWriter | inline |
stats_ | impala::HdfsTableWriter | protected |
sync_marker_ | impala::HdfsAvroTableWriter | private |
table_desc_ | impala::HdfsTableWriter | protected |
unflushed_rows_ | impala::HdfsAvroTableWriter | private |
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 |
WriteFileHeader() | impala::HdfsAvroTableWriter | private |
~HdfsAvroTableWriter() | impala::HdfsAvroTableWriter | inlinevirtual |
~HdfsTableWriter() | impala::HdfsTableWriter | inlinevirtual |