[37/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-py/hive_metastore/ThriftHiveMetastore.py
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 2e19105..3963f25 100644
---
a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++
b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1427,6 +1427,111 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def create_ischema(self, schema):
+"""
+Parameters:
+ - schema
+"""
+pass
+
+ def alter_ischema(self, schemaName, newSchema):
+"""
+Parameters:
+ - schemaName
+ - newSchema
+"""
+pass
+
+ def get_ischema(self, schemaName):
+"""
+Parameters:
+ - schemaName
+"""
+pass
+
+ def drop_ischema(self, schemaName):
+"""
+Parameters:
+ - schemaName
+"""
+pass
+
+ def add_schema_version(self, schemaVersion):
+"""
+Parameters:
+ - schemaVersion
+"""
+pass
+
+ def get_schema_version(self, schemaName, version):
+"""
+Parameters:
+ - schemaName
+ - version
+"""
+pass
+
+ def get_schema_latest_version(self, schemaName):
+"""
+Parameters:
+ - schemaName
+"""
+pass
+
+ def get_schema_all_versions(self, schemaName):
+"""
+Parameters:
+ - schemaName
+"""
+pass
+
+ def drop_schema_version(self, schemaName, version):
+"""
+Parameters:
+ - schemaName
+ - version
+"""
+pass
+
+ def get_schemas_by_cols(self, rqst):
+"""
+Parameters:
+ - rqst
+"""
+pass
+
+ def map_schema_version_to_serde(self, schemaName, version, serdeName):
+"""
+Parameters:
+ - schemaName
+ - version
+ - serdeName
+"""
+pass
+
+ def set_schema_version_state(self, schemaName, version, state):
+"""
+Parameters:
+ - schemaName
+ - version
+ - state
+"""
+pass
+
+ def add_serde(self, serde):
+"""
+Parameters:
+ - serde
+"""
+pass
+
+ def get_serde(self, serdeName):
+"""
+Parameters:
+ - serdeName
+"""
+pass
+
class Client(fb303.FacebookService.Client, Iface):
"""
@@ -7958,6 +8063,500 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o4
raise TApplicationException(TApplicationException.MISSING_RESULT,
"create_or_drop_wm_trigger_to_pool_mapping failed: unknown result")
+ def create_ischema(self, schema):
+"""
+Parameters:
+ - schema
+"""
+self.send_create_ischema(schema)
+self.recv_create_ischema()
+
+ def send_create_ischema(self, schema):
+self._oprot.writeMessageBegin('create_ischema', TMessageType.CALL,
self._seqid)
+args = create_ischema_args()
+args.schema = schema
+args.write(self._oprot)
+self._oprot.writeMessageEnd()
+self._oprot.trans.flush()
+
+ def recv_create_ischema(self):
+iprot = self._iprot
+(fname, mtype, rseqid) = iprot.readMessageBegin()
+if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+result = create_ischema_result()
+result.read(iprot)
+iprot.readMessageEnd()
+if result.o1 is not None:
+ raise result.o1
+if result.o2 is not None:
+ raise result.o2
+if result.o3 is not None:
+ raise result.o3
+return
+
+ def alter_ischema(self, schemaName, newSchema):
+"""
+Parameters:
+ - schemaName
+ - newSchema
+"""
+self.send_alter_ischema(schemaName, newSchema)
+self.recv_alter_ischema()
+
+ def send_alter_ischema(self, schemaName, newSchema):
+self._oprot.writeMessageBegin('alter_ischema', TMessageType.CALL,
self._seqid)
+args = alter_ischema_args()
+args.schemaName = schemaName
+args.newSchema = newSchema
+args.write(self._oprot)
+self._oprot.writeMessageEnd()
+self._oprot.trans.flush()
+
+ def recv_alter_ischema(self):
+iprot = self._iprot
+(fname, mtype, rseqid) = iprot.readMessageBegin()
+if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+result = alter_ischema_result()
+result.read(iprot)
+iprot.readMessageEnd()
+if result.o1 is not None:
+ raise result.o1
+if result.o2 is not None:
+ raise result.o2
+return
+
+ def get_ischema(self, schemaName):
+"""
+Parameters:
+ - schemaName
+"""
+self.send_get_ischema(schemaName)
+return self.recv_get_ischema()
+
+ def send_get_ischema(self, schemaName):
+self._oprot.writeMessageBegin('get_ischema', TMessageType.CALL,
self._seqid)
+args = get_ischema_args()
+args.schema
[37/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/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
--
diff --git
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index fc254c6..0c0e408 100644
---
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -2739,11 +2739,83 @@ public class HiveMetaStoreClient implements
IMetaStoreClient, AutoCloseable {
public void createOrDropTriggerToPoolMapping(String resourcePlanName, String
triggerName,
String poolPath, boolean shouldDrop) throws AlreadyExistsException,
NoSuchObjectException,
InvalidObjectException, MetaException, TException {
-WMCreateOrDropTriggerToPoolMappingRequest request = new
WMCreateOrDropTriggerToPoolMappingRequest();
+WMCreateOrDropTriggerToPoolMappingRequest request =
+new WMCreateOrDropTriggerToPoolMappingRequest();
request.setResourcePlanName(resourcePlanName);
request.setTriggerName(triggerName);
request.setPoolPath(poolPath);
request.setDrop(shouldDrop);
client.create_or_drop_wm_trigger_to_pool_mapping(request);
}
+
+ public void createISchema(ISchema schema) throws TException {
+client.create_ischema(schema);
+ }
+
+ @Override
+ public void alterISchema(String schemaName, ISchema newSchema) throws
TException {
+client.alter_ischema(schemaName, newSchema);
+ }
+
+ @Override
+ public ISchema getISchema(String name) throws TException {
+return client.get_ischema(name);
+ }
+
+ @Override
+ public void dropISchema(String name) throws TException {
+client.drop_ischema(name);
+ }
+
+ @Override
+ public void addSchemaVersion(SchemaVersion schemaVersion) throws TException {
+client.add_schema_version(schemaVersion);
+ }
+
+ @Override
+ public SchemaVersion getSchemaVersion(String schemaName, int version) throws
TException {
+return client.get_schema_version(schemaName, version);
+ }
+
+ @Override
+ public SchemaVersion getSchemaLatestVersion(String schemaName) throws
TException {
+return client.get_schema_latest_version(schemaName);
+ }
+
+ @Override
+ public List getSchemaAllVersions(String schemaName) throws
TException {
+return client.get_schema_all_versions(schemaName);
+ }
+
+ @Override
+ public void dropSchemaVersion(String schemaName, int version) throws
TException {
+client.drop_schema_version(schemaName, version);
+ }
+
+ @Override
+ public FindSchemasByColsResp getSchemaByCols(FindSchemasByColsRqst rqst)
throws TException {
+return client.get_schemas_by_cols(rqst);
+ }
+
+ @Override
+ public void mapSchemaVersionToSerde(String schemaName, int version, String
serdeName)
+ throws TException {
+client.map_schema_version_to_serde(schemaName, version, serdeName);
+ }
+
+ @Override
+ public void setSchemaVersionState(String schemaName, int version,
SchemaVersionState state)
+ throws TException {
+client.set_schema_version_state(schemaName, version, state);
+ }
+
+ @Override
+ public void addSerDe(SerDeInfo serDeInfo) throws TException {
+client.add_serde(serDeInfo);
+ }
+
+ @Override
+ public SerDeInfo getSerDe(String serDeName) throws TException {
+return client.get_serde(serDeName);
+ }
}
http://git-wip-us.apache.org/repos/asf/hive/blob/b3cb8526/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
--
diff --git
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
index 573ac01..6e0c1a7 100644
---
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
+++
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
@@ -47,6 +47,8 @@ import org.apache.hadoop.hive.metastore.api.DataOperationType;
import org.apache.hadoop.hive.metastore.api.Database;
import org.apache.hadoop.hive.metastore.api.EnvironmentContext;
import org.apache.hadoop.hive.metastore.api.FieldSchema;
+import org.apache.hadoop.hive.metastore.api.FindSchemasByColsResp;
+import org.apache.hadoop.hive.metastore.api.FindSchemasByColsRqst;
import org.apache.hadoop.hive.metastore.api.FireEventRequest;
import org.apache.hadoop.hive.metastore.api.FireEventResponse;
import org.apache.hadoop.hive.metastore.api.ForeignKeysRequest;
@@ -60,6 +62,7 @@ import
org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse;
import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeResponse;
impor
[37/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/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
--
diff --git
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index fc254c6..0c0e408 100644
---
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -2739,11 +2739,83 @@ public class HiveMetaStoreClient implements
IMetaStoreClient, AutoCloseable {
public void createOrDropTriggerToPoolMapping(String resourcePlanName, String
triggerName,
String poolPath, boolean shouldDrop) throws AlreadyExistsException,
NoSuchObjectException,
InvalidObjectException, MetaException, TException {
-WMCreateOrDropTriggerToPoolMappingRequest request = new
WMCreateOrDropTriggerToPoolMappingRequest();
+WMCreateOrDropTriggerToPoolMappingRequest request =
+new WMCreateOrDropTriggerToPoolMappingRequest();
request.setResourcePlanName(resourcePlanName);
request.setTriggerName(triggerName);
request.setPoolPath(poolPath);
request.setDrop(shouldDrop);
client.create_or_drop_wm_trigger_to_pool_mapping(request);
}
+
+ public void createISchema(ISchema schema) throws TException {
+client.create_ischema(schema);
+ }
+
+ @Override
+ public void alterISchema(String schemaName, ISchema newSchema) throws
TException {
+client.alter_ischema(schemaName, newSchema);
+ }
+
+ @Override
+ public ISchema getISchema(String name) throws TException {
+return client.get_ischema(name);
+ }
+
+ @Override
+ public void dropISchema(String name) throws TException {
+client.drop_ischema(name);
+ }
+
+ @Override
+ public void addSchemaVersion(SchemaVersion schemaVersion) throws TException {
+client.add_schema_version(schemaVersion);
+ }
+
+ @Override
+ public SchemaVersion getSchemaVersion(String schemaName, int version) throws
TException {
+return client.get_schema_version(schemaName, version);
+ }
+
+ @Override
+ public SchemaVersion getSchemaLatestVersion(String schemaName) throws
TException {
+return client.get_schema_latest_version(schemaName);
+ }
+
+ @Override
+ public List getSchemaAllVersions(String schemaName) throws
TException {
+return client.get_schema_all_versions(schemaName);
+ }
+
+ @Override
+ public void dropSchemaVersion(String schemaName, int version) throws
TException {
+client.drop_schema_version(schemaName, version);
+ }
+
+ @Override
+ public FindSchemasByColsResp getSchemaByCols(FindSchemasByColsRqst rqst)
throws TException {
+return client.get_schemas_by_cols(rqst);
+ }
+
+ @Override
+ public void mapSchemaVersionToSerde(String schemaName, int version, String
serdeName)
+ throws TException {
+client.map_schema_version_to_serde(schemaName, version, serdeName);
+ }
+
+ @Override
+ public void setSchemaVersionState(String schemaName, int version,
SchemaVersionState state)
+ throws TException {
+client.set_schema_version_state(schemaName, version, state);
+ }
+
+ @Override
+ public void addSerDe(SerDeInfo serDeInfo) throws TException {
+client.add_serde(serDeInfo);
+ }
+
+ @Override
+ public SerDeInfo getSerDe(String serDeName) throws TException {
+return client.get_serde(serDeName);
+ }
}
http://git-wip-us.apache.org/repos/asf/hive/blob/bd212257/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
--
diff --git
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
index 573ac01..6e0c1a7 100644
---
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
+++
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
@@ -47,6 +47,8 @@ import org.apache.hadoop.hive.metastore.api.DataOperationType;
import org.apache.hadoop.hive.metastore.api.Database;
import org.apache.hadoop.hive.metastore.api.EnvironmentContext;
import org.apache.hadoop.hive.metastore.api.FieldSchema;
+import org.apache.hadoop.hive.metastore.api.FindSchemasByColsResp;
+import org.apache.hadoop.hive.metastore.api.FindSchemasByColsRqst;
import org.apache.hadoop.hive.metastore.api.FireEventRequest;
import org.apache.hadoop.hive.metastore.api.FireEventResponse;
import org.apache.hadoop.hive.metastore.api.ForeignKeysRequest;
@@ -60,6 +62,7 @@ import
org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse;
import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeResponse;
impor
