| # |
| # Autogenerated by Thrift Compiler (0.9.3) |
| # |
| # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
| # |
| |
| require 'thrift' |
| require 'fb303_types' |
| |
| |
| module HiveObjectType |
| GLOBAL = 1 |
| DATABASE = 2 |
| TABLE = 3 |
| PARTITION = 4 |
| COLUMN = 5 |
| VALUE_MAP = {1 => "GLOBAL", 2 => "DATABASE", 3 => "TABLE", 4 => "PARTITION", 5 => "COLUMN"} |
| VALID_VALUES = Set.new([GLOBAL, DATABASE, TABLE, PARTITION, COLUMN]).freeze |
| end |
| |
| module PrincipalType |
| USER = 1 |
| ROLE = 2 |
| GROUP = 3 |
| VALUE_MAP = {1 => "USER", 2 => "ROLE", 3 => "GROUP"} |
| VALID_VALUES = Set.new([USER, ROLE, GROUP]).freeze |
| end |
| |
| module PartitionEventType |
| LOAD_DONE = 1 |
| VALUE_MAP = {1 => "LOAD_DONE"} |
| VALID_VALUES = Set.new([LOAD_DONE]).freeze |
| end |
| |
| module TxnState |
| COMMITTED = 1 |
| ABORTED = 2 |
| OPEN = 3 |
| VALUE_MAP = {1 => "COMMITTED", 2 => "ABORTED", 3 => "OPEN"} |
| VALID_VALUES = Set.new([COMMITTED, ABORTED, OPEN]).freeze |
| end |
| |
| module LockLevel |
| DB = 1 |
| TABLE = 2 |
| PARTITION = 3 |
| VALUE_MAP = {1 => "DB", 2 => "TABLE", 3 => "PARTITION"} |
| VALID_VALUES = Set.new([DB, TABLE, PARTITION]).freeze |
| end |
| |
| module LockState |
| ACQUIRED = 1 |
| WAITING = 2 |
| ABORT = 3 |
| NOT_ACQUIRED = 4 |
| VALUE_MAP = {1 => "ACQUIRED", 2 => "WAITING", 3 => "ABORT", 4 => "NOT_ACQUIRED"} |
| VALID_VALUES = Set.new([ACQUIRED, WAITING, ABORT, NOT_ACQUIRED]).freeze |
| end |
| |
| module LockType |
| SHARED_READ = 1 |
| SHARED_WRITE = 2 |
| EXCLUSIVE = 3 |
| EXCL_WRITE = 4 |
| VALUE_MAP = {1 => "SHARED_READ", 2 => "SHARED_WRITE", 3 => "EXCLUSIVE", 4 => "EXCL_WRITE"} |
| VALID_VALUES = Set.new([SHARED_READ, SHARED_WRITE, EXCLUSIVE, EXCL_WRITE]).freeze |
| end |
| |
| module CompactionType |
| MINOR = 1 |
| MAJOR = 2 |
| VALUE_MAP = {1 => "MINOR", 2 => "MAJOR"} |
| VALID_VALUES = Set.new([MINOR, MAJOR]).freeze |
| end |
| |
| module GrantRevokeType |
| GRANT = 1 |
| REVOKE = 2 |
| VALUE_MAP = {1 => "GRANT", 2 => "REVOKE"} |
| VALID_VALUES = Set.new([GRANT, REVOKE]).freeze |
| end |
| |
| module DataOperationType |
| SELECT = 1 |
| INSERT = 2 |
| UPDATE = 3 |
| DELETE = 4 |
| UNSET = 5 |
| NO_TXN = 6 |
| VALUE_MAP = {1 => "SELECT", 2 => "INSERT", 3 => "UPDATE", 4 => "DELETE", 5 => "UNSET", 6 => "NO_TXN"} |
| VALID_VALUES = Set.new([SELECT, INSERT, UPDATE, DELETE, UNSET, NO_TXN]).freeze |
| end |
| |
| module EventRequestType |
| INSERT = 1 |
| UPDATE = 2 |
| DELETE = 3 |
| VALUE_MAP = {1 => "INSERT", 2 => "UPDATE", 3 => "DELETE"} |
| VALID_VALUES = Set.new([INSERT, UPDATE, DELETE]).freeze |
| end |
| |
| module SerdeType |
| HIVE = 1 |
| SCHEMA_REGISTRY = 2 |
| VALUE_MAP = {1 => "HIVE", 2 => "SCHEMA_REGISTRY"} |
| VALID_VALUES = Set.new([HIVE, SCHEMA_REGISTRY]).freeze |
| end |
| |
| module SchemaType |
| HIVE = 1 |
| AVRO = 2 |
| VALUE_MAP = {1 => "HIVE", 2 => "AVRO"} |
| VALID_VALUES = Set.new([HIVE, AVRO]).freeze |
| end |
| |
| module SchemaCompatibility |
| NONE = 1 |
| BACKWARD = 2 |
| FORWARD = 3 |
| BOTH = 4 |
| VALUE_MAP = {1 => "NONE", 2 => "BACKWARD", 3 => "FORWARD", 4 => "BOTH"} |
| VALID_VALUES = Set.new([NONE, BACKWARD, FORWARD, BOTH]).freeze |
| end |
| |
| module SchemaValidation |
| LATEST = 1 |
| ALL = 2 |
| VALUE_MAP = {1 => "LATEST", 2 => "ALL"} |
| VALID_VALUES = Set.new([LATEST, ALL]).freeze |
| end |
| |
| module SchemaVersionState |
| INITIATED = 1 |
| START_REVIEW = 2 |
| CHANGES_REQUIRED = 3 |
| REVIEWED = 4 |
| ENABLED = 5 |
| DISABLED = 6 |
| ARCHIVED = 7 |
| DELETED = 8 |
| VALUE_MAP = {1 => "INITIATED", 2 => "START_REVIEW", 3 => "CHANGES_REQUIRED", 4 => "REVIEWED", 5 => "ENABLED", 6 => "DISABLED", 7 => "ARCHIVED", 8 => "DELETED"} |
| VALID_VALUES = Set.new([INITIATED, START_REVIEW, CHANGES_REQUIRED, REVIEWED, ENABLED, DISABLED, ARCHIVED, DELETED]).freeze |
| end |
| |
| module FunctionType |
| JAVA = 1 |
| VALUE_MAP = {1 => "JAVA"} |
| VALID_VALUES = Set.new([JAVA]).freeze |
| end |
| |
| module ResourceType |
| JAR = 1 |
| FILE = 2 |
| ARCHIVE = 3 |
| VALUE_MAP = {1 => "JAR", 2 => "FILE", 3 => "ARCHIVE"} |
| VALID_VALUES = Set.new([JAR, FILE, ARCHIVE]).freeze |
| end |
| |
| module TxnType |
| DEFAULT = 0 |
| REPL_CREATED = 1 |
| READ_ONLY = 2 |
| COMPACTION = 3 |
| VALUE_MAP = {0 => "DEFAULT", 1 => "REPL_CREATED", 2 => "READ_ONLY", 3 => "COMPACTION"} |
| VALID_VALUES = Set.new([DEFAULT, REPL_CREATED, READ_ONLY, COMPACTION]).freeze |
| end |
| |
| module GetTablesExtRequestFields |
| ACCESS_TYPE = 1 |
| PROCESSOR_CAPABILITIES = 2 |
| ALL = 2147483647 |
| VALUE_MAP = {1 => "ACCESS_TYPE", 2 => "PROCESSOR_CAPABILITIES", 2147483647 => "ALL"} |
| VALID_VALUES = Set.new([ACCESS_TYPE, PROCESSOR_CAPABILITIES, ALL]).freeze |
| end |
| |
| module FileMetadataExprType |
| ORC_SARG = 1 |
| VALUE_MAP = {1 => "ORC_SARG"} |
| VALID_VALUES = Set.new([ORC_SARG]).freeze |
| end |
| |
| module ClientCapability |
| TEST_CAPABILITY = 1 |
| INSERT_ONLY_TABLES = 2 |
| VALUE_MAP = {1 => "TEST_CAPABILITY", 2 => "INSERT_ONLY_TABLES"} |
| VALID_VALUES = Set.new([TEST_CAPABILITY, INSERT_ONLY_TABLES]).freeze |
| end |
| |
| module WMResourcePlanStatus |
| ACTIVE = 1 |
| ENABLED = 2 |
| DISABLED = 3 |
| VALUE_MAP = {1 => "ACTIVE", 2 => "ENABLED", 3 => "DISABLED"} |
| VALID_VALUES = Set.new([ACTIVE, ENABLED, DISABLED]).freeze |
| end |
| |
| module WMPoolSchedulingPolicy |
| FAIR = 1 |
| FIFO = 2 |
| VALUE_MAP = {1 => "FAIR", 2 => "FIFO"} |
| VALID_VALUES = Set.new([FAIR, FIFO]).freeze |
| end |
| |
| module ScheduledQueryMaintenanceRequestType |
| CREATE = 1 |
| ALTER = 2 |
| DROP = 3 |
| VALUE_MAP = {1 => "CREATE", 2 => "ALTER", 3 => "DROP"} |
| VALID_VALUES = Set.new([CREATE, ALTER, DROP]).freeze |
| end |
| |
| module QueryState |
| INITED = 0 |
| EXECUTING = 1 |
| FAILED = 2 |
| FINISHED = 3 |
| TIMED_OUT = 4 |
| VALUE_MAP = {0 => "INITED", 1 => "EXECUTING", 2 => "FAILED", 3 => "FINISHED", 4 => "TIMED_OUT"} |
| VALID_VALUES = Set.new([INITED, EXECUTING, FAILED, FINISHED, TIMED_OUT]).freeze |
| end |
| |
| module PartitionFilterMode |
| BY_NAMES = 0 |
| BY_VALUES = 1 |
| BY_EXPR = 2 |
| VALUE_MAP = {0 => "BY_NAMES", 1 => "BY_VALUES", 2 => "BY_EXPR"} |
| VALID_VALUES = Set.new([BY_NAMES, BY_VALUES, BY_EXPR]).freeze |
| end |
| |
| class Version |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| VERSION = 1 |
| COMMENTS = 2 |
| |
| FIELDS = { |
| VERSION => {:type => ::Thrift::Types::STRING, :name => 'version'}, |
| COMMENTS => {:type => ::Thrift::Types::STRING, :name => 'comments'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class FieldSchema |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| TYPE = 2 |
| COMMENT = 3 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| TYPE => {:type => ::Thrift::Types::STRING, :name => 'type'}, |
| COMMENT => {:type => ::Thrift::Types::STRING, :name => 'comment'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLPrimaryKey |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLE_DB = 1 |
| TABLE_NAME = 2 |
| COLUMN_NAME = 3 |
| KEY_SEQ = 4 |
| PK_NAME = 5 |
| ENABLE_CSTR = 6 |
| VALIDATE_CSTR = 7 |
| RELY_CSTR = 8 |
| CATNAME = 9 |
| |
| FIELDS = { |
| TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'}, |
| TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'}, |
| COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'}, |
| KEY_SEQ => {:type => ::Thrift::Types::I32, :name => 'key_seq'}, |
| PK_NAME => {:type => ::Thrift::Types::STRING, :name => 'pk_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLForeignKey |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PKTABLE_DB = 1 |
| PKTABLE_NAME = 2 |
| PKCOLUMN_NAME = 3 |
| FKTABLE_DB = 4 |
| FKTABLE_NAME = 5 |
| FKCOLUMN_NAME = 6 |
| KEY_SEQ = 7 |
| UPDATE_RULE = 8 |
| DELETE_RULE = 9 |
| FK_NAME = 10 |
| PK_NAME = 11 |
| ENABLE_CSTR = 12 |
| VALIDATE_CSTR = 13 |
| RELY_CSTR = 14 |
| CATNAME = 15 |
| |
| FIELDS = { |
| PKTABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'pktable_db'}, |
| PKTABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'pktable_name'}, |
| PKCOLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'pkcolumn_name'}, |
| FKTABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'fktable_db'}, |
| FKTABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'fktable_name'}, |
| FKCOLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'fkcolumn_name'}, |
| KEY_SEQ => {:type => ::Thrift::Types::I32, :name => 'key_seq'}, |
| UPDATE_RULE => {:type => ::Thrift::Types::I32, :name => 'update_rule'}, |
| DELETE_RULE => {:type => ::Thrift::Types::I32, :name => 'delete_rule'}, |
| FK_NAME => {:type => ::Thrift::Types::STRING, :name => 'fk_name'}, |
| PK_NAME => {:type => ::Thrift::Types::STRING, :name => 'pk_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLUniqueConstraint |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| TABLE_DB = 2 |
| TABLE_NAME = 3 |
| COLUMN_NAME = 4 |
| KEY_SEQ = 5 |
| UK_NAME = 6 |
| ENABLE_CSTR = 7 |
| VALIDATE_CSTR = 8 |
| RELY_CSTR = 9 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'}, |
| TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'}, |
| COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'}, |
| KEY_SEQ => {:type => ::Thrift::Types::I32, :name => 'key_seq'}, |
| UK_NAME => {:type => ::Thrift::Types::STRING, :name => 'uk_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLNotNullConstraint |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| TABLE_DB = 2 |
| TABLE_NAME = 3 |
| COLUMN_NAME = 4 |
| NN_NAME = 5 |
| ENABLE_CSTR = 6 |
| VALIDATE_CSTR = 7 |
| RELY_CSTR = 8 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'}, |
| TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'}, |
| COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'}, |
| NN_NAME => {:type => ::Thrift::Types::STRING, :name => 'nn_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLDefaultConstraint |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| TABLE_DB = 2 |
| TABLE_NAME = 3 |
| COLUMN_NAME = 4 |
| DEFAULT_VALUE = 5 |
| DC_NAME = 6 |
| ENABLE_CSTR = 7 |
| VALIDATE_CSTR = 8 |
| RELY_CSTR = 9 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'}, |
| TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'}, |
| COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'}, |
| DEFAULT_VALUE => {:type => ::Thrift::Types::STRING, :name => 'default_value'}, |
| DC_NAME => {:type => ::Thrift::Types::STRING, :name => 'dc_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SQLCheckConstraint |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| TABLE_DB = 2 |
| TABLE_NAME = 3 |
| COLUMN_NAME = 4 |
| CHECK_EXPRESSION = 5 |
| DC_NAME = 6 |
| ENABLE_CSTR = 7 |
| VALIDATE_CSTR = 8 |
| RELY_CSTR = 9 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'}, |
| TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'}, |
| COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'}, |
| CHECK_EXPRESSION => {:type => ::Thrift::Types::STRING, :name => 'check_expression'}, |
| DC_NAME => {:type => ::Thrift::Types::STRING, :name => 'dc_name'}, |
| ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'}, |
| VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'}, |
| RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Type |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| TYPE1 = 2 |
| TYPE2 = 3 |
| FIELDS = 4 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| TYPE1 => {:type => ::Thrift::Types::STRING, :name => 'type1', :optional => true}, |
| TYPE2 => {:type => ::Thrift::Types::STRING, :name => 'type2', :optional => true}, |
| FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class HiveObjectRef |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| OBJECTTYPE = 1 |
| DBNAME = 2 |
| OBJECTNAME = 3 |
| PARTVALUES = 4 |
| COLUMNNAME = 5 |
| CATNAME = 6 |
| |
| FIELDS = { |
| OBJECTTYPE => {:type => ::Thrift::Types::I32, :name => 'objectType', :enum_class => ::HiveObjectType}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| OBJECTNAME => {:type => ::Thrift::Types::STRING, :name => 'objectName'}, |
| PARTVALUES => {:type => ::Thrift::Types::LIST, :name => 'partValues', :element => {:type => ::Thrift::Types::STRING}}, |
| COLUMNNAME => {:type => ::Thrift::Types::STRING, :name => 'columnName'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @objectType.nil? || ::HiveObjectType::VALID_VALUES.include?(@objectType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field objectType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PrivilegeGrantInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRIVILEGE = 1 |
| CREATETIME = 2 |
| GRANTOR = 3 |
| GRANTORTYPE = 4 |
| GRANTOPTION = 5 |
| |
| FIELDS = { |
| PRIVILEGE => {:type => ::Thrift::Types::STRING, :name => 'privilege'}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| GRANTOR => {:type => ::Thrift::Types::STRING, :name => 'grantor'}, |
| GRANTORTYPE => {:type => ::Thrift::Types::I32, :name => 'grantorType', :enum_class => ::PrincipalType}, |
| GRANTOPTION => {:type => ::Thrift::Types::BOOL, :name => 'grantOption'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @grantorType.nil? || ::PrincipalType::VALID_VALUES.include?(@grantorType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field grantorType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class HiveObjectPrivilege |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| HIVEOBJECT = 1 |
| PRINCIPALNAME = 2 |
| PRINCIPALTYPE = 3 |
| GRANTINFO = 4 |
| AUTHORIZER = 5 |
| |
| FIELDS = { |
| HIVEOBJECT => {:type => ::Thrift::Types::STRUCT, :name => 'hiveObject', :class => ::HiveObjectRef}, |
| PRINCIPALNAME => {:type => ::Thrift::Types::STRING, :name => 'principalName'}, |
| PRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'principalType', :enum_class => ::PrincipalType}, |
| GRANTINFO => {:type => ::Thrift::Types::STRUCT, :name => 'grantInfo', :class => ::PrivilegeGrantInfo}, |
| AUTHORIZER => {:type => ::Thrift::Types::STRING, :name => 'authorizer'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @principalType.nil? || ::PrincipalType::VALID_VALUES.include?(@principalType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field principalType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PrivilegeBag |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRIVILEGES = 1 |
| |
| FIELDS = { |
| PRIVILEGES => {:type => ::Thrift::Types::LIST, :name => 'privileges', :element => {:type => ::Thrift::Types::STRUCT, :class => ::HiveObjectPrivilege}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PrincipalPrivilegeSet |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| USERPRIVILEGES = 1 |
| GROUPPRIVILEGES = 2 |
| ROLEPRIVILEGES = 3 |
| |
| FIELDS = { |
| USERPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'userPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}}, |
| GROUPPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'groupPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}}, |
| ROLEPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'rolePrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GrantRevokePrivilegeRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| REQUESTTYPE = 1 |
| PRIVILEGES = 2 |
| REVOKEGRANTOPTION = 3 |
| |
| FIELDS = { |
| REQUESTTYPE => {:type => ::Thrift::Types::I32, :name => 'requestType', :enum_class => ::GrantRevokeType}, |
| PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrivilegeBag}, |
| REVOKEGRANTOPTION => {:type => ::Thrift::Types::BOOL, :name => 'revokeGrantOption', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @requestType.nil? || ::GrantRevokeType::VALID_VALUES.include?(@requestType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field requestType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GrantRevokePrivilegeResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SUCCESS = 1 |
| |
| FIELDS = { |
| SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TruncateTableRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| PARTNAMES = 3 |
| WRITEID = 4 |
| VALIDWRITEIDLIST = 5 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| PARTNAMES => {:type => ::Thrift::Types::LIST, :name => 'partNames', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TruncateTableResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Role |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ROLENAME = 1 |
| CREATETIME = 2 |
| OWNERNAME = 3 |
| |
| FIELDS = { |
| ROLENAME => {:type => ::Thrift::Types::STRING, :name => 'roleName'}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| OWNERNAME => {:type => ::Thrift::Types::STRING, :name => 'ownerName'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class RolePrincipalGrant |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ROLENAME = 1 |
| PRINCIPALNAME = 2 |
| PRINCIPALTYPE = 3 |
| GRANTOPTION = 4 |
| GRANTTIME = 5 |
| GRANTORNAME = 6 |
| GRANTORPRINCIPALTYPE = 7 |
| |
| FIELDS = { |
| ROLENAME => {:type => ::Thrift::Types::STRING, :name => 'roleName'}, |
| PRINCIPALNAME => {:type => ::Thrift::Types::STRING, :name => 'principalName'}, |
| PRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'principalType', :enum_class => ::PrincipalType}, |
| GRANTOPTION => {:type => ::Thrift::Types::BOOL, :name => 'grantOption'}, |
| GRANTTIME => {:type => ::Thrift::Types::I32, :name => 'grantTime'}, |
| GRANTORNAME => {:type => ::Thrift::Types::STRING, :name => 'grantorName'}, |
| GRANTORPRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'grantorPrincipalType', :enum_class => ::PrincipalType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @principalType.nil? || ::PrincipalType::VALID_VALUES.include?(@principalType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field principalType!') |
| end |
| unless @grantorPrincipalType.nil? || ::PrincipalType::VALID_VALUES.include?(@grantorPrincipalType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field grantorPrincipalType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetRoleGrantsForPrincipalRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRINCIPAL_NAME = 1 |
| PRINCIPAL_TYPE = 2 |
| |
| FIELDS = { |
| PRINCIPAL_NAME => {:type => ::Thrift::Types::STRING, :name => 'principal_name'}, |
| PRINCIPAL_TYPE => {:type => ::Thrift::Types::I32, :name => 'principal_type', :enum_class => ::PrincipalType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field principal_name is unset!') unless @principal_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field principal_type is unset!') unless @principal_type |
| unless @principal_type.nil? || ::PrincipalType::VALID_VALUES.include?(@principal_type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field principal_type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetRoleGrantsForPrincipalResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRINCIPALGRANTS = 1 |
| |
| FIELDS = { |
| PRINCIPALGRANTS => {:type => ::Thrift::Types::LIST, :name => 'principalGrants', :element => {:type => ::Thrift::Types::STRUCT, :class => ::RolePrincipalGrant}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field principalGrants is unset!') unless @principalGrants |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPrincipalsInRoleRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ROLENAME = 1 |
| |
| FIELDS = { |
| ROLENAME => {:type => ::Thrift::Types::STRING, :name => 'roleName'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field roleName is unset!') unless @roleName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPrincipalsInRoleResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRINCIPALGRANTS = 1 |
| |
| FIELDS = { |
| PRINCIPALGRANTS => {:type => ::Thrift::Types::LIST, :name => 'principalGrants', :element => {:type => ::Thrift::Types::STRUCT, :class => ::RolePrincipalGrant}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field principalGrants is unset!') unless @principalGrants |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GrantRevokeRoleRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| REQUESTTYPE = 1 |
| ROLENAME = 2 |
| PRINCIPALNAME = 3 |
| PRINCIPALTYPE = 4 |
| GRANTOR = 5 |
| GRANTORTYPE = 6 |
| GRANTOPTION = 7 |
| |
| FIELDS = { |
| REQUESTTYPE => {:type => ::Thrift::Types::I32, :name => 'requestType', :enum_class => ::GrantRevokeType}, |
| ROLENAME => {:type => ::Thrift::Types::STRING, :name => 'roleName'}, |
| PRINCIPALNAME => {:type => ::Thrift::Types::STRING, :name => 'principalName'}, |
| PRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'principalType', :enum_class => ::PrincipalType}, |
| GRANTOR => {:type => ::Thrift::Types::STRING, :name => 'grantor', :optional => true}, |
| GRANTORTYPE => {:type => ::Thrift::Types::I32, :name => 'grantorType', :optional => true, :enum_class => ::PrincipalType}, |
| GRANTOPTION => {:type => ::Thrift::Types::BOOL, :name => 'grantOption', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @requestType.nil? || ::GrantRevokeType::VALID_VALUES.include?(@requestType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field requestType!') |
| end |
| unless @principalType.nil? || ::PrincipalType::VALID_VALUES.include?(@principalType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field principalType!') |
| end |
| unless @grantorType.nil? || ::PrincipalType::VALID_VALUES.include?(@grantorType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field grantorType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GrantRevokeRoleResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SUCCESS = 1 |
| |
| FIELDS = { |
| SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Catalog |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| DESCRIPTION = 2 |
| LOCATIONURI = 3 |
| CREATETIME = 4 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true}, |
| LOCATIONURI => {:type => ::Thrift::Types::STRING, :name => 'locationUri'}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CreateCatalogRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATALOG = 1 |
| |
| FIELDS = { |
| CATALOG => {:type => ::Thrift::Types::STRUCT, :name => 'catalog', :class => ::Catalog} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterCatalogRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| NEWCAT = 2 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| NEWCAT => {:type => ::Thrift::Types::STRUCT, :name => 'newCat', :class => ::Catalog} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetCatalogRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetCatalogResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATALOG = 1 |
| |
| FIELDS = { |
| CATALOG => {:type => ::Thrift::Types::STRUCT, :name => 'catalog', :class => ::Catalog} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetCatalogsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAMES = 1 |
| |
| FIELDS = { |
| NAMES => {:type => ::Thrift::Types::LIST, :name => 'names', :element => {:type => ::Thrift::Types::STRING}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DropCatalogRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Database |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| DESCRIPTION = 2 |
| LOCATIONURI = 3 |
| PARAMETERS = 4 |
| PRIVILEGES = 5 |
| OWNERNAME = 6 |
| OWNERTYPE = 7 |
| CATALOGNAME = 8 |
| CREATETIME = 9 |
| MANAGEDLOCATIONURI = 10 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description'}, |
| LOCATIONURI => {:type => ::Thrift::Types::STRING, :name => 'locationUri'}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true}, |
| OWNERNAME => {:type => ::Thrift::Types::STRING, :name => 'ownerName', :optional => true}, |
| OWNERTYPE => {:type => ::Thrift::Types::I32, :name => 'ownerType', :optional => true, :enum_class => ::PrincipalType}, |
| CATALOGNAME => {:type => ::Thrift::Types::STRING, :name => 'catalogName', :optional => true}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime', :optional => true}, |
| MANAGEDLOCATIONURI => {:type => ::Thrift::Types::STRING, :name => 'managedLocationUri', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @ownerType.nil? || ::PrincipalType::VALID_VALUES.include?(@ownerType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field ownerType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SerDeInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| SERIALIZATIONLIB = 2 |
| PARAMETERS = 3 |
| DESCRIPTION = 4 |
| SERIALIZERCLASS = 5 |
| DESERIALIZERCLASS = 6 |
| SERDETYPE = 7 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| SERIALIZATIONLIB => {:type => ::Thrift::Types::STRING, :name => 'serializationLib'}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true}, |
| SERIALIZERCLASS => {:type => ::Thrift::Types::STRING, :name => 'serializerClass', :optional => true}, |
| DESERIALIZERCLASS => {:type => ::Thrift::Types::STRING, :name => 'deserializerClass', :optional => true}, |
| SERDETYPE => {:type => ::Thrift::Types::I32, :name => 'serdeType', :optional => true, :enum_class => ::SerdeType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @serdeType.nil? || ::SerdeType::VALID_VALUES.include?(@serdeType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field serdeType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Order |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COL = 1 |
| ORDER = 2 |
| |
| FIELDS = { |
| COL => {:type => ::Thrift::Types::STRING, :name => 'col'}, |
| ORDER => {:type => ::Thrift::Types::I32, :name => 'order'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SkewedInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SKEWEDCOLNAMES = 1 |
| SKEWEDCOLVALUES = 2 |
| SKEWEDCOLVALUELOCATIONMAPS = 3 |
| |
| FIELDS = { |
| SKEWEDCOLNAMES => {:type => ::Thrift::Types::LIST, :name => 'skewedColNames', :element => {:type => ::Thrift::Types::STRING}}, |
| SKEWEDCOLVALUES => {:type => ::Thrift::Types::LIST, :name => 'skewedColValues', :element => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRING}}}, |
| SKEWEDCOLVALUELOCATIONMAPS => {:type => ::Thrift::Types::MAP, :name => 'skewedColValueLocationMaps', :key => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRING}}, :value => {:type => ::Thrift::Types::STRING}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class StorageDescriptor |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COLS = 1 |
| LOCATION = 2 |
| INPUTFORMAT = 3 |
| OUTPUTFORMAT = 4 |
| COMPRESSED = 5 |
| NUMBUCKETS = 6 |
| SERDEINFO = 7 |
| BUCKETCOLS = 8 |
| SORTCOLS = 9 |
| PARAMETERS = 10 |
| SKEWEDINFO = 11 |
| STOREDASSUBDIRECTORIES = 12 |
| |
| FIELDS = { |
| COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, |
| LOCATION => {:type => ::Thrift::Types::STRING, :name => 'location'}, |
| INPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'inputFormat'}, |
| OUTPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'outputFormat'}, |
| COMPRESSED => {:type => ::Thrift::Types::BOOL, :name => 'compressed'}, |
| NUMBUCKETS => {:type => ::Thrift::Types::I32, :name => 'numBuckets'}, |
| SERDEINFO => {:type => ::Thrift::Types::STRUCT, :name => 'serdeInfo', :class => ::SerDeInfo}, |
| BUCKETCOLS => {:type => ::Thrift::Types::LIST, :name => 'bucketCols', :element => {:type => ::Thrift::Types::STRING}}, |
| SORTCOLS => {:type => ::Thrift::Types::LIST, :name => 'sortCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Order}}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| SKEWEDINFO => {:type => ::Thrift::Types::STRUCT, :name => 'skewedInfo', :class => ::SkewedInfo, :optional => true}, |
| STOREDASSUBDIRECTORIES => {:type => ::Thrift::Types::BOOL, :name => 'storedAsSubDirectories', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CreationMetadata |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| TBLNAME = 3 |
| TABLESUSED = 4 |
| VALIDTXNLIST = 5 |
| MATERIALIZATIONTIME = 6 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| TABLESUSED => {:type => ::Thrift::Types::SET, :name => 'tablesUsed', :element => {:type => ::Thrift::Types::STRING}}, |
| VALIDTXNLIST => {:type => ::Thrift::Types::STRING, :name => 'validTxnList', :optional => true}, |
| MATERIALIZATIONTIME => {:type => ::Thrift::Types::I64, :name => 'materializationTime', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catName is unset!') unless @catName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablesUsed is unset!') unless @tablesUsed |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class BooleanColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NUMTRUES = 1 |
| NUMFALSES = 2 |
| NUMNULLS = 3 |
| BITVECTORS = 4 |
| |
| FIELDS = { |
| NUMTRUES => {:type => ::Thrift::Types::I64, :name => 'numTrues'}, |
| NUMFALSES => {:type => ::Thrift::Types::I64, :name => 'numFalses'}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numTrues is unset!') unless @numTrues |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numFalses is unset!') unless @numFalses |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DoubleColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOWVALUE = 1 |
| HIGHVALUE = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| LOWVALUE => {:type => ::Thrift::Types::DOUBLE, :name => 'lowValue', :optional => true}, |
| HIGHVALUE => {:type => ::Thrift::Types::DOUBLE, :name => 'highValue', :optional => true}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class LongColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOWVALUE = 1 |
| HIGHVALUE = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| LOWVALUE => {:type => ::Thrift::Types::I64, :name => 'lowValue', :optional => true}, |
| HIGHVALUE => {:type => ::Thrift::Types::I64, :name => 'highValue', :optional => true}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class StringColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MAXCOLLEN = 1 |
| AVGCOLLEN = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| MAXCOLLEN => {:type => ::Thrift::Types::I64, :name => 'maxColLen'}, |
| AVGCOLLEN => {:type => ::Thrift::Types::DOUBLE, :name => 'avgColLen'}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field maxColLen is unset!') unless @maxColLen |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field avgColLen is unset!') unless @avgColLen |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class BinaryColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MAXCOLLEN = 1 |
| AVGCOLLEN = 2 |
| NUMNULLS = 3 |
| BITVECTORS = 4 |
| |
| FIELDS = { |
| MAXCOLLEN => {:type => ::Thrift::Types::I64, :name => 'maxColLen'}, |
| AVGCOLLEN => {:type => ::Thrift::Types::DOUBLE, :name => 'avgColLen'}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field maxColLen is unset!') unless @maxColLen |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field avgColLen is unset!') unless @avgColLen |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Decimal |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCALE = 3 |
| UNSCALED = 1 |
| |
| FIELDS = { |
| SCALE => {:type => ::Thrift::Types::I16, :name => 'scale'}, |
| UNSCALED => {:type => ::Thrift::Types::STRING, :name => 'unscaled', :binary => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field scale is unset!') unless @scale |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field unscaled is unset!') unless @unscaled |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DecimalColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOWVALUE = 1 |
| HIGHVALUE = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| LOWVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'lowValue', :class => ::Decimal, :optional => true}, |
| HIGHVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'highValue', :class => ::Decimal, :optional => true}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Date |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DAYSSINCEEPOCH = 1 |
| |
| FIELDS = { |
| DAYSSINCEEPOCH => {:type => ::Thrift::Types::I64, :name => 'daysSinceEpoch'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field daysSinceEpoch is unset!') unless @daysSinceEpoch |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DateColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOWVALUE = 1 |
| HIGHVALUE = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| LOWVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'lowValue', :class => ::Date, :optional => true}, |
| HIGHVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'highValue', :class => ::Date, :optional => true}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Timestamp |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SECONDSSINCEEPOCH = 1 |
| |
| FIELDS = { |
| SECONDSSINCEEPOCH => {:type => ::Thrift::Types::I64, :name => 'secondsSinceEpoch'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field secondsSinceEpoch is unset!') unless @secondsSinceEpoch |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TimestampColumnStatsData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOWVALUE = 1 |
| HIGHVALUE = 2 |
| NUMNULLS = 3 |
| NUMDVS = 4 |
| BITVECTORS = 5 |
| |
| FIELDS = { |
| LOWVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'lowValue', :class => ::Timestamp, :optional => true}, |
| HIGHVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'highValue', :class => ::Timestamp, :optional => true}, |
| NUMNULLS => {:type => ::Thrift::Types::I64, :name => 'numNulls'}, |
| NUMDVS => {:type => ::Thrift::Types::I64, :name => 'numDVs'}, |
| BITVECTORS => {:type => ::Thrift::Types::STRING, :name => 'bitVectors', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numNulls is unset!') unless @numNulls |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field numDVs is unset!') unless @numDVs |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ColumnStatisticsData < ::Thrift::Union |
| include ::Thrift::Struct_Union |
| class << self |
| def booleanStats(val) |
| ColumnStatisticsData.new(:booleanStats, val) |
| end |
| |
| def longStats(val) |
| ColumnStatisticsData.new(:longStats, val) |
| end |
| |
| def doubleStats(val) |
| ColumnStatisticsData.new(:doubleStats, val) |
| end |
| |
| def stringStats(val) |
| ColumnStatisticsData.new(:stringStats, val) |
| end |
| |
| def binaryStats(val) |
| ColumnStatisticsData.new(:binaryStats, val) |
| end |
| |
| def decimalStats(val) |
| ColumnStatisticsData.new(:decimalStats, val) |
| end |
| |
| def dateStats(val) |
| ColumnStatisticsData.new(:dateStats, val) |
| end |
| |
| def timestampStats(val) |
| ColumnStatisticsData.new(:timestampStats, val) |
| end |
| end |
| |
| BOOLEANSTATS = 1 |
| LONGSTATS = 2 |
| DOUBLESTATS = 3 |
| STRINGSTATS = 4 |
| BINARYSTATS = 5 |
| DECIMALSTATS = 6 |
| DATESTATS = 7 |
| TIMESTAMPSTATS = 8 |
| |
| FIELDS = { |
| BOOLEANSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'booleanStats', :class => ::BooleanColumnStatsData}, |
| LONGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'longStats', :class => ::LongColumnStatsData}, |
| DOUBLESTATS => {:type => ::Thrift::Types::STRUCT, :name => 'doubleStats', :class => ::DoubleColumnStatsData}, |
| STRINGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'stringStats', :class => ::StringColumnStatsData}, |
| BINARYSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'binaryStats', :class => ::BinaryColumnStatsData}, |
| DECIMALSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'decimalStats', :class => ::DecimalColumnStatsData}, |
| DATESTATS => {:type => ::Thrift::Types::STRUCT, :name => 'dateStats', :class => ::DateColumnStatsData}, |
| TIMESTAMPSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'timestampStats', :class => ::TimestampColumnStatsData} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise(StandardError, 'Union fields are not set.') if get_set_field.nil? || get_value.nil? |
| end |
| |
| ::Thrift::Union.generate_accessors self |
| end |
| |
| class ColumnStatisticsObj |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COLNAME = 1 |
| COLTYPE = 2 |
| STATSDATA = 3 |
| |
| FIELDS = { |
| COLNAME => {:type => ::Thrift::Types::STRING, :name => 'colName'}, |
| COLTYPE => {:type => ::Thrift::Types::STRING, :name => 'colType'}, |
| STATSDATA => {:type => ::Thrift::Types::STRUCT, :name => 'statsData', :class => ::ColumnStatisticsData} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colName is unset!') unless @colName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colType is unset!') unless @colType |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field statsData is unset!') unless @statsData |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ColumnStatisticsDesc |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ISTBLLEVEL = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| PARTNAME = 4 |
| LASTANALYZED = 5 |
| CATNAME = 6 |
| |
| FIELDS = { |
| ISTBLLEVEL => {:type => ::Thrift::Types::BOOL, :name => 'isTblLevel'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| PARTNAME => {:type => ::Thrift::Types::STRING, :name => 'partName', :optional => true}, |
| LASTANALYZED => {:type => ::Thrift::Types::I64, :name => 'lastAnalyzed', :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isTblLevel is unset!') if @isTblLevel.nil? |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ColumnStatistics |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| STATSDESC = 1 |
| STATSOBJ = 2 |
| ISSTATSCOMPLIANT = 3 |
| ENGINE = 4 |
| |
| FIELDS = { |
| STATSDESC => {:type => ::Thrift::Types::STRUCT, :name => 'statsDesc', :class => ::ColumnStatisticsDesc}, |
| STATSOBJ => {:type => ::Thrift::Types::LIST, :name => 'statsObj', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatisticsObj}}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field statsDesc is unset!') unless @statsDesc |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field statsObj is unset!') unless @statsObj |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Table |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLENAME = 1 |
| DBNAME = 2 |
| OWNER = 3 |
| CREATETIME = 4 |
| LASTACCESSTIME = 5 |
| RETENTION = 6 |
| SD = 7 |
| PARTITIONKEYS = 8 |
| PARAMETERS = 9 |
| VIEWORIGINALTEXT = 10 |
| VIEWEXPANDEDTEXT = 11 |
| TABLETYPE = 12 |
| PRIVILEGES = 13 |
| TEMPORARY = 14 |
| REWRITEENABLED = 15 |
| CREATIONMETADATA = 16 |
| CATNAME = 17 |
| OWNERTYPE = 18 |
| WRITEID = 19 |
| ISSTATSCOMPLIANT = 20 |
| COLSTATS = 21 |
| ACCESSTYPE = 22 |
| REQUIREDREADCAPABILITIES = 23 |
| REQUIREDWRITECAPABILITIES = 24 |
| ID = 25 |
| |
| FIELDS = { |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| OWNER => {:type => ::Thrift::Types::STRING, :name => 'owner'}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, |
| RETENTION => {:type => ::Thrift::Types::I32, :name => 'retention'}, |
| SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor}, |
| PARTITIONKEYS => {:type => ::Thrift::Types::LIST, :name => 'partitionKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| VIEWORIGINALTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewOriginalText'}, |
| VIEWEXPANDEDTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewExpandedText'}, |
| TABLETYPE => {:type => ::Thrift::Types::STRING, :name => 'tableType'}, |
| PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true}, |
| TEMPORARY => {:type => ::Thrift::Types::BOOL, :name => 'temporary', :default => false, :optional => true}, |
| REWRITEENABLED => {:type => ::Thrift::Types::BOOL, :name => 'rewriteEnabled', :optional => true}, |
| CREATIONMETADATA => {:type => ::Thrift::Types::STRUCT, :name => 'creationMetadata', :class => ::CreationMetadata, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| OWNERTYPE => {:type => ::Thrift::Types::I32, :name => 'ownerType', :default => 1, :optional => true, :enum_class => ::PrincipalType}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true}, |
| COLSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'colStats', :class => ::ColumnStatistics, :optional => true}, |
| ACCESSTYPE => {:type => ::Thrift::Types::BYTE, :name => 'accessType', :optional => true}, |
| REQUIREDREADCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'requiredReadCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| REQUIREDWRITECAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'requiredWriteCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| ID => {:type => ::Thrift::Types::I64, :name => 'id', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @ownerType.nil? || ::PrincipalType::VALID_VALUES.include?(@ownerType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field ownerType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Partition |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| VALUES = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| CREATETIME = 4 |
| LASTACCESSTIME = 5 |
| SD = 6 |
| PARAMETERS = 7 |
| PRIVILEGES = 8 |
| CATNAME = 9 |
| WRITEID = 10 |
| ISSTATSCOMPLIANT = 11 |
| COLSTATS = 12 |
| |
| FIELDS = { |
| VALUES => {:type => ::Thrift::Types::LIST, :name => 'values', :element => {:type => ::Thrift::Types::STRING}}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, |
| SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true}, |
| COLSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'colStats', :class => ::ColumnStatistics, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionWithoutSD |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| VALUES = 1 |
| CREATETIME = 2 |
| LASTACCESSTIME = 3 |
| RELATIVEPATH = 4 |
| PARAMETERS = 5 |
| PRIVILEGES = 6 |
| |
| FIELDS = { |
| VALUES => {:type => ::Thrift::Types::LIST, :name => 'values', :element => {:type => ::Thrift::Types::STRING}}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, |
| RELATIVEPATH => {:type => ::Thrift::Types::STRING, :name => 'relativePath'}, |
| PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, |
| PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionSpecWithSharedSD |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| SD = 2 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::PartitionWithoutSD}}, |
| SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionListComposingSpec |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionSpec |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| ROOTPATH = 3 |
| SHAREDSDPARTITIONSPEC = 4 |
| PARTITIONLIST = 5 |
| CATNAME = 6 |
| WRITEID = 7 |
| ISSTATSCOMPLIANT = 8 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| ROOTPATH => {:type => ::Thrift::Types::STRING, :name => 'rootPath'}, |
| SHAREDSDPARTITIONSPEC => {:type => ::Thrift::Types::STRUCT, :name => 'sharedSDPartitionSpec', :class => ::PartitionSpecWithSharedSD, :optional => true}, |
| PARTITIONLIST => {:type => ::Thrift::Types::STRUCT, :name => 'partitionList', :class => ::PartitionListComposingSpec, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AggrStats |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COLSTATS = 1 |
| PARTSFOUND = 2 |
| ISSTATSCOMPLIANT = 3 |
| |
| FIELDS = { |
| COLSTATS => {:type => ::Thrift::Types::LIST, :name => 'colStats', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatisticsObj}}, |
| PARTSFOUND => {:type => ::Thrift::Types::I64, :name => 'partsFound'}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colStats is unset!') unless @colStats |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partsFound is unset!') unless @partsFound |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SetPartitionsStatsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COLSTATS = 1 |
| NEEDMERGE = 2 |
| WRITEID = 3 |
| VALIDWRITEIDLIST = 4 |
| ENGINE = 5 |
| |
| FIELDS = { |
| COLSTATS => {:type => ::Thrift::Types::LIST, :name => 'colStats', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatistics}}, |
| NEEDMERGE => {:type => ::Thrift::Types::BOOL, :name => 'needMerge', :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colStats is unset!') unless @colStats |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field engine is unset!') unless @engine |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SetPartitionsStatsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESULT = 1 |
| |
| FIELDS = { |
| RESULT => {:type => ::Thrift::Types::BOOL, :name => 'result'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field result is unset!') if @result.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Schema |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FIELDSCHEMAS = 1 |
| PROPERTIES = 2 |
| |
| FIELDS = { |
| FIELDSCHEMAS => {:type => ::Thrift::Types::LIST, :name => 'fieldSchemas', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, |
| PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class EnvironmentContext |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PROPERTIES = 1 |
| |
| FIELDS = { |
| PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PrimaryKeysRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DB_NAME = 1 |
| TBL_NAME = 2 |
| CATNAME = 3 |
| |
| FIELDS = { |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PrimaryKeysResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRIMARYKEYS = 1 |
| |
| FIELDS = { |
| PRIMARYKEYS => {:type => ::Thrift::Types::LIST, :name => 'primaryKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLPrimaryKey}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field primaryKeys is unset!') unless @primaryKeys |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ForeignKeysRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARENT_DB_NAME = 1 |
| PARENT_TBL_NAME = 2 |
| FOREIGN_DB_NAME = 3 |
| FOREIGN_TBL_NAME = 4 |
| CATNAME = 5 |
| |
| FIELDS = { |
| PARENT_DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'parent_db_name'}, |
| PARENT_TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'parent_tbl_name'}, |
| FOREIGN_DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'foreign_db_name'}, |
| FOREIGN_TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'foreign_tbl_name'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ForeignKeysResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FOREIGNKEYS = 1 |
| |
| FIELDS = { |
| FOREIGNKEYS => {:type => ::Thrift::Types::LIST, :name => 'foreignKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLForeignKey}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field foreignKeys is unset!') unless @foreignKeys |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UniqueConstraintsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DB_NAME = 2 |
| TBL_NAME = 3 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catName is unset!') unless @catName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UniqueConstraintsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| UNIQUECONSTRAINTS = 1 |
| |
| FIELDS = { |
| UNIQUECONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'uniqueConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLUniqueConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field uniqueConstraints is unset!') unless @uniqueConstraints |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotNullConstraintsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DB_NAME = 2 |
| TBL_NAME = 3 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catName is unset!') unless @catName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotNullConstraintsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NOTNULLCONSTRAINTS = 1 |
| |
| FIELDS = { |
| NOTNULLCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'notNullConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLNotNullConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field notNullConstraints is unset!') unless @notNullConstraints |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DefaultConstraintsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DB_NAME = 2 |
| TBL_NAME = 3 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catName is unset!') unless @catName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DefaultConstraintsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DEFAULTCONSTRAINTS = 1 |
| |
| FIELDS = { |
| DEFAULTCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'defaultConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLDefaultConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field defaultConstraints is unset!') unless @defaultConstraints |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CheckConstraintsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DB_NAME = 2 |
| TBL_NAME = 3 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catName is unset!') unless @catName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CheckConstraintsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CHECKCONSTRAINTS = 1 |
| |
| FIELDS = { |
| CHECKCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'checkConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLCheckConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field checkConstraints is unset!') unless @checkConstraints |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DropConstraintRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| CONSTRAINTNAME = 3 |
| CATNAME = 4 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, |
| CONSTRAINTNAME => {:type => ::Thrift::Types::STRING, :name => 'constraintname'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field constraintname is unset!') unless @constraintname |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddPrimaryKeyRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PRIMARYKEYCOLS = 1 |
| |
| FIELDS = { |
| PRIMARYKEYCOLS => {:type => ::Thrift::Types::LIST, :name => 'primaryKeyCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLPrimaryKey}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field primaryKeyCols is unset!') unless @primaryKeyCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddForeignKeyRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FOREIGNKEYCOLS = 1 |
| |
| FIELDS = { |
| FOREIGNKEYCOLS => {:type => ::Thrift::Types::LIST, :name => 'foreignKeyCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLForeignKey}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field foreignKeyCols is unset!') unless @foreignKeyCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddUniqueConstraintRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| UNIQUECONSTRAINTCOLS = 1 |
| |
| FIELDS = { |
| UNIQUECONSTRAINTCOLS => {:type => ::Thrift::Types::LIST, :name => 'uniqueConstraintCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLUniqueConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field uniqueConstraintCols is unset!') unless @uniqueConstraintCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddNotNullConstraintRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NOTNULLCONSTRAINTCOLS = 1 |
| |
| FIELDS = { |
| NOTNULLCONSTRAINTCOLS => {:type => ::Thrift::Types::LIST, :name => 'notNullConstraintCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLNotNullConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field notNullConstraintCols is unset!') unless @notNullConstraintCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddDefaultConstraintRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DEFAULTCONSTRAINTCOLS = 1 |
| |
| FIELDS = { |
| DEFAULTCONSTRAINTCOLS => {:type => ::Thrift::Types::LIST, :name => 'defaultConstraintCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLDefaultConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field defaultConstraintCols is unset!') unless @defaultConstraintCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddCheckConstraintRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CHECKCONSTRAINTCOLS = 1 |
| |
| FIELDS = { |
| CHECKCONSTRAINTCOLS => {:type => ::Thrift::Types::LIST, :name => 'checkConstraintCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLCheckConstraint}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field checkConstraintCols is unset!') unless @checkConstraintCols |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionsByExprResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| HASUNKNOWNPARTITIONS = 2 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}}, |
| HASUNKNOWNPARTITIONS => {:type => ::Thrift::Types::BOOL, :name => 'hasUnknownPartitions'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitions is unset!') unless @partitions |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hasUnknownPartitions is unset!') if @hasUnknownPartitions.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionsSpecByExprResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONSSPEC = 1 |
| HASUNKNOWNPARTITIONS = 2 |
| |
| FIELDS = { |
| PARTITIONSSPEC => {:type => ::Thrift::Types::LIST, :name => 'partitionsSpec', :element => {:type => ::Thrift::Types::STRUCT, :class => ::PartitionSpec}}, |
| HASUNKNOWNPARTITIONS => {:type => ::Thrift::Types::BOOL, :name => 'hasUnknownPartitions'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionsSpec is unset!') unless @partitionsSpec |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hasUnknownPartitions is unset!') if @hasUnknownPartitions.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionsByExprRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| EXPR = 3 |
| DEFAULTPARTITIONNAME = 4 |
| MAXPARTS = 5 |
| CATNAME = 6 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| EXPR => {:type => ::Thrift::Types::STRING, :name => 'expr', :binary => true}, |
| DEFAULTPARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'defaultPartitionName', :optional => true}, |
| MAXPARTS => {:type => ::Thrift::Types::I16, :name => 'maxParts', :default => -1, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field expr is unset!') unless @expr |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TableStatsResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLESTATS = 1 |
| ISSTATSCOMPLIANT = 2 |
| |
| FIELDS = { |
| TABLESTATS => {:type => ::Thrift::Types::LIST, :name => 'tableStats', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatisticsObj}}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableStats is unset!') unless @tableStats |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionsStatsResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTSTATS = 1 |
| ISSTATSCOMPLIANT = 2 |
| |
| FIELDS = { |
| PARTSTATS => {:type => ::Thrift::Types::MAP, :name => 'partStats', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatisticsObj}}}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partStats is unset!') unless @partStats |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TableStatsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| COLNAMES = 3 |
| CATNAME = 4 |
| VALIDWRITEIDLIST = 5 |
| ENGINE = 6 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| COLNAMES => {:type => ::Thrift::Types::LIST, :name => 'colNames', :element => {:type => ::Thrift::Types::STRING}}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colNames is unset!') unless @colNames |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field engine is unset!') unless @engine |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionsStatsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| COLNAMES = 3 |
| PARTNAMES = 4 |
| CATNAME = 5 |
| VALIDWRITEIDLIST = 6 |
| ENGINE = 7 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| COLNAMES => {:type => ::Thrift::Types::LIST, :name => 'colNames', :element => {:type => ::Thrift::Types::STRING}}, |
| PARTNAMES => {:type => ::Thrift::Types::LIST, :name => 'partNames', :element => {:type => ::Thrift::Types::STRING}}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field colNames is unset!') unless @colNames |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partNames is unset!') unless @partNames |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field engine is unset!') unless @engine |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddPartitionsResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| ISSTATSCOMPLIANT = 2 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}, :optional => true}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddPartitionsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| PARTS = 3 |
| IFNOTEXISTS = 4 |
| NEEDRESULT = 5 |
| CATNAME = 6 |
| VALIDWRITEIDLIST = 7 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| PARTS => {:type => ::Thrift::Types::LIST, :name => 'parts', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}}, |
| IFNOTEXISTS => {:type => ::Thrift::Types::BOOL, :name => 'ifNotExists'}, |
| NEEDRESULT => {:type => ::Thrift::Types::BOOL, :name => 'needResult', :default => true, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field parts is unset!') unless @parts |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field ifNotExists is unset!') if @ifNotExists.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DropPartitionsResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class DropPartitionsExpr |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EXPR = 1 |
| PARTARCHIVELEVEL = 2 |
| |
| FIELDS = { |
| EXPR => {:type => ::Thrift::Types::STRING, :name => 'expr', :binary => true}, |
| PARTARCHIVELEVEL => {:type => ::Thrift::Types::I32, :name => 'partArchiveLevel', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field expr is unset!') unless @expr |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class RequestPartsSpec < ::Thrift::Union |
| include ::Thrift::Struct_Union |
| class << self |
| def names(val) |
| RequestPartsSpec.new(:names, val) |
| end |
| |
| def exprs(val) |
| RequestPartsSpec.new(:exprs, val) |
| end |
| end |
| |
| NAMES = 1 |
| EXPRS = 2 |
| |
| FIELDS = { |
| NAMES => {:type => ::Thrift::Types::LIST, :name => 'names', :element => {:type => ::Thrift::Types::STRING}}, |
| EXPRS => {:type => ::Thrift::Types::LIST, :name => 'exprs', :element => {:type => ::Thrift::Types::STRUCT, :class => ::DropPartitionsExpr}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise(StandardError, 'Union fields are not set.') if get_set_field.nil? || get_value.nil? |
| end |
| |
| ::Thrift::Union.generate_accessors self |
| end |
| |
| class DropPartitionsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| PARTS = 3 |
| DELETEDATA = 4 |
| IFEXISTS = 5 |
| IGNOREPROTECTION = 6 |
| ENVIRONMENTCONTEXT = 7 |
| NEEDRESULT = 8 |
| CATNAME = 9 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| PARTS => {:type => ::Thrift::Types::STRUCT, :name => 'parts', :class => ::RequestPartsSpec}, |
| DELETEDATA => {:type => ::Thrift::Types::BOOL, :name => 'deleteData', :optional => true}, |
| IFEXISTS => {:type => ::Thrift::Types::BOOL, :name => 'ifExists', :default => true, :optional => true}, |
| IGNOREPROTECTION => {:type => ::Thrift::Types::BOOL, :name => 'ignoreProtection', :optional => true}, |
| ENVIRONMENTCONTEXT => {:type => ::Thrift::Types::STRUCT, :name => 'environmentContext', :class => ::EnvironmentContext, :optional => true}, |
| NEEDRESULT => {:type => ::Thrift::Types::BOOL, :name => 'needResult', :default => true, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field parts is unset!') unless @parts |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionValuesRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| PARTITIONKEYS = 3 |
| APPLYDISTINCT = 4 |
| FILTER = 5 |
| PARTITIONORDER = 6 |
| ASCENDING = 7 |
| MAXPARTS = 8 |
| CATNAME = 9 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| PARTITIONKEYS => {:type => ::Thrift::Types::LIST, :name => 'partitionKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, |
| APPLYDISTINCT => {:type => ::Thrift::Types::BOOL, :name => 'applyDistinct', :default => true, :optional => true}, |
| FILTER => {:type => ::Thrift::Types::STRING, :name => 'filter', :optional => true}, |
| PARTITIONORDER => {:type => ::Thrift::Types::LIST, :name => 'partitionOrder', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}, :optional => true}, |
| ASCENDING => {:type => ::Thrift::Types::BOOL, :name => 'ascending', :default => true, :optional => true}, |
| MAXPARTS => {:type => ::Thrift::Types::I64, :name => 'maxParts', :default => -1, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionKeys is unset!') unless @partitionKeys |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionValuesRow |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ROW = 1 |
| |
| FIELDS = { |
| ROW => {:type => ::Thrift::Types::LIST, :name => 'row', :element => {:type => ::Thrift::Types::STRING}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field row is unset!') unless @row |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PartitionValuesResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONVALUES = 1 |
| |
| FIELDS = { |
| PARTITIONVALUES => {:type => ::Thrift::Types::LIST, :name => 'partitionValues', :element => {:type => ::Thrift::Types::STRUCT, :class => ::PartitionValuesRow}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionValues is unset!') unless @partitionValues |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsByNamesRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DB_NAME = 1 |
| TBL_NAME = 2 |
| NAMES = 3 |
| GET_COL_STATS = 4 |
| PROCESSORCAPABILITIES = 5 |
| PROCESSORIDENTIFIER = 6 |
| ENGINE = 7 |
| |
| FIELDS = { |
| DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, |
| TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'}, |
| NAMES => {:type => ::Thrift::Types::LIST, :name => 'names', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| GET_COL_STATS => {:type => ::Thrift::Types::BOOL, :name => 'get_col_stats', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsByNamesResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONS = 1 |
| |
| FIELDS = { |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitions is unset!') unless @partitions |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ResourceUri |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCETYPE = 1 |
| URI = 2 |
| |
| FIELDS = { |
| RESOURCETYPE => {:type => ::Thrift::Types::I32, :name => 'resourceType', :enum_class => ::ResourceType}, |
| URI => {:type => ::Thrift::Types::STRING, :name => 'uri'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @resourceType.nil? || ::ResourceType::VALID_VALUES.include?(@resourceType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field resourceType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Function |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FUNCTIONNAME = 1 |
| DBNAME = 2 |
| CLASSNAME = 3 |
| OWNERNAME = 4 |
| OWNERTYPE = 5 |
| CREATETIME = 6 |
| FUNCTIONTYPE = 7 |
| RESOURCEURIS = 8 |
| CATNAME = 9 |
| |
| FIELDS = { |
| FUNCTIONNAME => {:type => ::Thrift::Types::STRING, :name => 'functionName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| CLASSNAME => {:type => ::Thrift::Types::STRING, :name => 'className'}, |
| OWNERNAME => {:type => ::Thrift::Types::STRING, :name => 'ownerName'}, |
| OWNERTYPE => {:type => ::Thrift::Types::I32, :name => 'ownerType', :enum_class => ::PrincipalType}, |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, |
| FUNCTIONTYPE => {:type => ::Thrift::Types::I32, :name => 'functionType', :enum_class => ::FunctionType}, |
| RESOURCEURIS => {:type => ::Thrift::Types::LIST, :name => 'resourceUris', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ResourceUri}}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @ownerType.nil? || ::PrincipalType::VALID_VALUES.include?(@ownerType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field ownerType!') |
| end |
| unless @functionType.nil? || ::FunctionType::VALID_VALUES.include?(@functionType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field functionType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TxnInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ID = 1 |
| STATE = 2 |
| USER = 3 |
| HOSTNAME = 4 |
| AGENTINFO = 5 |
| HEARTBEATCOUNT = 6 |
| METAINFO = 7 |
| STARTEDTIME = 8 |
| LASTHEARTBEATTIME = 9 |
| |
| FIELDS = { |
| ID => {:type => ::Thrift::Types::I64, :name => 'id'}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::TxnState}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user'}, |
| HOSTNAME => {:type => ::Thrift::Types::STRING, :name => 'hostname'}, |
| AGENTINFO => {:type => ::Thrift::Types::STRING, :name => 'agentInfo', :default => %q"Unknown", :optional => true}, |
| HEARTBEATCOUNT => {:type => ::Thrift::Types::I32, :name => 'heartbeatCount', :default => 0, :optional => true}, |
| METAINFO => {:type => ::Thrift::Types::STRING, :name => 'metaInfo', :optional => true}, |
| STARTEDTIME => {:type => ::Thrift::Types::I64, :name => 'startedTime', :optional => true}, |
| LASTHEARTBEATTIME => {:type => ::Thrift::Types::I64, :name => 'lastHeartbeatTime', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field id is unset!') unless @id |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field user is unset!') unless @user |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hostname is unset!') unless @hostname |
| unless @state.nil? || ::TxnState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetOpenTxnsInfoResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXN_HIGH_WATER_MARK = 1 |
| OPEN_TXNS = 2 |
| |
| FIELDS = { |
| TXN_HIGH_WATER_MARK => {:type => ::Thrift::Types::I64, :name => 'txn_high_water_mark'}, |
| OPEN_TXNS => {:type => ::Thrift::Types::LIST, :name => 'open_txns', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TxnInfo}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txn_high_water_mark is unset!') unless @txn_high_water_mark |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field open_txns is unset!') unless @open_txns |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetOpenTxnsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXN_HIGH_WATER_MARK = 1 |
| OPEN_TXNS = 2 |
| MIN_OPEN_TXN = 3 |
| ABORTEDBITS = 4 |
| |
| FIELDS = { |
| TXN_HIGH_WATER_MARK => {:type => ::Thrift::Types::I64, :name => 'txn_high_water_mark'}, |
| OPEN_TXNS => {:type => ::Thrift::Types::LIST, :name => 'open_txns', :element => {:type => ::Thrift::Types::I64}}, |
| MIN_OPEN_TXN => {:type => ::Thrift::Types::I64, :name => 'min_open_txn', :optional => true}, |
| ABORTEDBITS => {:type => ::Thrift::Types::STRING, :name => 'abortedBits', :binary => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txn_high_water_mark is unset!') unless @txn_high_water_mark |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field open_txns is unset!') unless @open_txns |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field abortedBits is unset!') unless @abortedBits |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class OpenTxnRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NUM_TXNS = 1 |
| USER = 2 |
| HOSTNAME = 3 |
| AGENTINFO = 4 |
| REPLPOLICY = 5 |
| REPLSRCTXNIDS = 6 |
| TXN_TYPE = 7 |
| |
| FIELDS = { |
| NUM_TXNS => {:type => ::Thrift::Types::I32, :name => 'num_txns'}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user'}, |
| HOSTNAME => {:type => ::Thrift::Types::STRING, :name => 'hostname'}, |
| AGENTINFO => {:type => ::Thrift::Types::STRING, :name => 'agentInfo', :default => %q"Unknown", :optional => true}, |
| REPLPOLICY => {:type => ::Thrift::Types::STRING, :name => 'replPolicy', :optional => true}, |
| REPLSRCTXNIDS => {:type => ::Thrift::Types::LIST, :name => 'replSrcTxnIds', :element => {:type => ::Thrift::Types::I64}, :optional => true}, |
| TXN_TYPE => {:type => ::Thrift::Types::I32, :name => 'txn_type', :default => 0, :optional => true, :enum_class => ::TxnType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field num_txns is unset!') unless @num_txns |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field user is unset!') unless @user |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hostname is unset!') unless @hostname |
| unless @txn_type.nil? || ::TxnType::VALID_VALUES.include?(@txn_type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field txn_type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class OpenTxnsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXN_IDS = 1 |
| |
| FIELDS = { |
| TXN_IDS => {:type => ::Thrift::Types::LIST, :name => 'txn_ids', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txn_ids is unset!') unless @txn_ids |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AbortTxnRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNID = 1 |
| REPLPOLICY = 2 |
| |
| FIELDS = { |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid'}, |
| REPLPOLICY => {:type => ::Thrift::Types::STRING, :name => 'replPolicy', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnid is unset!') unless @txnid |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AbortTxnsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXN_IDS = 1 |
| |
| FIELDS = { |
| TXN_IDS => {:type => ::Thrift::Types::LIST, :name => 'txn_ids', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txn_ids is unset!') unless @txn_ids |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CommitTxnKeyValue |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLEID = 1 |
| KEY = 2 |
| VALUE = 3 |
| |
| FIELDS = { |
| TABLEID => {:type => ::Thrift::Types::I64, :name => 'tableId'}, |
| KEY => {:type => ::Thrift::Types::STRING, :name => 'key'}, |
| VALUE => {:type => ::Thrift::Types::STRING, :name => 'value'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableId is unset!') unless @tableId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field key is unset!') unless @key |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field value is unset!') unless @value |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WriteEventInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| WRITEID = 1 |
| DATABASE = 2 |
| TABLE = 3 |
| FILES = 4 |
| PARTITION = 5 |
| TABLEOBJ = 6 |
| PARTITIONOBJ = 7 |
| |
| FIELDS = { |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId'}, |
| DATABASE => {:type => ::Thrift::Types::STRING, :name => 'database'}, |
| TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, |
| FILES => {:type => ::Thrift::Types::STRING, :name => 'files'}, |
| PARTITION => {:type => ::Thrift::Types::STRING, :name => 'partition', :optional => true}, |
| TABLEOBJ => {:type => ::Thrift::Types::STRING, :name => 'tableObj', :optional => true}, |
| PARTITIONOBJ => {:type => ::Thrift::Types::STRING, :name => 'partitionObj', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field writeId is unset!') unless @writeId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field database is unset!') unless @database |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field table is unset!') unless @table |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field files is unset!') unless @files |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ReplLastIdInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DATABASE = 1 |
| LASTREPLID = 2 |
| TABLE = 3 |
| CATALOG = 4 |
| PARTITIONLIST = 5 |
| |
| FIELDS = { |
| DATABASE => {:type => ::Thrift::Types::STRING, :name => 'database'}, |
| LASTREPLID => {:type => ::Thrift::Types::I64, :name => 'lastReplId'}, |
| TABLE => {:type => ::Thrift::Types::STRING, :name => 'table', :optional => true}, |
| CATALOG => {:type => ::Thrift::Types::STRING, :name => 'catalog', :optional => true}, |
| PARTITIONLIST => {:type => ::Thrift::Types::LIST, :name => 'partitionList', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field database is unset!') unless @database |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lastReplId is unset!') unless @lastReplId |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CommitTxnRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNID = 1 |
| REPLPOLICY = 2 |
| WRITEEVENTINFOS = 3 |
| KEYVALUE = 4 |
| REPLLASTIDINFO = 5 |
| |
| FIELDS = { |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid'}, |
| REPLPOLICY => {:type => ::Thrift::Types::STRING, :name => 'replPolicy', :optional => true}, |
| WRITEEVENTINFOS => {:type => ::Thrift::Types::LIST, :name => 'writeEventInfos', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WriteEventInfo}, :optional => true}, |
| KEYVALUE => {:type => ::Thrift::Types::STRUCT, :name => 'keyValue', :class => ::CommitTxnKeyValue, :optional => true}, |
| REPLLASTIDINFO => {:type => ::Thrift::Types::STRUCT, :name => 'replLastIdInfo', :class => ::ReplLastIdInfo, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnid is unset!') unless @txnid |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ReplTblWriteIdStateRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| VALIDWRITEIDLIST = 1 |
| USER = 2 |
| HOSTNAME = 3 |
| DBNAME = 4 |
| TABLENAME = 5 |
| PARTNAMES = 6 |
| |
| FIELDS = { |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdlist'}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user'}, |
| HOSTNAME => {:type => ::Thrift::Types::STRING, :name => 'hostName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| PARTNAMES => {:type => ::Thrift::Types::LIST, :name => 'partNames', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field validWriteIdlist is unset!') unless @validWriteIdlist |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field user is unset!') unless @user |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hostName is unset!') unless @hostName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetValidWriteIdsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FULLTABLENAMES = 1 |
| VALIDTXNLIST = 2 |
| WRITEID = 3 |
| |
| FIELDS = { |
| FULLTABLENAMES => {:type => ::Thrift::Types::LIST, :name => 'fullTableNames', :element => {:type => ::Thrift::Types::STRING}}, |
| VALIDTXNLIST => {:type => ::Thrift::Types::STRING, :name => 'validTxnList', :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fullTableNames is unset!') unless @fullTableNames |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TableValidWriteIds |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FULLTABLENAME = 1 |
| WRITEIDHIGHWATERMARK = 2 |
| INVALIDWRITEIDS = 3 |
| MINOPENWRITEID = 4 |
| ABORTEDBITS = 5 |
| |
| FIELDS = { |
| FULLTABLENAME => {:type => ::Thrift::Types::STRING, :name => 'fullTableName'}, |
| WRITEIDHIGHWATERMARK => {:type => ::Thrift::Types::I64, :name => 'writeIdHighWaterMark'}, |
| INVALIDWRITEIDS => {:type => ::Thrift::Types::LIST, :name => 'invalidWriteIds', :element => {:type => ::Thrift::Types::I64}}, |
| MINOPENWRITEID => {:type => ::Thrift::Types::I64, :name => 'minOpenWriteId', :optional => true}, |
| ABORTEDBITS => {:type => ::Thrift::Types::STRING, :name => 'abortedBits', :binary => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fullTableName is unset!') unless @fullTableName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field writeIdHighWaterMark is unset!') unless @writeIdHighWaterMark |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field invalidWriteIds is unset!') unless @invalidWriteIds |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field abortedBits is unset!') unless @abortedBits |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetValidWriteIdsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TBLVALIDWRITEIDS = 1 |
| |
| FIELDS = { |
| TBLVALIDWRITEIDS => {:type => ::Thrift::Types::LIST, :name => 'tblValidWriteIds', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TableValidWriteIds}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblValidWriteIds is unset!') unless @tblValidWriteIds |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TxnToWriteId |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNID = 1 |
| WRITEID = 2 |
| |
| FIELDS = { |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnId'}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnId is unset!') unless @txnId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field writeId is unset!') unless @writeId |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AllocateTableWriteIdsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| TXNIDS = 3 |
| REPLPOLICY = 4 |
| SRCTXNTOWRITEIDLIST = 5 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| TXNIDS => {:type => ::Thrift::Types::LIST, :name => 'txnIds', :element => {:type => ::Thrift::Types::I64}, :optional => true}, |
| REPLPOLICY => {:type => ::Thrift::Types::STRING, :name => 'replPolicy', :optional => true}, |
| SRCTXNTOWRITEIDLIST => {:type => ::Thrift::Types::LIST, :name => 'srcTxnToWriteIdList', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TxnToWriteId}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AllocateTableWriteIdsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNTOWRITEIDS = 1 |
| |
| FIELDS = { |
| TXNTOWRITEIDS => {:type => ::Thrift::Types::LIST, :name => 'txnToWriteIds', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TxnToWriteId}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnToWriteIds is unset!') unless @txnToWriteIds |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class LockComponent |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TYPE = 1 |
| LEVEL = 2 |
| DBNAME = 3 |
| TABLENAME = 4 |
| PARTITIONNAME = 5 |
| OPERATIONTYPE = 6 |
| ISTRANSACTIONAL = 7 |
| ISDYNAMICPARTITIONWRITE = 8 |
| |
| FIELDS = { |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::LockType}, |
| LEVEL => {:type => ::Thrift::Types::I32, :name => 'level', :enum_class => ::LockLevel}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename', :optional => true}, |
| PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true}, |
| OPERATIONTYPE => {:type => ::Thrift::Types::I32, :name => 'operationType', :default => 5, :optional => true, :enum_class => ::DataOperationType}, |
| ISTRANSACTIONAL => {:type => ::Thrift::Types::BOOL, :name => 'isTransactional', :default => false, :optional => true}, |
| ISDYNAMICPARTITIONWRITE => {:type => ::Thrift::Types::BOOL, :name => 'isDynamicPartitionWrite', :default => false, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field level is unset!') unless @level |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| unless @type.nil? || ::LockType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| unless @level.nil? || ::LockLevel::VALID_VALUES.include?(@level) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field level!') |
| end |
| unless @operationType.nil? || ::DataOperationType::VALID_VALUES.include?(@operationType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field operationType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class LockRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COMPONENT = 1 |
| TXNID = 2 |
| USER = 3 |
| HOSTNAME = 4 |
| AGENTINFO = 5 |
| ZEROWAITREADENABLED = 6 |
| |
| FIELDS = { |
| COMPONENT => {:type => ::Thrift::Types::LIST, :name => 'component', :element => {:type => ::Thrift::Types::STRUCT, :class => ::LockComponent}}, |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid', :optional => true}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user'}, |
| HOSTNAME => {:type => ::Thrift::Types::STRING, :name => 'hostname'}, |
| AGENTINFO => {:type => ::Thrift::Types::STRING, :name => 'agentInfo', :default => %q"Unknown", :optional => true}, |
| ZEROWAITREADENABLED => {:type => ::Thrift::Types::BOOL, :name => 'zeroWaitReadEnabled', :default => false, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field component is unset!') unless @component |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field user is unset!') unless @user |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hostname is unset!') unless @hostname |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class LockResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKID = 1 |
| STATE = 2 |
| ERRORMESSAGE = 3 |
| |
| FIELDS = { |
| LOCKID => {:type => ::Thrift::Types::I64, :name => 'lockid'}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::LockState}, |
| ERRORMESSAGE => {:type => ::Thrift::Types::STRING, :name => 'errorMessage', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lockid is unset!') unless @lockid |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| unless @state.nil? || ::LockState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CheckLockRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKID = 1 |
| TXNID = 2 |
| ELAPSED_MS = 3 |
| |
| FIELDS = { |
| LOCKID => {:type => ::Thrift::Types::I64, :name => 'lockid'}, |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid', :optional => true}, |
| ELAPSED_MS => {:type => ::Thrift::Types::I64, :name => 'elapsed_ms', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lockid is unset!') unless @lockid |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UnlockRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKID = 1 |
| |
| FIELDS = { |
| LOCKID => {:type => ::Thrift::Types::I64, :name => 'lockid'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lockid is unset!') unless @lockid |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowLocksRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| PARTNAME = 3 |
| ISEXTENDED = 4 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname', :optional => true}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename', :optional => true}, |
| PARTNAME => {:type => ::Thrift::Types::STRING, :name => 'partname', :optional => true}, |
| ISEXTENDED => {:type => ::Thrift::Types::BOOL, :name => 'isExtended', :default => false, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowLocksResponseElement |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKID = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| PARTNAME = 4 |
| STATE = 5 |
| TYPE = 6 |
| TXNID = 7 |
| LASTHEARTBEAT = 8 |
| ACQUIREDAT = 9 |
| USER = 10 |
| HOSTNAME = 11 |
| HEARTBEATCOUNT = 12 |
| AGENTINFO = 13 |
| BLOCKEDBYEXTID = 14 |
| BLOCKEDBYINTID = 15 |
| LOCKIDINTERNAL = 16 |
| |
| FIELDS = { |
| LOCKID => {:type => ::Thrift::Types::I64, :name => 'lockid'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename', :optional => true}, |
| PARTNAME => {:type => ::Thrift::Types::STRING, :name => 'partname', :optional => true}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::LockState}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::LockType}, |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid', :optional => true}, |
| LASTHEARTBEAT => {:type => ::Thrift::Types::I64, :name => 'lastheartbeat'}, |
| ACQUIREDAT => {:type => ::Thrift::Types::I64, :name => 'acquiredat', :optional => true}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user'}, |
| HOSTNAME => {:type => ::Thrift::Types::STRING, :name => 'hostname'}, |
| HEARTBEATCOUNT => {:type => ::Thrift::Types::I32, :name => 'heartbeatCount', :default => 0, :optional => true}, |
| AGENTINFO => {:type => ::Thrift::Types::STRING, :name => 'agentInfo', :optional => true}, |
| BLOCKEDBYEXTID => {:type => ::Thrift::Types::I64, :name => 'blockedByExtId', :optional => true}, |
| BLOCKEDBYINTID => {:type => ::Thrift::Types::I64, :name => 'blockedByIntId', :optional => true}, |
| LOCKIDINTERNAL => {:type => ::Thrift::Types::I64, :name => 'lockIdInternal', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lockid is unset!') unless @lockid |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lastheartbeat is unset!') unless @lastheartbeat |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field user is unset!') unless @user |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field hostname is unset!') unless @hostname |
| unless @state.nil? || ::LockState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| unless @type.nil? || ::LockType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowLocksResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKS = 1 |
| |
| FIELDS = { |
| LOCKS => {:type => ::Thrift::Types::LIST, :name => 'locks', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ShowLocksResponseElement}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class HeartbeatRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LOCKID = 1 |
| TXNID = 2 |
| |
| FIELDS = { |
| LOCKID => {:type => ::Thrift::Types::I64, :name => 'lockid', :optional => true}, |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class HeartbeatTxnRangeRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MIN = 1 |
| MAX = 2 |
| |
| FIELDS = { |
| MIN => {:type => ::Thrift::Types::I64, :name => 'min'}, |
| MAX => {:type => ::Thrift::Types::I64, :name => 'max'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field min is unset!') unless @min |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field max is unset!') unless @max |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class HeartbeatTxnRangeResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ABORTED = 1 |
| NOSUCH = 2 |
| |
| FIELDS = { |
| ABORTED => {:type => ::Thrift::Types::SET, :name => 'aborted', :element => {:type => ::Thrift::Types::I64}}, |
| NOSUCH => {:type => ::Thrift::Types::SET, :name => 'nosuch', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field aborted is unset!') unless @aborted |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field nosuch is unset!') unless @nosuch |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CompactionRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| PARTITIONNAME = 3 |
| TYPE = 4 |
| RUNAS = 5 |
| PROPERTIES = 6 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, |
| PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::CompactionType}, |
| RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runas', :optional => true}, |
| PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| unless @type.nil? || ::CompactionType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CompactionInfoStruct |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ID = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| PARTITIONNAME = 4 |
| TYPE = 5 |
| RUNAS = 6 |
| PROPERTIES = 7 |
| TOOMANYABORTS = 8 |
| STATE = 9 |
| WORKERID = 10 |
| START = 11 |
| HIGHESTWRITEID = 12 |
| ERRORMESSAGE = 13 |
| HASOLDABORT = 14 |
| |
| FIELDS = { |
| ID => {:type => ::Thrift::Types::I64, :name => 'id'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, |
| PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::CompactionType}, |
| RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runas', :optional => true}, |
| PROPERTIES => {:type => ::Thrift::Types::STRING, :name => 'properties', :optional => true}, |
| TOOMANYABORTS => {:type => ::Thrift::Types::BOOL, :name => 'toomanyaborts', :optional => true}, |
| STATE => {:type => ::Thrift::Types::STRING, :name => 'state', :optional => true}, |
| WORKERID => {:type => ::Thrift::Types::STRING, :name => 'workerId', :optional => true}, |
| START => {:type => ::Thrift::Types::I64, :name => 'start', :optional => true}, |
| HIGHESTWRITEID => {:type => ::Thrift::Types::I64, :name => 'highestWriteId', :optional => true}, |
| ERRORMESSAGE => {:type => ::Thrift::Types::STRING, :name => 'errorMessage', :optional => true}, |
| HASOLDABORT => {:type => ::Thrift::Types::BOOL, :name => 'hasoldabort', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field id is unset!') unless @id |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| unless @type.nil? || ::CompactionType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class OptionalCompactionInfoStruct |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CI = 1 |
| |
| FIELDS = { |
| CI => {:type => ::Thrift::Types::STRUCT, :name => 'ci', :class => ::CompactionInfoStruct, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CompactionResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ID = 1 |
| STATE = 2 |
| ACCEPTED = 3 |
| |
| FIELDS = { |
| ID => {:type => ::Thrift::Types::I64, :name => 'id'}, |
| STATE => {:type => ::Thrift::Types::STRING, :name => 'state'}, |
| ACCEPTED => {:type => ::Thrift::Types::BOOL, :name => 'accepted'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field id is unset!') unless @id |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field accepted is unset!') if @accepted.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowCompactRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowCompactResponseElement |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| PARTITIONNAME = 3 |
| TYPE = 4 |
| STATE = 5 |
| WORKERID = 6 |
| START = 7 |
| RUNAS = 8 |
| HIGHTESTTXNID = 9 |
| METAINFO = 10 |
| ENDTIME = 11 |
| HADOOPJOBID = 12 |
| ID = 13 |
| ERRORMESSAGE = 14 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, |
| PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::CompactionType}, |
| STATE => {:type => ::Thrift::Types::STRING, :name => 'state'}, |
| WORKERID => {:type => ::Thrift::Types::STRING, :name => 'workerid', :optional => true}, |
| START => {:type => ::Thrift::Types::I64, :name => 'start', :optional => true}, |
| RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runAs', :optional => true}, |
| HIGHTESTTXNID => {:type => ::Thrift::Types::I64, :name => 'hightestTxnId', :optional => true}, |
| METAINFO => {:type => ::Thrift::Types::STRING, :name => 'metaInfo', :optional => true}, |
| ENDTIME => {:type => ::Thrift::Types::I64, :name => 'endTime', :optional => true}, |
| HADOOPJOBID => {:type => ::Thrift::Types::STRING, :name => 'hadoopJobId', :default => %q"None", :optional => true}, |
| ID => {:type => ::Thrift::Types::I64, :name => 'id', :optional => true}, |
| ERRORMESSAGE => {:type => ::Thrift::Types::STRING, :name => 'errorMessage', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| unless @type.nil? || ::CompactionType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ShowCompactResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COMPACTS = 1 |
| |
| FIELDS = { |
| COMPACTS => {:type => ::Thrift::Types::LIST, :name => 'compacts', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ShowCompactResponseElement}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field compacts is unset!') unless @compacts |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AddDynamicPartitions |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNID = 1 |
| WRITEID = 2 |
| DBNAME = 3 |
| TABLENAME = 4 |
| PARTITIONNAMES = 5 |
| OPERATIONTYPE = 6 |
| |
| FIELDS = { |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid'}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeid'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, |
| PARTITIONNAMES => {:type => ::Thrift::Types::LIST, :name => 'partitionnames', :element => {:type => ::Thrift::Types::STRING}}, |
| OPERATIONTYPE => {:type => ::Thrift::Types::I32, :name => 'operationType', :default => 5, :optional => true, :enum_class => ::DataOperationType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnid is unset!') unless @txnid |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field writeid is unset!') unless @writeid |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionnames is unset!') unless @partitionnames |
| unless @operationType.nil? || ::DataOperationType::VALID_VALUES.include?(@operationType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field operationType!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class BasicTxnInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ISNULL = 1 |
| TIME = 2 |
| TXNID = 3 |
| DBNAME = 4 |
| TABLENAME = 5 |
| PARTITIONNAME = 6 |
| |
| FIELDS = { |
| ISNULL => {:type => ::Thrift::Types::BOOL, :name => 'isnull'}, |
| TIME => {:type => ::Thrift::Types::I64, :name => 'time', :optional => true}, |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid', :optional => true}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname', :optional => true}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename', :optional => true}, |
| PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isnull is unset!') if @isnull.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotificationEventRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| LASTEVENT = 1 |
| MAXEVENTS = 2 |
| EVENTTYPESKIPLIST = 3 |
| |
| FIELDS = { |
| LASTEVENT => {:type => ::Thrift::Types::I64, :name => 'lastEvent'}, |
| MAXEVENTS => {:type => ::Thrift::Types::I32, :name => 'maxEvents', :optional => true}, |
| EVENTTYPESKIPLIST => {:type => ::Thrift::Types::LIST, :name => 'eventTypeSkipList', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field lastEvent is unset!') unless @lastEvent |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotificationEvent |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EVENTID = 1 |
| EVENTTIME = 2 |
| EVENTTYPE = 3 |
| DBNAME = 4 |
| TABLENAME = 5 |
| MESSAGE = 6 |
| MESSAGEFORMAT = 7 |
| CATNAME = 8 |
| |
| FIELDS = { |
| EVENTID => {:type => ::Thrift::Types::I64, :name => 'eventId'}, |
| EVENTTIME => {:type => ::Thrift::Types::I32, :name => 'eventTime'}, |
| EVENTTYPE => {:type => ::Thrift::Types::STRING, :name => 'eventType'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName', :optional => true}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :optional => true}, |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}, |
| MESSAGEFORMAT => {:type => ::Thrift::Types::STRING, :name => 'messageFormat', :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field eventId is unset!') unless @eventId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field eventTime is unset!') unless @eventTime |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field eventType is unset!') unless @eventType |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field message is unset!') unless @message |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotificationEventResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EVENTS = 1 |
| |
| FIELDS = { |
| EVENTS => {:type => ::Thrift::Types::LIST, :name => 'events', :element => {:type => ::Thrift::Types::STRUCT, :class => ::NotificationEvent}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field events is unset!') unless @events |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CurrentNotificationEventId |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EVENTID = 1 |
| |
| FIELDS = { |
| EVENTID => {:type => ::Thrift::Types::I64, :name => 'eventId'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field eventId is unset!') unless @eventId |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotificationEventsCountRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FROMEVENTID = 1 |
| DBNAME = 2 |
| CATNAME = 3 |
| TOEVENTID = 4 |
| LIMIT = 5 |
| |
| FIELDS = { |
| FROMEVENTID => {:type => ::Thrift::Types::I64, :name => 'fromEventId'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| TOEVENTID => {:type => ::Thrift::Types::I64, :name => 'toEventId', :optional => true}, |
| LIMIT => {:type => ::Thrift::Types::I64, :name => 'limit', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fromEventId is unset!') unless @fromEventId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NotificationEventsCountResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EVENTSCOUNT = 1 |
| |
| FIELDS = { |
| EVENTSCOUNT => {:type => ::Thrift::Types::I64, :name => 'eventsCount'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field eventsCount is unset!') unless @eventsCount |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class InsertEventRequestData |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| REPLACE = 1 |
| FILESADDED = 2 |
| FILESADDEDCHECKSUM = 3 |
| SUBDIRECTORYLIST = 4 |
| PARTITIONVAL = 5 |
| |
| FIELDS = { |
| REPLACE => {:type => ::Thrift::Types::BOOL, :name => 'replace', :optional => true}, |
| FILESADDED => {:type => ::Thrift::Types::LIST, :name => 'filesAdded', :element => {:type => ::Thrift::Types::STRING}}, |
| FILESADDEDCHECKSUM => {:type => ::Thrift::Types::LIST, :name => 'filesAddedChecksum', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| SUBDIRECTORYLIST => {:type => ::Thrift::Types::LIST, :name => 'subDirectoryList', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PARTITIONVAL => {:type => ::Thrift::Types::LIST, :name => 'partitionVal', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field filesAdded is unset!') unless @filesAdded |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class FireEventRequestData < ::Thrift::Union |
| include ::Thrift::Struct_Union |
| class << self |
| def insertData(val) |
| FireEventRequestData.new(:insertData, val) |
| end |
| |
| def insertDatas(val) |
| FireEventRequestData.new(:insertDatas, val) |
| end |
| end |
| |
| INSERTDATA = 1 |
| INSERTDATAS = 2 |
| |
| FIELDS = { |
| INSERTDATA => {:type => ::Thrift::Types::STRUCT, :name => 'insertData', :class => ::InsertEventRequestData}, |
| INSERTDATAS => {:type => ::Thrift::Types::LIST, :name => 'insertDatas', :element => {:type => ::Thrift::Types::STRUCT, :class => ::InsertEventRequestData}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise(StandardError, 'Union fields are not set.') if get_set_field.nil? || get_value.nil? |
| end |
| |
| ::Thrift::Union.generate_accessors self |
| end |
| |
| class FireEventRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SUCCESSFUL = 1 |
| DATA = 2 |
| DBNAME = 3 |
| TABLENAME = 4 |
| PARTITIONVALS = 5 |
| CATNAME = 6 |
| |
| FIELDS = { |
| SUCCESSFUL => {:type => ::Thrift::Types::BOOL, :name => 'successful'}, |
| DATA => {:type => ::Thrift::Types::STRUCT, :name => 'data', :class => ::FireEventRequestData}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName', :optional => true}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :optional => true}, |
| PARTITIONVALS => {:type => ::Thrift::Types::LIST, :name => 'partitionVals', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field successful is unset!') if @successful.nil? |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field data is unset!') unless @data |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class FireEventResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| EVENTIDS = 1 |
| |
| FIELDS = { |
| EVENTIDS => {:type => ::Thrift::Types::LIST, :name => 'eventIds', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WriteNotificationLogRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TXNID = 1 |
| WRITEID = 2 |
| DB = 3 |
| TABLE = 4 |
| FILEINFO = 5 |
| PARTITIONVALS = 6 |
| |
| FIELDS = { |
| TXNID => {:type => ::Thrift::Types::I64, :name => 'txnId'}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId'}, |
| DB => {:type => ::Thrift::Types::STRING, :name => 'db'}, |
| TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, |
| FILEINFO => {:type => ::Thrift::Types::STRUCT, :name => 'fileInfo', :class => ::InsertEventRequestData}, |
| PARTITIONVALS => {:type => ::Thrift::Types::LIST, :name => 'partitionVals', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnId is unset!') unless @txnId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field writeId is unset!') unless @writeId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db is unset!') unless @db |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field table is unset!') unless @table |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fileInfo is unset!') unless @fileInfo |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WriteNotificationLogResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class MetadataPpdResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| METADATA = 1 |
| INCLUDEBITSET = 2 |
| |
| FIELDS = { |
| METADATA => {:type => ::Thrift::Types::STRING, :name => 'metadata', :binary => true, :optional => true}, |
| INCLUDEBITSET => {:type => ::Thrift::Types::STRING, :name => 'includeBitset', :binary => true, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetFileMetadataByExprResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| METADATA = 1 |
| ISSUPPORTED = 2 |
| |
| FIELDS = { |
| METADATA => {:type => ::Thrift::Types::MAP, :name => 'metadata', :key => {:type => ::Thrift::Types::I64}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::MetadataPpdResult}}, |
| ISSUPPORTED => {:type => ::Thrift::Types::BOOL, :name => 'isSupported'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field metadata is unset!') unless @metadata |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isSupported is unset!') if @isSupported.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetFileMetadataByExprRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FILEIDS = 1 |
| EXPR = 2 |
| DOGETFOOTERS = 3 |
| TYPE = 4 |
| |
| FIELDS = { |
| FILEIDS => {:type => ::Thrift::Types::LIST, :name => 'fileIds', :element => {:type => ::Thrift::Types::I64}}, |
| EXPR => {:type => ::Thrift::Types::STRING, :name => 'expr', :binary => true}, |
| DOGETFOOTERS => {:type => ::Thrift::Types::BOOL, :name => 'doGetFooters', :optional => true}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :optional => true, :enum_class => ::FileMetadataExprType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fileIds is unset!') unless @fileIds |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field expr is unset!') unless @expr |
| unless @type.nil? || ::FileMetadataExprType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetFileMetadataResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| METADATA = 1 |
| ISSUPPORTED = 2 |
| |
| FIELDS = { |
| METADATA => {:type => ::Thrift::Types::MAP, :name => 'metadata', :key => {:type => ::Thrift::Types::I64}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}, |
| ISSUPPORTED => {:type => ::Thrift::Types::BOOL, :name => 'isSupported'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field metadata is unset!') unless @metadata |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isSupported is unset!') if @isSupported.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetFileMetadataRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FILEIDS = 1 |
| |
| FIELDS = { |
| FILEIDS => {:type => ::Thrift::Types::LIST, :name => 'fileIds', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fileIds is unset!') unless @fileIds |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PutFileMetadataResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class PutFileMetadataRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FILEIDS = 1 |
| METADATA = 2 |
| TYPE = 3 |
| |
| FIELDS = { |
| FILEIDS => {:type => ::Thrift::Types::LIST, :name => 'fileIds', :element => {:type => ::Thrift::Types::I64}}, |
| METADATA => {:type => ::Thrift::Types::LIST, :name => 'metadata', :element => {:type => ::Thrift::Types::STRING, :binary => true}}, |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :optional => true, :enum_class => ::FileMetadataExprType} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fileIds is unset!') unless @fileIds |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field metadata is unset!') unless @metadata |
| unless @type.nil? || ::FileMetadataExprType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ClearFileMetadataResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ClearFileMetadataRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FILEIDS = 1 |
| |
| FIELDS = { |
| FILEIDS => {:type => ::Thrift::Types::LIST, :name => 'fileIds', :element => {:type => ::Thrift::Types::I64}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field fileIds is unset!') unless @fileIds |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CacheFileMetadataResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ISSUPPORTED = 1 |
| |
| FIELDS = { |
| ISSUPPORTED => {:type => ::Thrift::Types::BOOL, :name => 'isSupported'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isSupported is unset!') if @isSupported.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CacheFileMetadataRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| PARTNAME = 3 |
| ISALLPARTS = 4 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| PARTNAME => {:type => ::Thrift::Types::STRING, :name => 'partName', :optional => true}, |
| ISALLPARTS => {:type => ::Thrift::Types::BOOL, :name => 'isAllParts', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetAllFunctionsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FUNCTIONS = 1 |
| |
| FIELDS = { |
| FUNCTIONS => {:type => ::Thrift::Types::LIST, :name => 'functions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Function}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ClientCapabilities |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| VALUES = 1 |
| |
| FIELDS = { |
| VALUES => {:type => ::Thrift::Types::LIST, :name => 'values', :element => {:type => ::Thrift::Types::I32, :enum_class => ::ClientCapability}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field values is unset!') unless @values |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetTableRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAME = 2 |
| CAPABILITIES = 3 |
| CATNAME = 4 |
| VALIDWRITEIDLIST = 6 |
| GETCOLUMNSTATS = 7 |
| PROCESSORCAPABILITIES = 8 |
| PROCESSORIDENTIFIER = 9 |
| ENGINE = 10 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| CAPABILITIES => {:type => ::Thrift::Types::STRUCT, :name => 'capabilities', :class => ::ClientCapabilities, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true}, |
| GETCOLUMNSTATS => {:type => ::Thrift::Types::BOOL, :name => 'getColumnStats', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true}, |
| ENGINE => {:type => ::Thrift::Types::STRING, :name => 'engine', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetTableResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLE = 1 |
| ISSTATSCOMPLIANT = 2 |
| |
| FIELDS = { |
| TABLE => {:type => ::Thrift::Types::STRUCT, :name => 'table', :class => ::Table}, |
| ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field table is unset!') unless @table |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetTablesRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TBLNAMES = 2 |
| CAPABILITIES = 3 |
| CATNAME = 4 |
| PROCESSORCAPABILITIES = 5 |
| PROCESSORIDENTIFIER = 6 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAMES => {:type => ::Thrift::Types::LIST, :name => 'tblNames', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| CAPABILITIES => {:type => ::Thrift::Types::STRUCT, :name => 'capabilities', :class => ::ClientCapabilities, :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetTablesResult |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLES = 1 |
| |
| FIELDS = { |
| TABLES => {:type => ::Thrift::Types::LIST, :name => 'tables', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Table}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tables is unset!') unless @tables |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetTablesExtRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATALOG = 1 |
| DATABASE = 2 |
| TABLENAMEPATTERN = 3 |
| REQUESTEDFIELDS = 4 |
| LIMIT = 5 |
| PROCESSORCAPABILITIES = 6 |
| PROCESSORIDENTIFIER = 7 |
| |
| FIELDS = { |
| CATALOG => {:type => ::Thrift::Types::STRING, :name => 'catalog'}, |
| DATABASE => {:type => ::Thrift::Types::STRING, :name => 'database'}, |
| TABLENAMEPATTERN => {:type => ::Thrift::Types::STRING, :name => 'tableNamePattern'}, |
| REQUESTEDFIELDS => {:type => ::Thrift::Types::I32, :name => 'requestedFields'}, |
| LIMIT => {:type => ::Thrift::Types::I32, :name => 'limit', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field catalog is unset!') unless @catalog |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field database is unset!') unless @database |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableNamePattern is unset!') unless @tableNamePattern |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field requestedFields is unset!') unless @requestedFields |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ExtendedTableInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TBLNAME = 1 |
| ACCESSTYPE = 2 |
| REQUIREDREADCAPABILITIES = 3 |
| REQUIREDWRITECAPABILITIES = 4 |
| |
| FIELDS = { |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| ACCESSTYPE => {:type => ::Thrift::Types::I32, :name => 'accessType', :optional => true}, |
| REQUIREDREADCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'requiredReadCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| REQUIREDWRITECAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'requiredWriteCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tblName is unset!') unless @tblName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetDatabaseRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| CATALOGNAME = 2 |
| PROCESSORCAPABILITIES = 3 |
| PROCESSORIDENTIFIER = 4 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name', :optional => true}, |
| CATALOGNAME => {:type => ::Thrift::Types::STRING, :name => 'catalogName', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CmRecycleRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DATAPATH = 1 |
| PURGE = 2 |
| |
| FIELDS = { |
| DATAPATH => {:type => ::Thrift::Types::STRING, :name => 'dataPath'}, |
| PURGE => {:type => ::Thrift::Types::BOOL, :name => 'purge'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dataPath is unset!') unless @dataPath |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field purge is unset!') if @purge.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CmRecycleResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TableMeta |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| DBNAME = 1 |
| TABLENAME = 2 |
| TABLETYPE = 3 |
| COMMENTS = 4 |
| CATNAME = 5 |
| |
| FIELDS = { |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| TABLETYPE => {:type => ::Thrift::Types::STRING, :name => 'tableType'}, |
| COMMENTS => {:type => ::Thrift::Types::STRING, :name => 'comments', :optional => true}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableType is unset!') unless @tableType |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class Materialization |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SOURCETABLESUPDATEDELETEMODIFIED = 1 |
| |
| FIELDS = { |
| SOURCETABLESUPDATEDELETEMODIFIED => {:type => ::Thrift::Types::BOOL, :name => 'sourceTablesUpdateDeleteModified'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field sourceTablesUpdateDeleteModified is unset!') if @sourceTablesUpdateDeleteModified.nil? |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMResourcePlan |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| STATUS = 2 |
| QUERYPARALLELISM = 3 |
| DEFAULTPOOLPATH = 4 |
| NS = 5 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| STATUS => {:type => ::Thrift::Types::I32, :name => 'status', :optional => true, :enum_class => ::WMResourcePlanStatus}, |
| QUERYPARALLELISM => {:type => ::Thrift::Types::I32, :name => 'queryParallelism', :optional => true}, |
| DEFAULTPOOLPATH => {:type => ::Thrift::Types::STRING, :name => 'defaultPoolPath', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field name is unset!') unless @name |
| unless @status.nil? || ::WMResourcePlanStatus::VALID_VALUES.include?(@status) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field status!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMNullableResourcePlan |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| STATUS = 2 |
| QUERYPARALLELISM = 4 |
| ISSETQUERYPARALLELISM = 5 |
| DEFAULTPOOLPATH = 6 |
| ISSETDEFAULTPOOLPATH = 7 |
| NS = 8 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name', :optional => true}, |
| STATUS => {:type => ::Thrift::Types::I32, :name => 'status', :optional => true, :enum_class => ::WMResourcePlanStatus}, |
| QUERYPARALLELISM => {:type => ::Thrift::Types::I32, :name => 'queryParallelism', :optional => true}, |
| ISSETQUERYPARALLELISM => {:type => ::Thrift::Types::BOOL, :name => 'isSetQueryParallelism', :optional => true}, |
| DEFAULTPOOLPATH => {:type => ::Thrift::Types::STRING, :name => 'defaultPoolPath', :optional => true}, |
| ISSETDEFAULTPOOLPATH => {:type => ::Thrift::Types::BOOL, :name => 'isSetDefaultPoolPath', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @status.nil? || ::WMResourcePlanStatus::VALID_VALUES.include?(@status) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field status!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMPool |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| POOLPATH = 2 |
| ALLOCFRACTION = 3 |
| QUERYPARALLELISM = 4 |
| SCHEDULINGPOLICY = 5 |
| NS = 6 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName'}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath'}, |
| ALLOCFRACTION => {:type => ::Thrift::Types::DOUBLE, :name => 'allocFraction', :optional => true}, |
| QUERYPARALLELISM => {:type => ::Thrift::Types::I32, :name => 'queryParallelism', :optional => true}, |
| SCHEDULINGPOLICY => {:type => ::Thrift::Types::STRING, :name => 'schedulingPolicy', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field resourcePlanName is unset!') unless @resourcePlanName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field poolPath is unset!') unless @poolPath |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMNullablePool |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| POOLPATH = 2 |
| ALLOCFRACTION = 3 |
| QUERYPARALLELISM = 4 |
| SCHEDULINGPOLICY = 5 |
| ISSETSCHEDULINGPOLICY = 6 |
| NS = 7 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName'}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath'}, |
| ALLOCFRACTION => {:type => ::Thrift::Types::DOUBLE, :name => 'allocFraction', :optional => true}, |
| QUERYPARALLELISM => {:type => ::Thrift::Types::I32, :name => 'queryParallelism', :optional => true}, |
| SCHEDULINGPOLICY => {:type => ::Thrift::Types::STRING, :name => 'schedulingPolicy', :optional => true}, |
| ISSETSCHEDULINGPOLICY => {:type => ::Thrift::Types::BOOL, :name => 'isSetSchedulingPolicy', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field resourcePlanName is unset!') unless @resourcePlanName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field poolPath is unset!') unless @poolPath |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMTrigger |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| TRIGGERNAME = 2 |
| TRIGGEREXPRESSION = 3 |
| ACTIONEXPRESSION = 4 |
| ISINUNMANAGED = 5 |
| NS = 6 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName'}, |
| TRIGGERNAME => {:type => ::Thrift::Types::STRING, :name => 'triggerName'}, |
| TRIGGEREXPRESSION => {:type => ::Thrift::Types::STRING, :name => 'triggerExpression', :optional => true}, |
| ACTIONEXPRESSION => {:type => ::Thrift::Types::STRING, :name => 'actionExpression', :optional => true}, |
| ISINUNMANAGED => {:type => ::Thrift::Types::BOOL, :name => 'isInUnmanaged', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field resourcePlanName is unset!') unless @resourcePlanName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field triggerName is unset!') unless @triggerName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMMapping |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| ENTITYTYPE = 2 |
| ENTITYNAME = 3 |
| POOLPATH = 4 |
| ORDERING = 5 |
| NS = 6 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName'}, |
| ENTITYTYPE => {:type => ::Thrift::Types::STRING, :name => 'entityType'}, |
| ENTITYNAME => {:type => ::Thrift::Types::STRING, :name => 'entityName'}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath', :optional => true}, |
| ORDERING => {:type => ::Thrift::Types::I32, :name => 'ordering', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field resourcePlanName is unset!') unless @resourcePlanName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field entityType is unset!') unless @entityType |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field entityName is unset!') unless @entityName |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMPoolTrigger |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| POOL = 1 |
| TRIGGER = 2 |
| NS = 3 |
| |
| FIELDS = { |
| POOL => {:type => ::Thrift::Types::STRING, :name => 'pool'}, |
| TRIGGER => {:type => ::Thrift::Types::STRING, :name => 'trigger'}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field pool is unset!') unless @pool |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field trigger is unset!') unless @trigger |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMFullResourcePlan |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PLAN = 1 |
| POOLS = 2 |
| MAPPINGS = 3 |
| TRIGGERS = 4 |
| POOLTRIGGERS = 5 |
| |
| FIELDS = { |
| PLAN => {:type => ::Thrift::Types::STRUCT, :name => 'plan', :class => ::WMResourcePlan}, |
| POOLS => {:type => ::Thrift::Types::LIST, :name => 'pools', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMPool}}, |
| MAPPINGS => {:type => ::Thrift::Types::LIST, :name => 'mappings', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMMapping}, :optional => true}, |
| TRIGGERS => {:type => ::Thrift::Types::LIST, :name => 'triggers', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMTrigger}, :optional => true}, |
| POOLTRIGGERS => {:type => ::Thrift::Types::LIST, :name => 'poolTriggers', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMPoolTrigger}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field plan is unset!') unless @plan |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field pools is unset!') unless @pools |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLAN = 1 |
| COPYFROM = 2 |
| |
| FIELDS = { |
| RESOURCEPLAN => {:type => ::Thrift::Types::STRUCT, :name => 'resourcePlan', :class => ::WMResourcePlan, :optional => true}, |
| COPYFROM => {:type => ::Thrift::Types::STRING, :name => 'copyFrom', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetActiveResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NS = 1 |
| |
| FIELDS = { |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetActiveResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLAN = 1 |
| |
| FIELDS = { |
| RESOURCEPLAN => {:type => ::Thrift::Types::STRUCT, :name => 'resourcePlan', :class => ::WMFullResourcePlan, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| NS = 2 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLAN = 1 |
| |
| FIELDS = { |
| RESOURCEPLAN => {:type => ::Thrift::Types::STRUCT, :name => 'resourcePlan', :class => ::WMFullResourcePlan, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetAllResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NS = 1 |
| |
| FIELDS = { |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetAllResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANS = 1 |
| |
| FIELDS = { |
| RESOURCEPLANS => {:type => ::Thrift::Types::LIST, :name => 'resourcePlans', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMResourcePlan}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| RESOURCEPLAN = 2 |
| ISENABLEANDACTIVATE = 3 |
| ISFORCEDEACTIVATE = 4 |
| ISREPLACE = 5 |
| NS = 6 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| RESOURCEPLAN => {:type => ::Thrift::Types::STRUCT, :name => 'resourcePlan', :class => ::WMNullableResourcePlan, :optional => true}, |
| ISENABLEANDACTIVATE => {:type => ::Thrift::Types::BOOL, :name => 'isEnableAndActivate', :optional => true}, |
| ISFORCEDEACTIVATE => {:type => ::Thrift::Types::BOOL, :name => 'isForceDeactivate', :optional => true}, |
| ISREPLACE => {:type => ::Thrift::Types::BOOL, :name => 'isReplace', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FULLRESOURCEPLAN = 1 |
| |
| FIELDS = { |
| FULLRESOURCEPLAN => {:type => ::Thrift::Types::STRUCT, :name => 'fullResourcePlan', :class => ::WMFullResourcePlan, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMValidateResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| NS = 2 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMValidateResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| ERRORS = 1 |
| WARNINGS = 2 |
| |
| FIELDS = { |
| ERRORS => {:type => ::Thrift::Types::LIST, :name => 'errors', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| WARNINGS => {:type => ::Thrift::Types::LIST, :name => 'warnings', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropResourcePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| NS = 2 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropResourcePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateTriggerRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TRIGGER = 1 |
| |
| FIELDS = { |
| TRIGGER => {:type => ::Thrift::Types::STRUCT, :name => 'trigger', :class => ::WMTrigger, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateTriggerResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterTriggerRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TRIGGER = 1 |
| |
| FIELDS = { |
| TRIGGER => {:type => ::Thrift::Types::STRUCT, :name => 'trigger', :class => ::WMTrigger, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterTriggerResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropTriggerRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| TRIGGERNAME = 2 |
| NS = 3 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| TRIGGERNAME => {:type => ::Thrift::Types::STRING, :name => 'triggerName', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropTriggerResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetTriggersForResourePlanRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| NS = 2 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMGetTriggersForResourePlanResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TRIGGERS = 1 |
| |
| FIELDS = { |
| TRIGGERS => {:type => ::Thrift::Types::LIST, :name => 'triggers', :element => {:type => ::Thrift::Types::STRUCT, :class => ::WMTrigger}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreatePoolRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| POOL = 1 |
| |
| FIELDS = { |
| POOL => {:type => ::Thrift::Types::STRUCT, :name => 'pool', :class => ::WMPool, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreatePoolResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterPoolRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| POOL = 1 |
| POOLPATH = 2 |
| |
| FIELDS = { |
| POOL => {:type => ::Thrift::Types::STRUCT, :name => 'pool', :class => ::WMNullablePool, :optional => true}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMAlterPoolResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropPoolRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| POOLPATH = 2 |
| NS = 3 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropPoolResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateOrUpdateMappingRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MAPPING = 1 |
| UPDATE = 2 |
| |
| FIELDS = { |
| MAPPING => {:type => ::Thrift::Types::STRUCT, :name => 'mapping', :class => ::WMMapping, :optional => true}, |
| UPDATE => {:type => ::Thrift::Types::BOOL, :name => 'update', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateOrUpdateMappingResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropMappingRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MAPPING = 1 |
| |
| FIELDS = { |
| MAPPING => {:type => ::Thrift::Types::STRUCT, :name => 'mapping', :class => ::WMMapping, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMDropMappingResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateOrDropTriggerToPoolMappingRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| RESOURCEPLANNAME = 1 |
| TRIGGERNAME = 2 |
| POOLPATH = 3 |
| DROP = 4 |
| NS = 5 |
| |
| FIELDS = { |
| RESOURCEPLANNAME => {:type => ::Thrift::Types::STRING, :name => 'resourcePlanName', :optional => true}, |
| TRIGGERNAME => {:type => ::Thrift::Types::STRING, :name => 'triggerName', :optional => true}, |
| POOLPATH => {:type => ::Thrift::Types::STRING, :name => 'poolPath', :optional => true}, |
| DROP => {:type => ::Thrift::Types::BOOL, :name => 'drop', :optional => true}, |
| NS => {:type => ::Thrift::Types::STRING, :name => 'ns', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class WMCreateOrDropTriggerToPoolMappingResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ISchema |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMATYPE = 1 |
| NAME = 2 |
| CATNAME = 3 |
| DBNAME = 4 |
| COMPATIBILITY = 5 |
| VALIDATIONLEVEL = 6 |
| CANEVOLVE = 7 |
| SCHEMAGROUP = 8 |
| DESCRIPTION = 9 |
| |
| FIELDS = { |
| SCHEMATYPE => {:type => ::Thrift::Types::I32, :name => 'schemaType', :enum_class => ::SchemaType}, |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| COMPATIBILITY => {:type => ::Thrift::Types::I32, :name => 'compatibility', :enum_class => ::SchemaCompatibility}, |
| VALIDATIONLEVEL => {:type => ::Thrift::Types::I32, :name => 'validationLevel', :enum_class => ::SchemaValidation}, |
| CANEVOLVE => {:type => ::Thrift::Types::BOOL, :name => 'canEvolve'}, |
| SCHEMAGROUP => {:type => ::Thrift::Types::STRING, :name => 'schemaGroup', :optional => true}, |
| DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @schemaType.nil? || ::SchemaType::VALID_VALUES.include?(@schemaType) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field schemaType!') |
| end |
| unless @compatibility.nil? || ::SchemaCompatibility::VALID_VALUES.include?(@compatibility) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field compatibility!') |
| end |
| unless @validationLevel.nil? || ::SchemaValidation::VALID_VALUES.include?(@validationLevel) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field validationLevel!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ISchemaName |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| SCHEMANAME = 3 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName'}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| SCHEMANAME => {:type => ::Thrift::Types::STRING, :name => 'schemaName'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterISchemaRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| NAME = 1 |
| NEWSCHEMA = 3 |
| |
| FIELDS = { |
| NAME => {:type => ::Thrift::Types::STRUCT, :name => 'name', :class => ::ISchemaName}, |
| NEWSCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'newSchema', :class => ::ISchema} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SchemaVersion |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMA = 1 |
| VERSION = 2 |
| CREATEDAT = 3 |
| COLS = 4 |
| STATE = 5 |
| DESCRIPTION = 6 |
| SCHEMATEXT = 7 |
| FINGERPRINT = 8 |
| NAME = 9 |
| SERDE = 10 |
| |
| FIELDS = { |
| SCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'schema', :class => ::ISchemaName}, |
| VERSION => {:type => ::Thrift::Types::I32, :name => 'version'}, |
| CREATEDAT => {:type => ::Thrift::Types::I64, :name => 'createdAt'}, |
| COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :optional => true, :enum_class => ::SchemaVersionState}, |
| DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true}, |
| SCHEMATEXT => {:type => ::Thrift::Types::STRING, :name => 'schemaText', :optional => true}, |
| FINGERPRINT => {:type => ::Thrift::Types::STRING, :name => 'fingerprint', :optional => true}, |
| NAME => {:type => ::Thrift::Types::STRING, :name => 'name', :optional => true}, |
| SERDE => {:type => ::Thrift::Types::STRUCT, :name => 'serDe', :class => ::SerDeInfo, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @state.nil? || ::SchemaVersionState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SchemaVersionDescriptor |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMA = 1 |
| VERSION = 2 |
| |
| FIELDS = { |
| SCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'schema', :class => ::ISchemaName}, |
| VERSION => {:type => ::Thrift::Types::I32, :name => 'version'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class FindSchemasByColsRqst |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| COLNAME = 1 |
| COLNAMESPACE = 2 |
| TYPE = 3 |
| |
| FIELDS = { |
| COLNAME => {:type => ::Thrift::Types::STRING, :name => 'colName', :optional => true}, |
| COLNAMESPACE => {:type => ::Thrift::Types::STRING, :name => 'colNamespace', :optional => true}, |
| TYPE => {:type => ::Thrift::Types::STRING, :name => 'type', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class FindSchemasByColsResp |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMAVERSIONS = 1 |
| |
| FIELDS = { |
| SCHEMAVERSIONS => {:type => ::Thrift::Types::LIST, :name => 'schemaVersions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SchemaVersionDescriptor}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class MapSchemaVersionToSerdeRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMAVERSION = 1 |
| SERDENAME = 2 |
| |
| FIELDS = { |
| SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor}, |
| SERDENAME => {:type => ::Thrift::Types::STRING, :name => 'serdeName'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class SetSchemaVersionStateRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEMAVERSION = 1 |
| STATE = 2 |
| |
| FIELDS = { |
| SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::SchemaVersionState} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @state.nil? || ::SchemaVersionState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetSerdeRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SERDENAME = 1 |
| |
| FIELDS = { |
| SERDENAME => {:type => ::Thrift::Types::STRING, :name => 'serdeName'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class RuntimeStat |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CREATETIME = 1 |
| WEIGHT = 2 |
| PAYLOAD = 3 |
| |
| FIELDS = { |
| CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime', :optional => true}, |
| WEIGHT => {:type => ::Thrift::Types::I32, :name => 'weight'}, |
| PAYLOAD => {:type => ::Thrift::Types::STRING, :name => 'payload', :binary => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field weight is unset!') unless @weight |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field payload is unset!') unless @payload |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetRuntimeStatsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| MAXWEIGHT = 1 |
| MAXCREATETIME = 2 |
| |
| FIELDS = { |
| MAXWEIGHT => {:type => ::Thrift::Types::I32, :name => 'maxWeight'}, |
| MAXCREATETIME => {:type => ::Thrift::Types::I32, :name => 'maxCreateTime'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field maxWeight is unset!') unless @maxWeight |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field maxCreateTime is unset!') unless @maxCreateTime |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class CreateTableRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TABLE = 1 |
| ENVCONTEXT = 2 |
| PRIMARYKEYS = 3 |
| FOREIGNKEYS = 4 |
| UNIQUECONSTRAINTS = 5 |
| NOTNULLCONSTRAINTS = 6 |
| DEFAULTCONSTRAINTS = 7 |
| CHECKCONSTRAINTS = 8 |
| PROCESSORCAPABILITIES = 9 |
| PROCESSORIDENTIFIER = 10 |
| |
| FIELDS = { |
| TABLE => {:type => ::Thrift::Types::STRUCT, :name => 'table', :class => ::Table}, |
| ENVCONTEXT => {:type => ::Thrift::Types::STRUCT, :name => 'envContext', :class => ::EnvironmentContext, :optional => true}, |
| PRIMARYKEYS => {:type => ::Thrift::Types::LIST, :name => 'primaryKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLPrimaryKey}, :optional => true}, |
| FOREIGNKEYS => {:type => ::Thrift::Types::LIST, :name => 'foreignKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLForeignKey}, :optional => true}, |
| UNIQUECONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'uniqueConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLUniqueConstraint}, :optional => true}, |
| NOTNULLCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'notNullConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLNotNullConstraint}, :optional => true}, |
| DEFAULTCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'defaultConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLDefaultConstraint}, :optional => true}, |
| CHECKCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'checkConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLCheckConstraint}, :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field table is unset!') unless @table |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQueryPollRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CLUSTERNAMESPACE = 1 |
| |
| FIELDS = { |
| CLUSTERNAMESPACE => {:type => ::Thrift::Types::STRING, :name => 'clusterNamespace'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field clusterNamespace is unset!') unless @clusterNamespace |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQueryKey |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEDULENAME = 1 |
| CLUSTERNAMESPACE = 2 |
| |
| FIELDS = { |
| SCHEDULENAME => {:type => ::Thrift::Types::STRING, :name => 'scheduleName'}, |
| CLUSTERNAMESPACE => {:type => ::Thrift::Types::STRING, :name => 'clusterNamespace'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field scheduleName is unset!') unless @scheduleName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field clusterNamespace is unset!') unless @clusterNamespace |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQueryPollResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEDULEKEY = 1 |
| EXECUTIONID = 2 |
| QUERY = 3 |
| USER = 4 |
| |
| FIELDS = { |
| SCHEDULEKEY => {:type => ::Thrift::Types::STRUCT, :name => 'scheduleKey', :class => ::ScheduledQueryKey, :optional => true}, |
| EXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'executionId', :optional => true}, |
| QUERY => {:type => ::Thrift::Types::STRING, :name => 'query', :optional => true}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQuery |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEDULEKEY = 1 |
| ENABLED = 2 |
| SCHEDULE = 4 |
| USER = 5 |
| QUERY = 6 |
| NEXTEXECUTION = 7 |
| |
| FIELDS = { |
| SCHEDULEKEY => {:type => ::Thrift::Types::STRUCT, :name => 'scheduleKey', :class => ::ScheduledQueryKey}, |
| ENABLED => {:type => ::Thrift::Types::BOOL, :name => 'enabled', :optional => true}, |
| SCHEDULE => {:type => ::Thrift::Types::STRING, :name => 'schedule', :optional => true}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user', :optional => true}, |
| QUERY => {:type => ::Thrift::Types::STRING, :name => 'query', :optional => true}, |
| NEXTEXECUTION => {:type => ::Thrift::Types::I32, :name => 'nextExecution', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field scheduleKey is unset!') unless @scheduleKey |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQueryMaintenanceRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| TYPE = 1 |
| SCHEDULEDQUERY = 2 |
| |
| FIELDS = { |
| TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::ScheduledQueryMaintenanceRequestType}, |
| SCHEDULEDQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'scheduledQuery', :class => ::ScheduledQuery} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field scheduledQuery is unset!') unless @scheduledQuery |
| unless @type.nil? || ::ScheduledQueryMaintenanceRequestType::VALID_VALUES.include?(@type) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ScheduledQueryProgressInfo |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| SCHEDULEDEXECUTIONID = 1 |
| STATE = 2 |
| EXECUTORQUERYID = 3 |
| ERRORMESSAGE = 4 |
| |
| FIELDS = { |
| SCHEDULEDEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'scheduledExecutionId'}, |
| STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::QueryState}, |
| EXECUTORQUERYID => {:type => ::Thrift::Types::STRING, :name => 'executorQueryId'}, |
| ERRORMESSAGE => {:type => ::Thrift::Types::STRING, :name => 'errorMessage', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field scheduledExecutionId is unset!') unless @scheduledExecutionId |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field executorQueryId is unset!') unless @executorQueryId |
| unless @state.nil? || ::QueryState::VALID_VALUES.include?(@state) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterPartitionsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| PARTITIONS = 4 |
| ENVIRONMENTCONTEXT = 5 |
| WRITEID = 6 |
| VALIDWRITEIDLIST = 7 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}}, |
| ENVIRONMENTCONTEXT => {:type => ::Thrift::Types::STRUCT, :name => 'environmentContext', :class => ::EnvironmentContext, :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitions is unset!') unless @partitions |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterPartitionsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class RenamePartitionRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| PARTVALS = 4 |
| NEWPART = 5 |
| VALIDWRITEIDLIST = 6 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| PARTVALS => {:type => ::Thrift::Types::LIST, :name => 'partVals', :element => {:type => ::Thrift::Types::STRING}}, |
| NEWPART => {:type => ::Thrift::Types::STRUCT, :name => 'newPart', :class => ::Partition}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partVals is unset!') unless @partVals |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field newPart is unset!') unless @newPart |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class RenamePartitionResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterTableRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| TABLENAME = 3 |
| TABLE = 4 |
| ENVIRONMENTCONTEXT = 5 |
| WRITEID = 6 |
| VALIDWRITEIDLIST = 7 |
| PROCESSORCAPABILITIES = 8 |
| PROCESSORIDENTIFIER = 9 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, |
| TABLE => {:type => ::Thrift::Types::STRUCT, :name => 'table', :class => ::Table}, |
| ENVIRONMENTCONTEXT => {:type => ::Thrift::Types::STRUCT, :name => 'environmentContext', :class => ::EnvironmentContext, :optional => true}, |
| WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, |
| VALIDWRITEIDLIST => {:type => ::Thrift::Types::STRING, :name => 'validWriteIdList', :optional => true}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbName is unset!') unless @dbName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tableName is unset!') unless @tableName |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field table is unset!') unless @table |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlterTableResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| |
| FIELDS = { |
| |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsProjectionSpec |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FIELDLIST = 1 |
| INCLUDEPARAMKEYPATTERN = 2 |
| EXCLUDEPARAMKEYPATTERN = 3 |
| |
| FIELDS = { |
| FIELDLIST => {:type => ::Thrift::Types::LIST, :name => 'fieldList', :element => {:type => ::Thrift::Types::STRING}}, |
| INCLUDEPARAMKEYPATTERN => {:type => ::Thrift::Types::STRING, :name => 'includeParamKeyPattern'}, |
| EXCLUDEPARAMKEYPATTERN => {:type => ::Thrift::Types::STRING, :name => 'excludeParamKeyPattern'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsFilterSpec |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| FILTERMODE = 7 |
| FILTERS = 8 |
| |
| FIELDS = { |
| FILTERMODE => {:type => ::Thrift::Types::I32, :name => 'filterMode', :optional => true, :enum_class => ::PartitionFilterMode}, |
| FILTERS => {:type => ::Thrift::Types::LIST, :name => 'filters', :element => {:type => ::Thrift::Types::STRING}, :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| unless @filterMode.nil? || ::PartitionFilterMode::VALID_VALUES.include?(@filterMode) |
| raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field filterMode!') |
| end |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsResponse |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| PARTITIONSPEC = 1 |
| |
| FIELDS = { |
| PARTITIONSPEC => {:type => ::Thrift::Types::LIST, :name => 'partitionSpec', :element => {:type => ::Thrift::Types::STRUCT, :class => ::PartitionSpec}} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class GetPartitionsRequest |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| CATNAME = 1 |
| DBNAME = 2 |
| TBLNAME = 3 |
| WITHAUTH = 4 |
| USER = 5 |
| GROUPNAMES = 6 |
| PROJECTIONSPEC = 7 |
| FILTERSPEC = 8 |
| PROCESSORCAPABILITIES = 9 |
| PROCESSORIDENTIFIER = 10 |
| |
| FIELDS = { |
| CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, |
| DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, |
| TBLNAME => {:type => ::Thrift::Types::STRING, :name => 'tblName'}, |
| WITHAUTH => {:type => ::Thrift::Types::BOOL, :name => 'withAuth', :optional => true}, |
| USER => {:type => ::Thrift::Types::STRING, :name => 'user', :optional => true}, |
| GROUPNAMES => {:type => ::Thrift::Types::LIST, :name => 'groupNames', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROJECTIONSPEC => {:type => ::Thrift::Types::STRUCT, :name => 'projectionSpec', :class => ::GetPartitionsProjectionSpec}, |
| FILTERSPEC => {:type => ::Thrift::Types::STRUCT, :name => 'filterSpec', :class => ::GetPartitionsFilterSpec}, |
| PROCESSORCAPABILITIES => {:type => ::Thrift::Types::LIST, :name => 'processorCapabilities', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, |
| PROCESSORIDENTIFIER => {:type => ::Thrift::Types::STRING, :name => 'processorIdentifier', :optional => true} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class MetaException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UnknownTableException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UnknownDBException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class AlreadyExistsException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class InvalidPartitionException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class UnknownPartitionException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class InvalidObjectException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NoSuchObjectException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class InvalidOperationException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class ConfigValSecurityException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class InvalidInputException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NoSuchTxnException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TxnAbortedException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class TxnOpenException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |
| class NoSuchLockException < ::Thrift::Exception |
| include ::Thrift::Struct, ::Thrift::Struct_Union |
| def initialize(message=nil) |
| super() |
| self.message = message |
| end |
| |
| MESSAGE = 1 |
| |
| FIELDS = { |
| MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'} |
| } |
| |
| def struct_fields; FIELDS; end |
| |
| def validate |
| end |
| |
| ::Thrift::Struct.generate_accessors self |
| end |
| |