Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
#include <glog/logging.h>
#include <gflags/gflags.h>
Go to the source code of this file.
Namespaces | |
impala | |
This file contains type definitions that are used throughout the code base. | |
Macros | |
#define | VLOG_CONNECTION VLOG(1) |
#define | VLOG_RPC VLOG(2) |
#define | VLOG_QUERY VLOG(1) |
#define | VLOG_FILE VLOG(2) |
#define | VLOG_ROW VLOG(3) |
#define | VLOG_PROGRESS VLOG(2) |
#define | VLOG_CONNECTION_IS_ON VLOG_IS_ON(1) |
#define | VLOG_RPC_IS_ON VLOG_IS_ON(2) |
#define | VLOG_QUERY_IS_ON VLOG_IS_ON(1) |
#define | VLOG_FILE_IS_ON VLOG_IS_ON(2) |
#define | VLOG_ROW_IS_ON VLOG_IS_ON(3) |
#define | VLOG_PROGRESS_IS_ON VLOG_IS_ON(2) |
Functions | |
void | impala::InitGoogleLoggingSafe (const char *arg) |
void | impala::GetFullLogFilename (google::LogSeverity severity, std::string *filename) |
void | impala::ShutdownLogging () |
void | impala::LogCommandLineFlags () |
Writes all command-line flags to the log at level INFO. More... | |
void | impala::CheckAndRotateLogFiles (int max_log_files) |
#define VLOG_CONNECTION VLOG(1) |
This is a wrapper around the glog header. When we are compiling to IR, we don't want to pull in the glog headers. Pulling them in causes linking issues when we try to dynamically link the codegen'd functions. GLOG defines this based on the system but doesn't check if it's already been defined. undef it first to avoid warnings. glog MUST be included before gflags. Instead of including them, our files should include this file instead. Define verbose logging levels. Per-row logging is more verbase than per-file / per-rpc logging which is more verbose than per-connection / per-query logging.
Definition at line 55 of file logging.h.
Referenced by main().
#define VLOG_CONNECTION_IS_ON VLOG_IS_ON(1) |
Definition at line 62 of file logging.h.
Referenced by impala::SaslGetOption().
#define VLOG_FILE VLOG(2) |
Definition at line 58 of file logging.h.
Referenced by impala::AnalyticEvalNode::AddRow(), impala::AnalyticEvalNode::AnalyticEvalNode(), impala::BaseSequenceScanner::Close(), impala::DiskIoMgr::ScanRange::Close(), impala::HdfsTableSink::ClosePartitionFile(), impala::DataStreamMgr::CloseSender(), impala::HdfsParquetScanner::CreateColumnReaders(), impala::HdfsTableSink::CreateNewTmpFile(), impala::DataStreamMgr::CreateRecvr(), impala::DataStreamRecvr::SenderQueue::DecrementSenders(), impala::HdfsOp::Execute(), impala::HdfsTextScanner::FillByteBufferCompressedFile(), impala::HdfsTextScanner::FillByteBufferGzip(), impala::ExchangeNode::FillInputRowBatch(), impala::SimpleScheduler::GetBackend(), impala::AnalyticEvalNode::GetNext(), impala::PlanFragmentExecutor::GetNext(), impala::ScannerContext::Stream::GetNextBuffer(), impala::AnalyticEvalNode::GetNextOutputBatch(), impala::DiskIoMgr::GetNextRequestRange(), impala::HdfsSequenceScanner::GetRecord(), impala::HdfsParquetTableWriter::Init(), impala::AnalyticEvalNode::InitNextPartition(), impala::AggregationNode::Open(), impala::AnalyticEvalNode::Open(), impala::DiskIoMgr::ScanRange::Open(), impala::HdfsAvroScanner::ParseMetadata(), impala::PlanFragmentExecutor::PrintVolumeIds(), impala::AnalyticEvalNode::ProcessChildBatch(), impala::HdfsAvroScanner::ProcessRange(), impala::HdfsRCFileScanner::ReadColumnBuffers(), impala::HdfsSequenceScanner::ReadCompressedBlock(), impala::HdfsParquetScanner::BaseColumnReader::ReadDataPage(), impala::HdfsSequenceScanner::ReadFileHeader(), impala::HdfsRCFileScanner::ReadFileHeader(), impala::HdfsRCFileScanner::ReadKeyBuffers(), impala::ImpalaServer::ReportExecStatus(), impala::PlanFragmentExecutor::ReportProfile(), and impala::BaseSequenceScanner::SkipToSync().
#define VLOG_FILE_IS_ON VLOG_IS_ON(2) |
Definition at line 65 of file logging.h.
Referenced by impala::SimpleScheduler::GetBackend(), and impala::PlanFragmentExecutor::ReportProfile().
#define VLOG_QUERY VLOG(1) |
Definition at line 57 of file logging.h.
Referenced by impala::QueryResourceMgr::AcquireVcoreResources(), impala::AdmissionController::AdmitQuery(), impala::ResourceBroker::AMNotification(), impala::DataStreamRecvr::SenderQueue::Cancel(), impala::ChildQuery::Cancel(), impala::DataStreamMgr::Cancel(), impala::PlanFragmentExecutor::Cancel(), impala::ImpalaServer::CancelFromThreadPool(), impala::ImpalaServer::CancelInternal(), impala::ImpalaServer::CancelOperation(), impala::FragmentMgr::CancelPlanFragment(), impala::ResourceBroker::ClearRequests(), impala::HiveUdfCall::Close(), impala::ImpalaServer::close(), impala::ImpalaServer::CloseInsert(), impala::ImpalaServer::CloseOperation(), impala::ImpalaServer::CloseSession(), impala::HashTableCtx::CodegenEquals(), impala::ExecNode::CodegenEvalConjuncts(), impala::HashTableCtx::CodegenEvalRow(), impala::AggregationNode::CodegenUpdateSlot(), impala::PartitionedAggregationNode::CodegenUpdateSlot(), impala::AggregationNode::CodegenUpdateTuple(), impala::PartitionedAggregationNode::CodegenUpdateTuple(), impala::BufferedBlockMgr::ConsumeMemory(), impala::HdfsParquetScanner::CreateColumnReaders(), impala::DataStreamMgr::DeregisterRecvr(), impala::Statestore::DoSubscriberUpdate(), impala::ChildQuery::ExecAndFetch(), impala::FragmentMgr::ExecPlanFragment(), impala::ImpalaServer::executeAndWait(), impala::ImpalaServer::ExecuteInternal(), impala::ImpalaServer::ExecuteStatement(), impala::ResourceBroker::Expand(), impala::ImpalaServer::ExpireQueries(), impala::ImpalaServer::explain(), impala::BufferedBlockMgr::FindBufferForBlock(), impala::Statestore::GatherTopicUpdates(), impala::ImpalaServer::get_results_metadata(), impala::ImpalaServer::get_state(), impala::ImpalaServer::GetCatalogs(), impala::ImpalaServer::GetColumns(), impala::ImpalaServer::GetFunctions(), impala::ImpalaServer::GetInfo(), impala::PlanFragmentExecutor::GetNext(), impala::DataSourceScanNode::GetNextInputBatch(), impala::MemTracker::GetQueryMemTracker(), impala::ResourceBroker::PendingRequest::GetResources(), impala::ImpalaServer::GetResultSetMetadata(), impala::ImpalaServer::GetSchemas(), impala::ImpalaServer::GetTables(), impala::ImpalaServer::GetTableTypes(), impala::ImpalaServer::GetTypeInfo(), impala::CatalogOpExecutor::HandleDropDataSource(), impala::CatalogOpExecutor::HandleDropFunction(), impala::AdmissionController::HandleTopicUpdates(), impala::DataStreamTest::JoinReceivers(), impala::DataStreamTest::JoinSenders(), impala::RuntimeState::LogError(), impala::BufferedBlockMgr::MemLimitTooLowError(), impala::PlanFragmentExecutor::Open(), impala::ImpalaServer::OpenSession(), impala::ParsePoolTopicKey(), impala::BufferedTupleStream::PinStream(), impala::PlanFragmentExecutor::Prepare(), impala::HdfsTableSink::Prepare(), impala::ImpalaServer::ProcessCatalogUpdateResult(), impala::ImpalaServer::query(), impala::ImpalaServer::QueryToTQueryContext(), impala::DataStreamTest::ReadStream(), impala::DataStreamTest::ReadStreamMerging(), impala::ResourceBroker::Release(), impala::ImpalaServer::ReportExecStatus(), impala::ResourceBroker::Reserve(), impala::SaslLdapCheckPass(), impala::HdfsScanNode::ScannerThread(), impala::DataStreamTest::Sender(), impala::ImpalaServer::QueryExecState::SetCreateTableAsSelectResultSet(), impala::ImpalaServer::SetQueryInflight(), impala::DataStreamTest::StartReceiver(), impala::DataStreamTest::StartSender(), impala::DataStreamTest::StopBackend(), impala::DataStreamTest::TestStream(), impala::ImpalaServer::TExecuteStatementReqToTQueryContext(), impala::ThriftOutputFunction(), impala::ImpalaServer::UnregisterQuery(), impala::ImpalaServer::QueryExecState::UpdateCatalog(), impala::WaitForServer(), and impala::BufferedBlockMgr::WriteComplete().
#define VLOG_QUERY_IS_ON VLOG_IS_ON(1) |
Definition at line 64 of file logging.h.
Referenced by impala::BufferedBlockMgr::FindBufferForBlock(), and impala::HdfsScanNode::ScannerThread().
#define VLOG_ROW VLOG(3) |
Definition at line 59 of file logging.h.
Referenced by impala::DataStreamRecvr::SenderQueue::AddBatch(), impala::DataStreamMgr::AddData(), impala::AdmissionController::AddPoolUpdates(), impala::AnalyticEvalNode::AddResultTuple(), impala::AnalyticEvalNode::AddRow(), impala_udf::FunctionContext::Allocate(), impala::FunctionContextImpl::AllocateLocal(), impala::CgroupsMgr::AssignThreadToCgroup(), impala::CrossJoinNode::ConstructBuildSide(), impala::HashJoinNode::ConstructBuildSide(), impala::AdmissionController::DequeueLoop(), impala::DistinceEstimateFinalize(), impala::ImpalaServer::fetch(), impala::ImpalaServer::FetchResults(), impala::DataStreamMgr::FindRecvr(), impala_udf::FunctionContext::Free(), impala::FunctionContextImpl::FreeLocalAllocations(), impala::ImpalaServer::get_state(), impala::DataStreamRecvr::SenderQueue::GetBatch(), impala::HashJoinNode::GetNext(), impala::AggregationNode::GetNext(), impala::AnalyticEvalNode::GetNextOutputBatch(), impala::ImpalaServer::GetOperationStatus(), impala::AdmissionController::HandleTopicDeletions(), impala::AdmissionController::HandleTopicUpdates(), impala::AnalyticEvalNode::InitNextPartition(), impala::AggregationNode::Open(), impala::PartitionedAggregationNode::Open(), impala::PlanFragmentExecutor::OpenInternal(), impala::TimestampParser::Parse(), impala::HdfsAvroScanner::ParseMetadata(), impala::AggregateFunctions::PcMerge(), impala::GzipDecompressor::ProcessBlockStreaming(), impala_udf::FunctionContext::Reallocate(), impala::CgroupsMgr::RelocateThreads(), impala::DataStreamSender::Channel::SendBatch(), impala::RowBatch::Serialize(), impala::DataStreamSender::SerializeBatch(), impala::ImpalaServer::TransmitData(), impala::DataStreamSender::Channel::TransmitDataHelper(), impala::AnalyticEvalNode::TryAddRemainingResults(), impala::AnalyticEvalNode::TryAddResultTupleForCurrRow(), impala::AnalyticEvalNode::TryAddResultTupleForPrevRow(), impala::AnalyticEvalNode::TryRemoveRowsBeforeWindow(), impala::AdmissionController::UpdateClusterAggregates(), and impala::AdmissionController::UpdatePoolStats().
#define VLOG_ROW_IS_ON VLOG_IS_ON(3) |
Definition at line 66 of file logging.h.
Referenced by impala::FunctionContextImpl::FreeLocalAllocations(), impala::InitCommonRuntime(), impala::AggregationNode::Open(), impala::PartitionedAggregationNode::Open(), impala::PlanFragmentExecutor::OpenInternal(), and impala::SaslGetOption().
#define VLOG_RPC VLOG(2) |
Definition at line 56 of file logging.h.
Referenced by impala::AdmissionController::AdmitQuery(), impala::ResourceBroker::AMNotification(), impala::DataStreamSender::Channel::CloseInternal(), impala::SimpleScheduler::ComputeFragmentExecParams(), impala::AdmissionController::DequeueLoop(), CatalogServiceThriftIf::ExecDdl(), impala::ResourceBroker::Expand(), CatalogServiceThriftIf::GetCatalogObject(), impala::RpcEventHandler::getContext(), impala::ImpalaServer::GetExecSummary(), CatalogServiceThriftIf::GetFunctions(), impala::SaslAuthProvider::GetServerTransportFactory(), impala::StatestoreSubscriber::Heartbeat(), impala::ResourceBroker::LlamaRpc(), impala::ImpalaServer::PingImpalaService(), impala::RpcEventHandler::postWrite(), CatalogServiceThriftIf::PrioritizeLoad(), impala::AdmissionController::ReleaseQuery(), impala::ResourceBroker::Reserve(), CatalogServiceThriftIf::ResetMetadata(), CatalogServiceThriftIf::SentryAdminCheck(), CatalogServiceThriftIf::UpdateCatalog(), and impala::SaslAuthProvider::WrapClientTransport().