impala-hs2-server.cc File Reference

#include "service/impala-server.h"
#include "service/impala-server.inline.h"
#include <algorithm>
#include <boost/algorithm/string/join.hpp>
#include <boost/date_time/posix_time/posix_time_types.hpp>
#include <boost/unordered_set.hpp>
#include <jni.h>
#include <thrift/protocol/TDebugProtocol.h>
#include <gtest/gtest.h>
#include <boost/foreach.hpp>
#include <boost/bind.hpp>
#include <boost/algorithm/string.hpp>
#include <google/heap-profiler.h>
#include <google/malloc_extension.h>
#include <gutil/strings/substitute.h>
#include "common/logging.h"
#include "common/version.h"
#include "exprs/expr.h"
#include "runtime/raw-value.h"
#include "service/query-exec-state.h"
#include "service/query-options.h"
#include "util/debug-util.h"
#include "rpc/thrift-util.h"
#include "util/impalad-metrics.h"
#include "service/hs2-util.h"
#include "common/names.h"

Include dependency graph for impala-hs2-server.cc:

Go to the source code of this file.

Classes
class	impala::ImpalaServer::HS2ColumnarResultSet
class	impala::ImpalaServer::HS2RowOrientedResultSet

Namespaces
	impala
	This file contains type definitions that are used throughout the code base.

Macros
#define	HS2_RETURN_ERROR(return_val, error_msg, error_state)
#define	HS2_RETURN_IF_ERROR(return_val, status, error_state)

Functions
static int64_t	impala::ByteSize (const thrift::TColumnValue &val)
static int64_t	impala::ByteSize (const thrift::TRow &row)
static uint32_t	impala::TColumnByteSize (const thrift::TColumn &col, uint32_t start_idx, uint32_t end_idx)
static TOperationState::type	impala::QueryStateToTOperationState (const beeswax::QueryState::type &query_state)
TOperationState::type	impala::QueryStateToTOperationState (const QueryState::type &query_state)

Variables
const TProtocolVersion::type	MAX_SUPPORTED_HS2_VERSION
const string	impala::IMPALA_RESULT_CACHING_OPT = "impala.resultset.cache.size"

Macro Definition Documentation

#define HS2_RETURN_ERROR	(		return_val,
			error_msg,
			error_state
	)

Value:

do { \
    return_val.status.__set_statusCode(thrift::TStatusCode::ERROR_STATUS); \
    return_val.status.__set_errorMessage(error_msg); \
    return_val.status.__set_sqlState(error_state); \
    return; \
  } while (false)

Definition at line 58 of file impala-hs2-server.cc.

Referenced by impala::ImpalaServer::CancelOperation(), impala::ImpalaServer::CloseOperation(), impala::ImpalaServer::ExecuteStatement(), impala::ImpalaServer::FetchResults(), impala::ImpalaServer::GetInfo(), impala::ImpalaServer::GetLog(), impala::ImpalaServer::GetOperationStatus(), and impala::ImpalaServer::GetResultSetMetadata().

#define HS2_RETURN_IF_ERROR	(		return_val,
			status,
			error_state
	)

Value:

do { \
    if (UNLIKELY(!status.ok())) { \
      HS2_RETURN_ERROR(return_val, status.GetDetail(), error_state); \
      return; \
    } \
  } while (false)

Definition at line 66 of file impala-hs2-server.cc.

Referenced by impala::ImpalaServer::CancelOperation(), impala::ImpalaServer::CloseOperation(), impala::ImpalaServer::CloseSession(), impala::ImpalaServer::ExecuteStatement(), impala::ImpalaServer::FetchResults(), impala::ImpalaServer::GetExecSummary(), impala::ImpalaServer::GetInfo(), impala::ImpalaServer::GetLog(), impala::ImpalaServer::GetOperationStatus(), impala::ImpalaServer::GetResultSetMetadata(), impala::ImpalaServer::GetRuntimeProfile(), and impala::ImpalaServer::OpenSession().

Variable Documentation

const TProtocolVersion::type MAX_SUPPORTED_HS2_VERSION

Initial value:

=
    TProtocolVersion::HIVE_CLI_SERVICE_PROTOCOL_V6

Definition at line 54 of file impala-hs2-server.cc.

Referenced by impala::ImpalaServer::OpenSession().