[40/50] [abbrv] hive git commit: HIVE-17990 Add Thrift and DB storage for Schema Registry objects
http://git-wip-us.apache.org/repos/asf/hive/blob/a9e1acaf/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index d5e3527..4659b79 100644
---
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -404,6 +404,34 @@ import org.slf4j.LoggerFactory;
public WMCreateOrDropTriggerToPoolMappingResponse
create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingRequest
request) throws AlreadyExistsException, NoSuchObjectException,
InvalidObjectException, MetaException, org.apache.thrift.TException;
+public void create_ischema(ISchema schema) throws AlreadyExistsException,
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public void alter_ischema(String schemaName, ISchema newSchema) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public ISchema get_ischema(String schemaName) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public void drop_ischema(String schemaName) throws NoSuchObjectException,
InvalidOperationException, MetaException, org.apache.thrift.TException;
+
+public void add_schema_version(SchemaVersion schemaVersion) throws
AlreadyExistsException, NoSuchObjectException, MetaException,
org.apache.thrift.TException;
+
+public SchemaVersion get_schema_version(String schemaName, int version)
throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public SchemaVersion get_schema_latest_version(String schemaName) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public List get_schema_all_versions(String schemaName)
throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public void drop_schema_version(String schemaName, int version) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+public FindSchemasByColsResp get_schemas_by_cols(FindSchemasByColsRqst
rqst) throws MetaException, org.apache.thrift.TException;
+
+public void map_schema_version_to_serde(String schemaName, int version,
String serdeName) throws NoSuchObjectException, MetaException,
org.apache.thrift.TException;
+
+public void set_schema_version_state(String schemaName, int version,
SchemaVersionState state) throws NoSuchObjectException,
InvalidOperationException, MetaException, org.apache.thrift.TException;
+
+public void add_serde(SerDeInfo serde) throws AlreadyExistsException,
MetaException, org.apache.thrift.TException;
+
+public SerDeInfo get_serde(String serdeName) throws NoSuchObjectException,
MetaException, org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -770,6 +798,34 @@ import org.slf4j.LoggerFactory;
public void
create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingRequest
request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+public void create_ischema(ISchema schema,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void alter_ischema(String schemaName, ISchema newSchema,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void get_ischema(String schemaName,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void drop_ischema(String schemaName,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void add_schema_version(SchemaVersion schemaVersion,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void get_schema_version(String schemaName, int version,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void get_schema_latest_version(String schemaName,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void get_schema_all_versions(String schemaName,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+
+public void drop_schema_version(String schemaName, int
[40/50] [abbrv] hive git commit: HIVE-17990 Add Thrift and DB storage for Schema Registry objects
http://git-wip-us.apache.org/repos/asf/hive/blob/b3cb8526/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
--
diff --git a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
index e78a851..3342454 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -142,6 +142,67 @@ final class EventRequestType {
);
}
+final class SerdeType {
+ const HIVE = 1;
+ const SCHEMA_REGISTRY = 2;
+ static public $__names = array(
+1 => 'HIVE',
+2 => 'SCHEMA_REGISTRY',
+ );
+}
+
+final class SchemaType {
+ const HIVE = 1;
+ const AVRO = 2;
+ static public $__names = array(
+1 => 'HIVE',
+2 => 'AVRO',
+ );
+}
+
+final class SchemaCompatibility {
+ const NONE = 1;
+ const BACKWARD = 2;
+ const FORWARD = 3;
+ const BOTH = 4;
+ static public $__names = array(
+1 => 'NONE',
+2 => 'BACKWARD',
+3 => 'FORWARD',
+4 => 'BOTH',
+ );
+}
+
+final class SchemaValidation {
+ const LATEST = 1;
+ const ALL = 2;
+ static public $__names = array(
+1 => 'LATEST',
+2 => 'ALL',
+ );
+}
+
+final class SchemaVersionState {
+ const INITIATED = 1;
+ const START_REVIEW = 2;
+ const CHANGES_REQUIRED = 3;
+ const REVIEWED = 4;
+ const ENABLED = 5;
+ const DISABLED = 6;
+ const ARCHIVED = 7;
+ const DELETED = 8;
+ static public $__names = array(
+1 => 'INITIATED',
+2 => 'START_REVIEW',
+3 => 'CHANGES_REQUIRED',
+4 => 'REVIEWED',
+5 => 'ENABLED',
+6 => 'DISABLED',
+7 => 'ARCHIVED',
+8 => 'DELETED',
+ );
+}
+
final class FunctionType {
const JAVA = 1;
static public $__names = array(
@@ -4021,6 +4082,22 @@ class SerDeInfo {
* @var array
*/
public $parameters = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var string
+ */
+ public $serializerClass = null;
+ /**
+ * @var string
+ */
+ public $deserializerClass = null;
+ /**
+ * @var int
+ */
+ public $serdeType = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -4045,6 +4122,22 @@ class SerDeInfo {
'type' => TType::STRING,
),
),
+4 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+5 => array(
+ 'var' => 'serializerClass',
+ 'type' => TType::STRING,
+ ),
+6 => array(
+ 'var' => 'deserializerClass',
+ 'type' => TType::STRING,
+ ),
+7 => array(
+ 'var' => 'serdeType',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -4057,6 +4150,18 @@ class SerDeInfo {
if (isset($vals['parameters'])) {
$this->parameters = $vals['parameters'];
}
+ if (isset($vals['description'])) {
+$this->description = $vals['description'];
+ }
+ if (isset($vals['serializerClass'])) {
+$this->serializerClass = $vals['serializerClass'];
+ }
+ if (isset($vals['deserializerClass'])) {
+$this->deserializerClass = $vals['deserializerClass'];
+ }
+ if (isset($vals['serdeType'])) {
+$this->serdeType = $vals['serdeType'];
+ }
}
}
@@ -4113,6 +4218,34 @@ class SerDeInfo {
$xfer += $input->skip($ftype);
}
break;
+case 4:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->description);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 5:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->serializerClass);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 6:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->deserializerClass);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 7:
+ if ($ftype == TType::I32) {
+$xfer += $input->readI32($this->serdeType);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -4154,6 +4287,26 @@ class SerDeInfo {
}
$xfer += $output->writeFieldEnd();
}
+if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 4);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+}
+if ($this->serializerClass !== null) {
+ $xfer += $output->writeFieldBegin('serializerClass', TType::STRING, 5);
+ $xfer += $output->writeString($this->serializerClass);
[40/50] [abbrv] hive git commit: HIVE-17990 Add Thrift and DB storage for Schema Registry objects
http://git-wip-us.apache.org/repos/asf/hive/blob/bd212257/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
--
diff --git a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
index e78a851..3342454 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -142,6 +142,67 @@ final class EventRequestType {
);
}
+final class SerdeType {
+ const HIVE = 1;
+ const SCHEMA_REGISTRY = 2;
+ static public $__names = array(
+1 => 'HIVE',
+2 => 'SCHEMA_REGISTRY',
+ );
+}
+
+final class SchemaType {
+ const HIVE = 1;
+ const AVRO = 2;
+ static public $__names = array(
+1 => 'HIVE',
+2 => 'AVRO',
+ );
+}
+
+final class SchemaCompatibility {
+ const NONE = 1;
+ const BACKWARD = 2;
+ const FORWARD = 3;
+ const BOTH = 4;
+ static public $__names = array(
+1 => 'NONE',
+2 => 'BACKWARD',
+3 => 'FORWARD',
+4 => 'BOTH',
+ );
+}
+
+final class SchemaValidation {
+ const LATEST = 1;
+ const ALL = 2;
+ static public $__names = array(
+1 => 'LATEST',
+2 => 'ALL',
+ );
+}
+
+final class SchemaVersionState {
+ const INITIATED = 1;
+ const START_REVIEW = 2;
+ const CHANGES_REQUIRED = 3;
+ const REVIEWED = 4;
+ const ENABLED = 5;
+ const DISABLED = 6;
+ const ARCHIVED = 7;
+ const DELETED = 8;
+ static public $__names = array(
+1 => 'INITIATED',
+2 => 'START_REVIEW',
+3 => 'CHANGES_REQUIRED',
+4 => 'REVIEWED',
+5 => 'ENABLED',
+6 => 'DISABLED',
+7 => 'ARCHIVED',
+8 => 'DELETED',
+ );
+}
+
final class FunctionType {
const JAVA = 1;
static public $__names = array(
@@ -4021,6 +4082,22 @@ class SerDeInfo {
* @var array
*/
public $parameters = null;
+ /**
+ * @var string
+ */
+ public $description = null;
+ /**
+ * @var string
+ */
+ public $serializerClass = null;
+ /**
+ * @var string
+ */
+ public $deserializerClass = null;
+ /**
+ * @var int
+ */
+ public $serdeType = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -4045,6 +4122,22 @@ class SerDeInfo {
'type' => TType::STRING,
),
),
+4 => array(
+ 'var' => 'description',
+ 'type' => TType::STRING,
+ ),
+5 => array(
+ 'var' => 'serializerClass',
+ 'type' => TType::STRING,
+ ),
+6 => array(
+ 'var' => 'deserializerClass',
+ 'type' => TType::STRING,
+ ),
+7 => array(
+ 'var' => 'serdeType',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -4057,6 +4150,18 @@ class SerDeInfo {
if (isset($vals['parameters'])) {
$this->parameters = $vals['parameters'];
}
+ if (isset($vals['description'])) {
+$this->description = $vals['description'];
+ }
+ if (isset($vals['serializerClass'])) {
+$this->serializerClass = $vals['serializerClass'];
+ }
+ if (isset($vals['deserializerClass'])) {
+$this->deserializerClass = $vals['deserializerClass'];
+ }
+ if (isset($vals['serdeType'])) {
+$this->serdeType = $vals['serdeType'];
+ }
}
}
@@ -4113,6 +4218,34 @@ class SerDeInfo {
$xfer += $input->skip($ftype);
}
break;
+case 4:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->description);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 5:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->serializerClass);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 6:
+ if ($ftype == TType::STRING) {
+$xfer += $input->readString($this->deserializerClass);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
+case 7:
+ if ($ftype == TType::I32) {
+$xfer += $input->readI32($this->serdeType);
+ } else {
+$xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -4154,6 +4287,26 @@ class SerDeInfo {
}
$xfer += $output->writeFieldEnd();
}
+if ($this->description !== null) {
+ $xfer += $output->writeFieldBegin('description', TType::STRING, 4);
+ $xfer += $output->writeString($this->description);
+ $xfer += $output->writeFieldEnd();
+}
+if ($this->serializerClass !== null) {
+ $xfer += $output->writeFieldBegin('serializerClass', TType::STRING, 5);
+ $xfer += $output->writeString($this->serializerClass);
