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 |