Module: Impala::Protocol

Defined in:

lib/impala/protocol.rb,
lib/impala/protocol/data_types.rb,
lib/impala/protocol/exprs_types.rb,
lib/impala/protocol/fb303_types.rb,
lib/impala/protocol/types_types.rb,
lib/impala/protocol/status_types.rb,
lib/impala/protocol/beeswax_types.rb,
lib/impala/protocol/opcodes_types.rb,
lib/impala/protocol/planner_types.rb,
lib/impala/protocol/data_constants.rb,
lib/impala/protocol/frontend_types.rb,
lib/impala/protocol/impala_service.rb,
lib/impala/protocol/beeswax_service.rb,
lib/impala/protocol/exprs_constants.rb,
lib/impala/protocol/fb303_constants.rb,
lib/impala/protocol/types_constants.rb,
lib/impala/protocol/data_sinks_types.rb,
lib/impala/protocol/facebook_service.rb,
lib/impala/protocol/partitions_types.rb,
lib/impala/protocol/plan_nodes_types.rb,
lib/impala/protocol/status_constants.rb,
lib/impala/protocol/beeswax_constants.rb,
lib/impala/protocol/descriptors_types.rb,
lib/impala/protocol/opcodes_constants.rb,
lib/impala/protocol/planner_constants.rb,
lib/impala/protocol/frontend_constants.rb,
lib/impala/protocol/impala_plan_service.rb,
lib/impala/protocol/state_store_service.rb,
lib/impala/protocol/data_sinks_constants.rb,
lib/impala/protocol/hive_metastore_types.rb,
lib/impala/protocol/impala_service_types.rb,
lib/impala/protocol/java_constants_types.rb,
lib/impala/protocol/partitions_constants.rb,
lib/impala/protocol/plan_nodes_constants.rb,
lib/impala/protocol/descriptors_constants.rb,
lib/impala/protocol/runtime_profile_types.rb,
lib/impala/protocol/thrift_hive_metastore.rb,
lib/impala/protocol/statestore_types_types.rb,
lib/impala/protocol/impala_internal_service.rb,
lib/impala/protocol/hive_metastore_constants.rb,
lib/impala/protocol/impala_service_constants.rb,
lib/impala/protocol/java_constants_constants.rb,
lib/impala/protocol/impala_plan_service_types.rb,
lib/impala/protocol/runtime_profile_constants.rb,
lib/impala/protocol/state_store_service_types.rb,
lib/impala/protocol/statestore_types_constants.rb,
lib/impala/protocol/impala_internal_service_types.rb,
lib/impala/protocol/impala_plan_service_constants.rb,
lib/impala/protocol/state_store_service_constants.rb,
lib/impala/protocol/state_store_subscriber_service.rb,
lib/impala/protocol/impala_internal_service_constants.rb,
lib/impala/protocol/state_store_subscriber_service_types.rb,
lib/impala/protocol/state_store_subscriber_service_constants.rb

Overview

Taken as a whole, this module contains all the thrift-generated stuff that defines the Impala protocol.

Defined Under Namespace

Modules: Beeswax, Fb303, HiveMetastore, ImpalaInternalService, ImpalaInternalServiceVersion, ImpalaPlanService, ImpalaService, StateStoreService, StateStoreServiceVersion, StateStoreSubscriberService, StateStoreSubscriberServiceVersion, TAggregationOp, TCounterType, TDataSinkType, TDdlType, TExplainLevel, TExprNodeType, TExprOpcode, THdfsCompression, THdfsFileFormat, TImpalaQueryOptions, TJoinOp, TPartitionType, TPlanNodeType, TPrimitiveType, TStatusCode, TStmtType, TTableType Classes: TAggregateExpr, TAggregationNode, TBoolLiteral, TCancelPlanFragmentParams, TCancelPlanFragmentResult, TCaseExpr, TCatalogUpdate, TClientRequest, TColumnDesc, TColumnValue, TCounter, TDataPartition, TDataSink, TDataStreamSink, TDateLiteral, TDdlExecRequest, TDescribeTableParams, TDescribeTableResult, TDescriptorTable, TEqJoinCondition, TExecPlanFragmentParams, TExecPlanFragmentResult, TExecRequest, TExpr, TExprNode, TFinalizeParams, TFloatLiteral, TGetDbsParams, TGetDbsResult, TGetTablesParams, TGetTablesResult, THBaseFilter, THBaseKeyRange, THBaseScanNode, THBaseTable, THashJoinNode, THdfsFileSplit, THdfsPartition, THdfsScanNode, THdfsTable, THdfsTableSink, THostPort, TImpalaPlanServiceException, TInPredicate, TInsertExecStatus, TInsertResult, TIntLiteral, TIsNullPredicate, TLikePredicate, TLiteralPredicate, TMergeNode, TPlan, TPlanFragment, TPlanFragmentDestination, TPlanFragmentExecParams, TPlanNode, TQueryExecRequest, TQueryGlobals, TQueryOptions, TRegisterServiceRequest, TRegisterServiceResponse, TRegisterSubscriptionRequest, TRegisterSubscriptionResponse, TReportExecStatusParams, TReportExecStatusResult, TResultRow, TResultSetMetadata, TRowBatch, TRuntimeProfileNode, TRuntimeProfileTree, TScanRange, TScanRangeLocation, TScanRangeLocations, TScanRangeParams, TServiceInstance, TServiceMembership, TSessionState, TSlotDescriptor, TSlotRef, TSortNode, TStatus, TStringLiteral, TTableDescriptor, TTableSink, TTransmitDataParams, TTransmitDataResult, TTupleDescriptor, TUniqueId, TUnregisterServiceRequest, TUnregisterServiceResponse, TUnregisterSubscriptionRequest, TUnregisterSubscriptionResponse, TUpdateStateRequest, TUpdateStateResponse, TVersionedObject

Constant Summary

NUM_NODES_ALL =

0

NUM_NODES_ALL_RACKS =

-1

INVALID_PLAN_NODE_ID =

-1

DEFAULT_PARTITION_ID =

-1

COMPRESSION_MAP =

{
%q"" =>           0,
%q"none" =>           0,
%q"deflate" =>           1,
%q"gzip" =>           2,
%q"bzip2" =>           3,
%q"snappy" =>           4,
}

DEFAULT_QUERY_OPTIONS =

{
0 => %q"false",
1 => %q"0",
2 => %q"false",
3 => %q"0",
4 => %q"0",
5 => %q"0",
6 => %q"0",
7 => %q"0",
8 => %q"false",
9 => %q"-1",
}