AddRowGroup() | impala::HdfsParquetTableWriter | private |
AppendRowBatch(RowBatch *batch, const std::vector< int32_t > &row_group_indices, bool *new_file) | impala::HdfsParquetTableWriter | virtual |
BaseColumnWriter class | impala::HdfsParquetTableWriter | friend |
BoolColumnWriter class | impala::HdfsParquetTableWriter | friend |
Close() | impala::HdfsParquetTableWriter | virtual |
columns_ | impala::HdfsParquetTableWriter | private |
ColumnWriter class | impala::HdfsParquetTableWriter | friend |
compression_staging_buffer_ | impala::HdfsParquetTableWriter | private |
CreateSchema() | impala::HdfsParquetTableWriter | private |
current_row_group_ | impala::HdfsParquetTableWriter | private |
default_block_size() const | impala::HdfsParquetTableWriter | virtual |
DEFAULT_DATA_PAGE_SIZE | impala::HdfsParquetTableWriter | privatestatic |
file_extension() const | impala::HdfsParquetTableWriter | inlinevirtual |
file_metadata_ | impala::HdfsParquetTableWriter | private |
file_pos_ | impala::HdfsParquetTableWriter | private |
file_size_estimate_ | impala::HdfsParquetTableWriter | private |
file_size_limit_ | impala::HdfsParquetTableWriter | private |
Finalize() | impala::HdfsParquetTableWriter | virtual |
FlushCurrentRowGroup() | impala::HdfsParquetTableWriter | private |
HDFS_BLOCK_ALIGNMENT | impala::HdfsParquetTableWriter | privatestatic |
HDFS_BLOCK_SIZE | impala::HdfsParquetTableWriter | privatestatic |
HDFS_FLUSH_WRITE_SIZE | impala::HdfsTableWriter | protectedstatic |
HDFS_MIN_FILE_SIZE | impala::HdfsParquetTableWriter | privatestatic |
HdfsParquetTableWriter(HdfsTableSink *parent, RuntimeState *state, OutputPartition *output_partition, const HdfsPartitionDescriptor *part_desc, const HdfsTableDescriptor *table_desc, const std::vector< ExprContext * > &output_expr_ctxs) | impala::HdfsParquetTableWriter | |
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::HdfsParquetTableWriter | virtual |
InitNewFile() | impala::HdfsParquetTableWriter | virtual |
MAX_DATA_PAGE_SIZE | impala::HdfsParquetTableWriter | privatestatic |
MinBlockSize() const | impala::HdfsParquetTableWriter | private |
output_ | impala::HdfsTableWriter | protected |
output_expr_ctxs_ | impala::HdfsTableWriter | protected |
parent_ | impala::HdfsTableWriter | protected |
parquet_stats_ | impala::HdfsParquetTableWriter | private |
per_file_mem_pool_ | impala::HdfsParquetTableWriter | private |
reusable_col_mem_pool_ | impala::HdfsParquetTableWriter | private |
row_count_ | impala::HdfsParquetTableWriter | private |
ROW_GROUP_SIZE | impala::HdfsParquetTableWriter | privatestatic |
row_idx_ | impala::HdfsParquetTableWriter | private |
state_ | impala::HdfsTableWriter | protected |
stats() | impala::HdfsTableWriter | inline |
stats_ | impala::HdfsTableWriter | protected |
table_desc_ | impala::HdfsTableWriter | protected |
thrift_serializer_ | impala::HdfsParquetTableWriter | 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 |
WriteFileFooter() | impala::HdfsParquetTableWriter | private |
WriteFileHeader() | impala::HdfsParquetTableWriter | private |
~HdfsParquetTableWriter() | impala::HdfsParquetTableWriter | |
~HdfsTableWriter() | impala::HdfsTableWriter | inlinevirtual |