Class: Impala::Protocol::TQueryOptions

Inherits:
Object
  • Object
show all
Includes:
Thrift::Struct, Thrift::Struct_Union
Defined in:
lib/impala/protocol/impala_internal_service_types.rb

Constant Summary collapse

ABORT_ON_ERROR =
1
MAX_ERRORS =
2
DISABLE_CODEGEN =
3
BATCH_SIZE =
4
RETURN_AS_ASCII =
5
NUM_NODES =
6
MAX_SCAN_RANGE_LENGTH =
7
NUM_SCANNER_THREADS =
8
MAX_IO_BUFFERS =
9
ALLOW_UNSUPPORTED_FORMATS =
10
DEFAULT_ORDER_BY_LIMIT =
11
FIELDS =
{
ABORT_ON_ERROR => { :type => ::Thrift::Types::BOOL, :name => 'abort_on_error', :default => false },
MAX_ERRORS => { :type => ::Thrift::Types::I32, :name => 'max_errors', :default => 0 },
DISABLE_CODEGEN => { :type => ::Thrift::Types::BOOL, :name => 'disable_codegen', :default => false },
BATCH_SIZE => { :type => ::Thrift::Types::I32, :name => 'batch_size', :default => 0 },
RETURN_AS_ASCII => { :type => ::Thrift::Types::BOOL, :name => 'return_as_ascii', :default => true },
NUM_NODES => { :type => ::Thrift::Types::I32, :name => 'num_nodes', :default => 0 },
MAX_SCAN_RANGE_LENGTH => { :type => ::Thrift::Types::I64, :name => 'max_scan_range_length', :default => 0 },
NUM_SCANNER_THREADS => { :type => ::Thrift::Types::I32, :name => 'num_scanner_threads', :default => 0 },
MAX_IO_BUFFERS => { :type => ::Thrift::Types::I32, :name => 'max_io_buffers', :default => 0 },
ALLOW_UNSUPPORTED_FORMATS => { :type => ::Thrift::Types::BOOL, :name => 'allow_unsupported_formats', :default => false },
DEFAULT_ORDER_BY_LIMIT => { :type => ::Thrift::Types::I64, :name => 'default_order_by_limit', :default => -1, :optional => true }
}

Instance Method Summary collapse

Instance Method Details

#struct_fieldsObject



56
# File 'lib/impala/protocol/impala_internal_service_types.rb', line 56

def struct_fields; FIELDS; end

#validateObject

Raises:

  • (::Thrift::ProtocolException)


58
59
60
61
62
63
64
65
66
67
68
69
# File 'lib/impala/protocol/impala_internal_service_types.rb', line 58

def validate
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field abort_on_error is unset!') if @abort_on_error.nil?
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field max_errors is unset!') unless @max_errors
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field disable_codegen is unset!') if @disable_codegen.nil?
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field batch_size is unset!') unless @batch_size
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field return_as_ascii is unset!') if @return_as_ascii.nil?
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field num_nodes is unset!') unless @num_nodes
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field max_scan_range_length is unset!') unless @max_scan_range_length
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field num_scanner_threads is unset!') unless @num_scanner_threads
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field max_io_buffers is unset!') unless @max_io_buffers
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field allow_unsupported_formats is unset!') if @allow_unsupported_formats.nil?
end