Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
#include <string>
#include <vector>
#include <boost/lexical_cast.hpp>
#include "common/logging.h"
#include "common/compiler-util.h"
#include "gen-cpp/Status_types.h"
#include "gen-cpp/ErrorCodes_types.h"
#include "gen-cpp/TCLIService_types.h"
#include "util/error-util.h"
Go to the source code of this file.
Classes | |
class | impala::Status |
Namespaces | |
impala | |
This file contains type definitions that are used throughout the code base. | |
Macros | |
#define | STATUS_API_VERSION 2 |
#define | RETURN_IF_ERROR(stmt) |
some generally useful macros More... | |
#define | EXIT_IF_ERROR(stmt) |
#define | EXIT_WITH_ERROR(msg) |
#define EXIT_IF_ERROR | ( | stmt | ) |
Definition at line 248 of file status.h.
Referenced by impala::Catalog::Catalog(), impala::Frontend::Frontend(), GenerateBenchmarkExprs(), impala::ImpalaServer::ImpalaServer(), impala::InitCommonRuntime(), main(), Planner::Planner(), impala::RequestPoolService::RequestPoolService(), and TEST().
#define EXIT_WITH_ERROR | ( | msg | ) |
Definition at line 256 of file status.h.
Referenced by impala::InitCommonRuntime().
#define RETURN_IF_ERROR | ( | stmt | ) |
some generally useful macros
Definition at line 242 of file status.h.
Referenced by impala::Sorter::Run::AddBatch(), impala::Sorter::AddBatch(), impala::HdfsScanNode::AddDiskIoRanges(), impala::DataStreamSender::Channel::AddRow(), impala::AnalyticEvalNode::AddRow(), impala::HdfsParquetTableWriter::AddRowGroup(), impala::DiskIoMgr::AddScanRanges(), impala::ThreadGroup::AddThread(), impala::AdmissionController::AdmitQuery(), impala::TmpFileMgr::File::AllocateSpace(), impala::SimpleLogger::AppendEntry(), impala::HBaseTableWriter::AppendRowBatch(), impala::HdfsSequenceTableWriter::AppendRowBatch(), impala::HdfsTextTableWriter::AppendRowBatch(), impala::HdfsParquetTableWriter::AppendRowBatch(), impala::HdfsParquetScanner::AssembleRows(), impala::CgroupsMgr::AssignThreadToCgroup(), impala::PartitionedHashJoinNode::Partition::BuildHashTableInternal(), impala::PartitionedHashJoinNode::BuildHashTables(), CallJniMethod(), impala::JniUtil::CallJniMethod(), impala::FragmentMgr::FragmentExecState::Cancel(), impala::LibCache::CheckSymbolExists(), impala::PartitionedHashJoinNode::CleanUpHashPartitions(), impala::Expr::Clone(), impala::ImpalaServer::CloseInsertInternal(), impala::DataStreamSender::Channel::CloseInternal(), impala::CompoundPredicate::CodegenComputeFn(), impala::HdfsScanner::CommitRows(), impala::SimpleScheduler::ComputeScanRangeAssignment(), impala::CrossJoinNode::ConstructBuildSide(), impala::HashJoinNode::ConstructBuildSide(), impala::PartitionedHashJoinNode::ConstructBuildSide(), impala::HdfsSequenceTableWriter::ConsumeRow(), impala::AggFnEvaluator::Create(), impala::RuntimeState::CreateBlockMgr(), impala::RuntimeState::CreateCodegen(), impala::Expr::CreateExprTrees(), impala::PartitionedAggregationNode::CreateHashPartitions(), impala::CreateImpalaServer(), impala::DataStreamRecvr::CreateMerger(), impala::Sorter::CreateMerger(), impala::ExecNode::CreateNode(), impala::HBaseTableWriter::CreatePut(), impala::HBaseTableWriter::CreatePutList(), impala::Expr::CreateTreeFromThrift(), impala::ExecNode::CreateTreeHelper(), impala::DeserializeThriftMsg(), impala::ClientConnection< T >::DoRpc(), impala::PartitionedHashJoinNode::EvaluateNullProbe(), impala::CatalogOpExecutor::Exec(), impala::ImpalaServer::QueryExecState::Exec(), impala::ChildQuery::ExecAndFetch(), impala::CatalogOpExecutor::ExecComputeStats(), impala::ImpalaServer::QueryExecState::ExecDdlRequest(), impala::ImpalaServer::QueryExecState::ExecLocalCatalogOp(), impala::FragmentMgr::ExecPlanFragment(), impala::ImpalaServer::QueryExecState::ExecQueryOrDmlRequest(), impala::ImpalaServer::ExecuteInternal(), impala::ImpalaServer::FetchInternal(), impala::ImpalaServer::QueryExecState::FetchRowsInternal(), impala::HdfsTextScanner::FillByteBuffer(), impala::HdfsTextScanner::FillByteBufferCompressedFile(), impala::HdfsTextScanner::FillByteBufferGzip(), impala::HdfsParquetTableWriter::Finalize(), impala::HdfsTableSink::FinalizePartitionFile(), impala::BufferedBlockMgr::FindBuffer(), impala::BufferedBlockMgr::FindBufferForBlock(), impala::HdfsTextScanner::FindFirstTuple(), impala::HdfsTextScanner::FinishScanRange(), impala::HdfsTextTableWriter::Flush(), impala::HdfsSequenceTableWriter::Flush(), impala::HdfsAvroTableWriter::Flush(), impala::HdfsParquetTableWriter::BaseColumnWriter::Flush(), impala::HdfsParquetTableWriter::FlushCurrentRowGroup(), Planner::GeneratePlan(), impala::Catalog::GetAllCatalogObjects(), impala::ScannerContext::Stream::GetBuffer(), impala::ScannerContext::Stream::GetBytesInternal(), impala::LibCache::GetCacheEntryInternal(), impala::CatalogOpExecutor::GetCatalogObject(), impala::Catalog::GetCatalogVersion(), impala::ClientCacheHelper::GetClient(), impala::RuntimeState::GetCodegen(), impala::NullLiteral::GetCodegendComputeFn(), impala::CaseExpr::GetCodegendComputeFn(), impala::SlotRef::GetCodegendComputeFn(), impala::Literal::GetCodegendComputeFn(), impala::ScalarFnCall::GetCodegendComputeFn(), impala::Expr::GetCodegendComputeFnWrapper(), impala::HBaseTableScanner::GetCurrentValue(), impala::ScalarFnCall::GetFunction(), impala::JniUtil::GetGlobalClassRef(), impala::LibCache::GetLocalLibPath(), impala::BufferedBlockMgr::GetNewBlock(), impala::SelectNode::GetNext(), impala::SortNode::GetNext(), impala::UnionNode::GetNext(), impala::HBaseScanNode::GetNext(), impala::TopNNode::GetNext(), impala::ExchangeNode::GetNext(), impala::CrossJoinNode::GetNext(), impala::DataSourceScanNode::GetNext(), impala::HashJoinNode::GetNext(), impala::AggregationNode::GetNext(), impala::SortedRunMerger::GetNext(), impala::AnalyticEvalNode::GetNext(), impala::PartitionedHashJoinNode::GetNext(), impala::Sorter::Run::GetNext(), impala::PartitionedAggregationNode::GetNext(), impala::Sorter::GetNext(), impala::HdfsScanNode::GetNext(), impala::Sorter::Run::GetNextBatch(), impala::ScannerContext::Stream::GetNextBuffer(), impala::DataSourceScanNode::GetNextInputBatch(), impala::PlanFragmentExecutor::GetNextInternal(), impala::BufferedTupleStream::GetNextInternal(), impala::HdfsScanNode::GetNextInternal(), impala::ExchangeNode::GetNextMerging(), impala::AnalyticEvalNode::GetNextOutputBatch(), impala::DiskIoMgr::GetNextRange(), impala::RequestPoolService::GetPoolConfig(), impala::HdfsSequenceScanner::GetRecord(), impala::SimpleScheduler::GetRequestPool(), impala::BufferedTupleStream::GetRows(), impala::LibCache::GetSoFunctionPtr(), impala::HBaseTableFactory::GetTable(), impala::ScalarFnCall::GetUdf(), impala::HBaseTableScanner::HandleResultScannerTimeout(), impala::SimpleLogger::Init(), impala::HBaseTable::Init(), impala::SortNode::Init(), impala::UnionNode::Init(), impala::HBaseTableFactory::Init(), impala::ExternalDataSourceExecutor::Init(), impala::AuthManager::Init(), impala::TopNNode::Init(), impala::ExchangeNode::Init(), impala::SortedRunMerger::BatchedRowSupplier::Init(), impala::BlockingJoinNode::Init(), impala::HdfsSequenceTableWriter::Init(), impala::HdfsTextTableWriter::Init(), impala::HashJoinNode::Init(), impala::ResourceBroker::Init(), impala::HBaseTableWriter::Init(), impala::AggregationNode::Init(), impala::ExecNode::Init(), impala::Sorter::Run::Init(), impala::HdfsParquetTableWriter::Init(), impala::PartitionedHashJoinNode::Init(), impala::AnalyticEvalNode::Init(), impala::HdfsAvroTableWriter::Init(), impala::TmpFileMgr::Init(), impala::HBaseTableScanner::Init(), impala::CgroupsMgr::Init(), impala::SimpleScheduler::Init(), impala::PartitionedAggregationNode::Init(), impala::Sorter::Init(), impala::BufferedTupleStream::Init(), impala::LlvmCodeGen::Init(), impala::ImpalaServer::InitAuditEventLogging(), impala::InitAuth(), impala::HdfsParquetScanner::InitColumns(), impala::LibCache::InitInternal(), impala::HBaseTable::InitJNI(), impala::HBaseTableWriter::InitJNI(), impala::SaslAuthProvider::InitKerberos(), impala::SaslAuthProvider::InitKerberosEnv(), impala::ImpalaServer::InitLineageLogging(), impala::JvmMetric::InitMetrics(), impala::HdfsParquetTableWriter::InitNewFile(), impala::HdfsTextScanner::InitNewRange(), impala::HdfsAvroScanner::InitNewRange(), impala::HdfsSequenceScanner::InitNewRange(), impala::HdfsRCFileScanner::InitNewRange(), impala::HdfsTableSink::InitOutputPartition(), impala::ImpalaServer::InitProfileLogging(), impala::HBaseTableScanner::InitScanRange(), impala::PartitionedAggregationNode::Partition::InitStreams(), impala::BufferedBlockMgr::InitTmpFiles(), impala::Sorter::InputDone(), impala::BaseSequenceScanner::IssueInitialRanges(), impala::HdfsTextScanner::IssueInitialRanges(), impala::HdfsParquetScanner::IssueInitialRanges(), impala::HashJoinNode::LeftJoinGetNext(), impala::LlvmCodeGen::LinkModule(), impala::ResourceBroker::LlamaRpc(), impala::LlvmCodeGen::LoadFromFile(), impala::LlvmCodeGen::LoadImpalaIR(), impala::HdfsLzoTextScanner::LoadLzoLibrary(), impala::DataSourceScanNode::MaterializeNextRow(), impala::Sorter::MergeIntermediateRuns(), impala::PartitionedAggregationNode::MoveHashPartitions(), impala::BufferedTupleStream::NewBlockForWrite(), impala::SortedRunMerger::BatchedRowSupplier::Next(), impala::HBaseTableScanner::Next(), impala::BufferedTupleStream::NextBlockForRead(), impala::PartitionedAggregationNode::NextPartition(), impala::PartitionedHashJoinNode::NextProbeRowBatch(), impala::HdfsRCFileScanner::NextRow(), impala::PartitionedHashJoinNode::NextSpilledProbeRowBatch(), impala::SelectNode::Open(), impala::HBaseScanNode::Open(), impala::SortNode::Open(), impala::UnionNode::Open(), impala::TopNNode::Open(), impala::SortExecExprs::Open(), impala::ExchangeNode::Open(), impala::DataSourceScanNode::Open(), impala::CaseExpr::Open(), impala::BlockingJoinNode::Open(), impala::AggregationNode::Open(), impala::ScalarFnCall::Open(), impala::HiveUdfCall::Open(), impala::AnalyticEvalNode::Open(), impala::ExecNode::Open(), impala::PartitionedAggregationNode::Open(), impala::AggFnEvaluator::Open(), impala::HdfsScanNode::Open(), impala::HdfsTableSink::Open(), impala::Expr::Open(), impala::UnionNode::OpenCurrentChild(), impala::PlanFragmentExecutor::OpenInternal(), impala::PartitionedHashJoinNode::OutputNullAwareNullProbe(), impala::PartitionedHashJoinNode::OutputNullAwareProbeRows(), impala::HdfsAvroScanner::ParseMetadata(), impala::BufferedBlockMgr::PinBlock(), impala::BufferedTupleStream::PinStream(), impala::SelectNode::Prepare(), impala::HdfsTextScanner::Prepare(), impala::TupleIsNullPredicate::Prepare(), impala::HBaseScanNode::Prepare(), impala::HBaseTableSink::Prepare(), impala::SortNode::Prepare(), impala::UnionNode::Prepare(), impala::BaseSequenceScanner::Prepare(), impala::SortExecExprs::Prepare(), impala::TopNNode::Prepare(), impala::ExchangeNode::Prepare(), impala::DataSourceScanNode::Prepare(), impala::CrossJoinNode::Prepare(), impala::HdfsParquetScanner::Prepare(), impala::FragmentMgr::FragmentExecState::Prepare(), impala::BlockingJoinNode::Prepare(), impala::CaseExpr::Prepare(), impala::HashJoinNode::Prepare(), impala::SortedRunMerger::Prepare(), impala::AggregationNode::Prepare(), impala::ScalarFnCall::Prepare(), impala::HiveUdfCall::Prepare(), impala::PartitionedHashJoinNode::Prepare(), impala::AnalyticEvalNode::Prepare(), impala::DataStreamSender::Prepare(), impala::ExecNode::Prepare(), impala::ScanNode::Prepare(), impala::PlanFragmentExecutor::Prepare(), impala::AggFnEvaluator::Prepare(), impala::PartitionedAggregationNode::Prepare(), impala::HdfsScanner::Prepare(), impala::HdfsScanNode::Prepare(), impala::HdfsTableSink::Prepare(), impala::HdfsSequenceScanner::Prepare(), impala::HdfsRCFileScanner::Prepare(), impala::Expr::Prepare(), impala::HBaseTableSink::PrepareExprs(), impala::HdfsTableSink::PrepareExprs(), impala::HdfsPartitionDescriptor::PrepareExprs(), impala::BufferedTupleStream::PrepareForRead(), impala::PartitionedHashJoinNode::PrepareNextPartition(), impala::PartitionedHashJoinNode::PrepareNullAwareNullProbe(), impala::PartitionedHashJoinNode::PrepareNullAwarePartition(), impala::Sorter::Run::PrepareRead(), PrepareSelectList(), impala::CatalogOpExecutor::PrioritizeLoad(), impala::PartitionedAggregationNode::ProcessBatch(), impala::GzipCompressor::ProcessBlock(), impala::SnappyBlockDecompressor::ProcessBlock(), impala::Codec::ProcessBlock32(), impala::HdfsSequenceScanner::ProcessBlockCompressedScanRange(), impala::PartitionedHashJoinNode::ProcessBuildInput(), impala::ImpalaServer::ProcessCatalogUpdateResult(), impala::AnalyticEvalNode::ProcessChildBatch(), impala::AnalyticEvalNode::ProcessChildBatches(), impala::HdfsSequenceScanner::ProcessDecompressedBlock(), impala::HdfsParquetScanner::ProcessFooter(), impala::HdfsTextScanner::ProcessRange(), impala::HdfsAvroScanner::ProcessRange(), impala::HdfsSequenceScanner::ProcessRange(), impala::HdfsRCFileScanner::ProcessRange(), impala::HdfsTextScanner::ProcessSplit(), impala::BaseSequenceScanner::ProcessSplit(), impala::HdfsParquetScanner::ProcessSplit(), impala::PartitionedAggregationNode::ProcessStream(), impala::ImpalaServer::QueryToTQueryContext(), impala::DiskIoMgr::Read(), impala::HdfsRCFileScanner::ReadColumnBuffers(), impala::HdfsSequenceScanner::ReadCompressedBlock(), impala::HdfsParquetScanner::BaseColumnReader::ReadDataPage(), impala::HdfsAvroScanner::ReadFileHeader(), impala::HdfsRCFileScanner::ReadFileHeader(), impala::HdfsRCFileScanner::ReadKeyBuffers(), impala::HdfsRCFileScanner::ReadRowGroup(), impala::ResourceBroker::RefreshLlamaNodes(), impala::StatestoreSubscriber::Register(), impala::CgroupsMgr::RegisterFragment(), impala::RegisterMemoryMetrics(), impala::Statestore::RegisterSubscriber(), impala::ResourceBroker::RegisterWithLlama(), impala::ResourceBroker::Release(), impala::SimpleScheduler::Release(), impala::CgroupsMgr::RelocateThreads(), impala::ResourceBroker::ReRegisterWithLlama(), impala::PartitionedHashJoinNode::ReserveTupleStreamBlocks(), impala::ExecNode::Reset(), impala::HdfsParquetScanner::BaseColumnReader::Reset(), impala::HdfsTextScanner::ResetScanner(), impala::HdfsAvroScanner::ResolveSchemas(), impala::HBaseTableScanner::ScanSetup(), impala::SimpleScheduler::Schedule(), impala::HBaseTableSink::Send(), impala::DataStreamSender::Send(), impala::HdfsTableSink::Send(), impala::DataStreamSender::Channel::SendBatch(), impala::DataStreamSender::Channel::SendCurrentBatch(), impala::Statestore::SendHeartbeat(), impala::Statestore::SendTopicUpdate(), impala::CatalogOpExecutor::SentryAdminCheck(), impala::ThriftSerializer::Serialize(), impala::SerializeThriftMsg(), impala::Frontend::SetCatalogInitialized(), impala::ThreadGroup::SetCgroup(), impala::CgroupsMgr::SetCpuShares(), impala::ImpaladQueryExecutor::Setup(), impala::BaseSequenceScanner::SkipToSync(), impala::SortNode::SortInput(), impala::Sorter::SortRun(), impala::PartitionedAggregationNode::Partition::Spill(), impala::PartitionedHashJoinNode::SpillPartition(), impala::PartitionedAggregationNode::SpillPartition(), impala::CatalogServer::Start(), impala::SaslAuthProvider::Start(), impala::InProcessStatestore::Start(), impala::ThriftServer::Start(), impala::StatestoreSubscriber::Start(), impala::InProcessImpalaServer::StartAsBackendOnly(), impala::HBaseTableScanner::StartScan(), impala::ExecEnv::StartServices(), impala::InProcessImpalaServer::StartWithClientServers(), impala::ImpalaServer::TExecuteStatementReqToTQueryContext(), impala::Sorter::Run::TryAddBlock(), impala::Sorter::Run::UnpinAllBlocks(), impala::BufferedTupleStream::UnpinBlock(), impala::BufferedBlockMgr::UnpinBlock(), impala::BufferedTupleStream::UnpinStream(), impala::CgroupsMgr::UnregisterFragment(), impala::ImpalaServer::UnregisterQuery(), impala::ImpalaServer::QueryExecState::UpdateCatalog(), impala::ImpalaServer::UpdateCatalogMetrics(), impala::HdfsScanner::UpdateDecompressor(), impala::StatestoreSubscriber::UpdateState(), impala::ImpalaServer::QueryExecState::UpdateTableAndColumnStats(), impala::Frontend::ValidateSettings(), impala::ImpalaServer::QueryExecState::WaitForChildQueries(), impala::ImpalaServer::QueryExecState::WaitInternal(), impala::ImpalaServer::ScopedSessionState::WithSession(), impala::HdfsSequenceTableWriter::WriteCompressedBlock(), impala::HdfsParquetTableWriter::WriteFileFooter(), impala::HdfsSequenceTableWriter::WriteFileHeader(), impala::HdfsAvroTableWriter::WriteFileHeader(), impala::HdfsParquetTableWriter::WriteFileHeader(), impala::BufferedBlockMgr::WriteUnpinnedBlock(), and impala::BufferedBlockMgr::WriteUnpinnedBlocks().