| BuildHdfsFileNames(const HdfsPartitionDescriptor &partition_descriptor, OutputPartition *output) | impala::HdfsTableSink | private |
| bytes_written_counter() | impala::HdfsTableSink | inline |
| bytes_written_counter_ | impala::HdfsTableSink | private |
| Close(RuntimeState *state) | impala::HdfsTableSink | virtual |
| closed_ | impala::DataSink | protected |
| ClosePartitionFile(RuntimeState *state, OutputPartition *partition) | impala::HdfsTableSink | private |
| compress_timer() | impala::HdfsTableSink | inline |
| compress_timer_ | impala::HdfsTableSink | private |
| CreateDataSink(ObjectPool *pool, const TDataSink &thrift_sink, const std::vector< TExpr > &output_exprs, const TPlanFragmentExecParams ¶ms, const RowDescriptor &row_desc, boost::scoped_ptr< DataSink > *sink) | impala::DataSink | static |
| CreateNewTmpFile(RuntimeState *state, OutputPartition *output_partition) | impala::HdfsTableSink | private |
| current_row_ | impala::HdfsTableSink | private |
| DataSink() | impala::DataSink | inline |
| DebugString() const | impala::HdfsTableSink | |
| default_partition_ | impala::HdfsTableSink | private |
| dynamic_partition_key_expr_ctxs_ | impala::HdfsTableSink | private |
| encode_timer() | impala::HdfsTableSink | inline |
| encode_timer_ | impala::HdfsTableSink | private |
| expr_mem_tracker_ | impala::DataSink | protected |
| files_created_counter_ | impala::HdfsTableSink | private |
| FinalizePartitionFile(RuntimeState *state, OutputPartition *partition) | impala::HdfsTableSink | private |
| GetFileBlockSize(OutputPartition *output_partition, int64_t *size) | impala::HdfsTableSink | static |
| GetHashTblKey(const std::vector< ExprContext * > &ctxs, std::string *key) | impala::HdfsTableSink | private |
| GetOutputPartition(RuntimeState *state, const std::string &key, PartitionPair **partition_pair) | impala::HdfsTableSink | inlineprivate |
| has_empty_input_batch_ | impala::HdfsTableSink | private |
| hdfs_connection_ | impala::HdfsTableSink | private |
| hdfs_write_timer() | impala::HdfsTableSink | inline |
| hdfs_write_timer_ | impala::HdfsTableSink | private |
| HdfsTableSink(const RowDescriptor &row_desc, const std::vector< TExpr > &select_list_texprs, const TDataSink &tsink) | impala::HdfsTableSink | |
| InitOutputPartition(RuntimeState *state, const HdfsPartitionDescriptor &partition_descriptor, OutputPartition *output_partition) | impala::HdfsTableSink | private |
| mem_tracker() | impala::HdfsTableSink | inline |
| mem_tracker_ | impala::HdfsTableSink | private |
| MergeInsertStats(const TInsertStats &src_stats, TInsertStats *dst_stats) | impala::DataSink | static |
| Open(RuntimeState *state) | impala::HdfsTableSink | virtual |
| output_expr_ctxs_ | impala::HdfsTableSink | private |
| OutputInsertStats(const PartitionStatusMap &stats, const std::string &prefix="") | impala::DataSink | static |
| overwrite_ | impala::HdfsTableSink | private |
| partition_descriptor_map_ | impala::HdfsTableSink | private |
| partition_key_expr_ctxs_ | impala::HdfsTableSink | private |
| partition_key_texprs_ | impala::HdfsTableSink | private |
| partition_keys_to_output_partitions_ | impala::HdfsTableSink | private |
| PartitionDescriptorMap typedef | impala::HdfsTableSink | private |
| PartitionMap typedef | impala::HdfsTableSink | private |
| PartitionPair typedef | impala::HdfsTableSink | private |
| partitions_created_counter_ | impala::HdfsTableSink | private |
| Prepare(RuntimeState *state) | impala::HdfsTableSink | virtual |
| PrepareExprs(RuntimeState *state) | impala::HdfsTableSink | private |
| profile() | impala::HdfsTableSink | inlinevirtual |
| row_desc_ | impala::HdfsTableSink | private |
| rows_inserted_counter() | impala::HdfsTableSink | inline |
| rows_inserted_counter_ | impala::HdfsTableSink | private |
| runtime_profile_ | impala::HdfsTableSink | private |
| select_list_texprs_ | impala::HdfsTableSink | private |
| Send(RuntimeState *state, RowBatch *batch, bool eos) | impala::HdfsTableSink | virtual |
| staging_dir_ | impala::HdfsTableSink | private |
| table_desc_ | impala::HdfsTableSink | private |
| table_id_ | impala::HdfsTableSink | private |
| TableDesc() | impala::HdfsTableSink | inline |
| unique_id_str_ | impala::HdfsTableSink | private |
| ~DataSink() | impala::DataSink | inlinevirtual |