Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::HdfsTableSink Member List

This is the complete list of members for impala::HdfsTableSink, including all inherited members.

BuildHdfsFileNames(const HdfsPartitionDescriptor &partition_descriptor, OutputPartition *output)impala::HdfsTableSinkprivate
bytes_written_counter()impala::HdfsTableSinkinline
bytes_written_counter_impala::HdfsTableSinkprivate
Close(RuntimeState *state)impala::HdfsTableSinkvirtual
closed_impala::DataSinkprotected
ClosePartitionFile(RuntimeState *state, OutputPartition *partition)impala::HdfsTableSinkprivate
compress_timer()impala::HdfsTableSinkinline
compress_timer_impala::HdfsTableSinkprivate
CreateDataSink(ObjectPool *pool, const TDataSink &thrift_sink, const std::vector< TExpr > &output_exprs, const TPlanFragmentExecParams &params, const RowDescriptor &row_desc, boost::scoped_ptr< DataSink > *sink)impala::DataSinkstatic
CreateNewTmpFile(RuntimeState *state, OutputPartition *output_partition)impala::HdfsTableSinkprivate
current_row_impala::HdfsTableSinkprivate
DataSink()impala::DataSinkinline
DebugString() const impala::HdfsTableSink
default_partition_impala::HdfsTableSinkprivate
dynamic_partition_key_expr_ctxs_impala::HdfsTableSinkprivate
encode_timer()impala::HdfsTableSinkinline
encode_timer_impala::HdfsTableSinkprivate
expr_mem_tracker_impala::DataSinkprotected
files_created_counter_impala::HdfsTableSinkprivate
FinalizePartitionFile(RuntimeState *state, OutputPartition *partition)impala::HdfsTableSinkprivate
GetFileBlockSize(OutputPartition *output_partition, int64_t *size)impala::HdfsTableSinkstatic
GetHashTblKey(const std::vector< ExprContext * > &ctxs, std::string *key)impala::HdfsTableSinkprivate
GetOutputPartition(RuntimeState *state, const std::string &key, PartitionPair **partition_pair)impala::HdfsTableSinkinlineprivate
has_empty_input_batch_impala::HdfsTableSinkprivate
hdfs_connection_impala::HdfsTableSinkprivate
hdfs_write_timer()impala::HdfsTableSinkinline
hdfs_write_timer_impala::HdfsTableSinkprivate
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::HdfsTableSinkprivate
mem_tracker()impala::HdfsTableSinkinline
mem_tracker_impala::HdfsTableSinkprivate
MergeInsertStats(const TInsertStats &src_stats, TInsertStats *dst_stats)impala::DataSinkstatic
Open(RuntimeState *state)impala::HdfsTableSinkvirtual
output_expr_ctxs_impala::HdfsTableSinkprivate
OutputInsertStats(const PartitionStatusMap &stats, const std::string &prefix="")impala::DataSinkstatic
overwrite_impala::HdfsTableSinkprivate
partition_descriptor_map_impala::HdfsTableSinkprivate
partition_key_expr_ctxs_impala::HdfsTableSinkprivate
partition_key_texprs_impala::HdfsTableSinkprivate
partition_keys_to_output_partitions_impala::HdfsTableSinkprivate
PartitionDescriptorMap typedefimpala::HdfsTableSinkprivate
PartitionMap typedefimpala::HdfsTableSinkprivate
PartitionPair typedefimpala::HdfsTableSinkprivate
partitions_created_counter_impala::HdfsTableSinkprivate
Prepare(RuntimeState *state)impala::HdfsTableSinkvirtual
PrepareExprs(RuntimeState *state)impala::HdfsTableSinkprivate
profile()impala::HdfsTableSinkinlinevirtual
row_desc_impala::HdfsTableSinkprivate
rows_inserted_counter()impala::HdfsTableSinkinline
rows_inserted_counter_impala::HdfsTableSinkprivate
runtime_profile_impala::HdfsTableSinkprivate
select_list_texprs_impala::HdfsTableSinkprivate
Send(RuntimeState *state, RowBatch *batch, bool eos)impala::HdfsTableSinkvirtual
staging_dir_impala::HdfsTableSinkprivate
table_desc_impala::HdfsTableSinkprivate
table_id_impala::HdfsTableSinkprivate
TableDesc()impala::HdfsTableSinkinline
unique_id_str_impala::HdfsTableSinkprivate
~DataSink()impala::DataSinkinlinevirtual