[46/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-cpp/ThriftHiveMetastore.h
--
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
index bfa17eb..83108d8 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -203,6 +203,20 @@ class ThriftHiveMetastoreIf : virtual public
::facebook::fb303::FacebookService
virtual void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse&
_return, const WMCreateOrUpdateMappingRequest& request) = 0;
virtual void drop_wm_mapping(WMDropMappingResponse& _return, const
WMDropMappingRequest& request) = 0;
virtual void
create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse&
_return, const WMCreateOrDropTriggerToPoolMappingRequest& request) = 0;
+ virtual void create_ischema(const ISchema& schema) = 0;
+ virtual void alter_ischema(const std::string& schemaName, const ISchema&
newSchema) = 0;
+ virtual void get_ischema(ISchema& _return, const std::string& schemaName) =
0;
+ virtual void drop_ischema(const std::string& schemaName) = 0;
+ virtual void add_schema_version(const SchemaVersion& schemaVersion) = 0;
+ virtual void get_schema_version(SchemaVersion& _return, const std::string&
schemaName, const int32_t version) = 0;
+ virtual void get_schema_latest_version(SchemaVersion& _return, const
std::string& schemaName) = 0;
+ virtual void get_schema_all_versions(std::vector & _return,
const std::string& schemaName) = 0;
+ virtual void drop_schema_version(const std::string& schemaName, const
int32_t version) = 0;
+ virtual void get_schemas_by_cols(FindSchemasByColsResp& _return, const
FindSchemasByColsRqst& rqst) = 0;
+ virtual void map_schema_version_to_serde(const std::string& schemaName,
const int32_t version, const std::string& serdeName) = 0;
+ virtual void set_schema_version_state(const std::string& schemaName, const
int32_t version, const SchemaVersionState::type state) = 0;
+ virtual void add_serde(const SerDeInfo& serde) = 0;
+ virtual void get_serde(SerDeInfo& _return, const std::string& serdeName) = 0;
};
class ThriftHiveMetastoreIfFactory : virtual public
::facebook::fb303::FacebookServiceIfFactory {
@@ -803,6 +817,48 @@ class ThriftHiveMetastoreNull : virtual public
ThriftHiveMetastoreIf , virtual p
void
create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse&
/* _return */, const WMCreateOrDropTriggerToPoolMappingRequest& /* request */)
{
return;
}
+ void create_ischema(const ISchema& /* schema */) {
+return;
+ }
+ void alter_ischema(const std::string& /* schemaName */, const ISchema& /*
newSchema */) {
+return;
+ }
+ void get_ischema(ISchema& /* _return */, const std::string& /* schemaName
*/) {
+return;
+ }
+ void drop_ischema(const std::string& /* schemaName */) {
+return;
+ }
+ void add_schema_version(const SchemaVersion& /* schemaVersion */) {
+return;
+ }
+ void get_schema_version(SchemaVersion& /* _return */, const std::string& /*
schemaName */, const int32_t /* version */) {
+return;
+ }
+ void get_schema_latest_version(SchemaVersion& /* _return */, const
std::string& /* schemaName */) {
+return;
+ }
+ void get_schema_all_versions(std::vector & /* _return */,
const std::string& /* schemaName */) {
+return;
+ }
+ void drop_schema_version(const std::string& /* schemaName */, const int32_t
/* version */) {
+return;
+ }
+ void get_schemas_by_cols(FindSchemasByColsResp& /* _return */, const
FindSchemasByColsRqst& /* rqst */) {
+return;
+ }
+ void map_schema_version_to_serde(const std::string& /* schemaName */, const
int32_t /* version */, const std::string& /* serdeName */) {
+return;
+ }
+ void set_schema_version_state(const std::string& /* schemaName */, const
int32_t /* version */, const SchemaVersionState::type /* state */) {
+return;
+ }
+ void add_serde(const SerDeInfo& /* serde */) {
+return;
+ }
+ void get_serde(SerDeInfo& /* _return */, const std::string& /* serdeName */)
{
+return;
+ }
};
typedef struct _ThriftHiveMetastore_getMetaConf_args__isset {
@@ -23160,228 +23216,1917 @@ class
ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult {
};
-class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
::facebook::fb303::FacebookServiceClient {
+typedef struct _ThriftHiveMetastore_create_ischema_args__isset {
+ _ThriftHiveMetastore_create_ischema_args__isset() : schema(false) {}
+ bool schema :1;
+} _ThriftHiveMetastore_create_ischema_args__isset;
+
+class ThriftHiveMetastore_create_ischema_args {
public:
- ThriftHiveMetastoreClient(boost::shared_ptr<
[46/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-cpp/hive_metastore_types.cpp
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
index 913e3cc..f026ff9 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
@@ -149,6 +149,72 @@ const char* _kEventRequestTypeNames[] = {
};
const std::map
_EventRequestType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3,
_kEventRequestTypeValues, _kEventRequestTypeNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+int _kSerdeTypeValues[] = {
+ SerdeType::HIVE,
+ SerdeType::SCHEMA_REGISTRY
+};
+const char* _kSerdeTypeNames[] = {
+ "HIVE",
+ "SCHEMA_REGISTRY"
+};
+const std::map
_SerdeType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSerdeTypeValues, _kSerdeTypeNames), ::apache::thrift::TEnumIterator(-1, NULL,
NULL));
+
+int _kSchemaTypeValues[] = {
+ SchemaType::HIVE,
+ SchemaType::AVRO
+};
+const char* _kSchemaTypeNames[] = {
+ "HIVE",
+ "AVRO"
+};
+const std::map
_SchemaType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSchemaTypeValues, _kSchemaTypeNames), ::apache::thrift::TEnumIterator(-1,
NULL, NULL));
+
+int _kSchemaCompatibilityValues[] = {
+ SchemaCompatibility::NONE,
+ SchemaCompatibility::BACKWARD,
+ SchemaCompatibility::FORWARD,
+ SchemaCompatibility::BOTH
+};
+const char* _kSchemaCompatibilityNames[] = {
+ "NONE",
+ "BACKWARD",
+ "FORWARD",
+ "BOTH"
+};
+const std::map
_SchemaCompatibility_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4,
_kSchemaCompatibilityValues, _kSchemaCompatibilityNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kSchemaValidationValues[] = {
+ SchemaValidation::LATEST,
+ SchemaValidation::ALL
+};
+const char* _kSchemaValidationNames[] = {
+ "LATEST",
+ "ALL"
+};
+const std::map
_SchemaValidation_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSchemaValidationValues, _kSchemaValidationNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kSchemaVersionStateValues[] = {
+ SchemaVersionState::INITIATED,
+ SchemaVersionState::START_REVIEW,
+ SchemaVersionState::CHANGES_REQUIRED,
+ SchemaVersionState::REVIEWED,
+ SchemaVersionState::ENABLED,
+ SchemaVersionState::DISABLED,
+ SchemaVersionState::ARCHIVED,
+ SchemaVersionState::DELETED
+};
+const char* _kSchemaVersionStateNames[] = {
+ "INITIATED",
+ "START_REVIEW",
+ "CHANGES_REQUIRED",
+ "REVIEWED",
+ "ENABLED",
+ "DISABLED",
+ "ARCHIVED",
+ "DELETED"
+};
+const std::map
_SchemaVersionState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8,
_kSchemaVersionStateValues, _kSchemaVersionStateNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
int _kFunctionTypeValues[] = {
FunctionType::JAVA
};
@@ -3999,6 +4065,26 @@ void SerDeInfo::__set_parameters(const
std::map & val)
this->parameters = val;
}
+void SerDeInfo::__set_description(const std::string& val) {
+ this->description = val;
+__isset.description = true;
+}
+
+void SerDeInfo::__set_serializerClass(const std::string& val) {
+ this->serializerClass = val;
+__isset.serializerClass = true;
+}
+
+void SerDeInfo::__set_deserializerClass(const std::string& val) {
+ this->deserializerClass = val;
+__isset.deserializerClass = true;
+}
+
+void SerDeInfo::__set_serdeType(const SerdeType::type val) {
+ this->serdeType = val;
+__isset.serdeType = true;
+}
+
uint32_t SerDeInfo::read(::apache::thrift::protocol::TProtocol* iprot) {
apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
@@ -4059,6 +4145,40 @@ uint32_t
SerDeInfo::read(::apache::thrift::protocol::TProtocol* iprot) {
xfer += iprot->skip(ftype);
}
break;
+ case 4:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->description);
+ this->__isset.description = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 5:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->serializerClass);
+ this->__isset.serializerClass = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 6:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->deserializerClass);
+ this->__isset.deserializerClass = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 7:
+if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast144;
+
[46/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-cpp/hive_metastore_types.cpp
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
index 913e3cc..f026ff9 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
@@ -149,6 +149,72 @@ const char* _kEventRequestTypeNames[] = {
};
const std::map
_EventRequestType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3,
_kEventRequestTypeValues, _kEventRequestTypeNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+int _kSerdeTypeValues[] = {
+ SerdeType::HIVE,
+ SerdeType::SCHEMA_REGISTRY
+};
+const char* _kSerdeTypeNames[] = {
+ "HIVE",
+ "SCHEMA_REGISTRY"
+};
+const std::map
_SerdeType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSerdeTypeValues, _kSerdeTypeNames), ::apache::thrift::TEnumIterator(-1, NULL,
NULL));
+
+int _kSchemaTypeValues[] = {
+ SchemaType::HIVE,
+ SchemaType::AVRO
+};
+const char* _kSchemaTypeNames[] = {
+ "HIVE",
+ "AVRO"
+};
+const std::map
_SchemaType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSchemaTypeValues, _kSchemaTypeNames), ::apache::thrift::TEnumIterator(-1,
NULL, NULL));
+
+int _kSchemaCompatibilityValues[] = {
+ SchemaCompatibility::NONE,
+ SchemaCompatibility::BACKWARD,
+ SchemaCompatibility::FORWARD,
+ SchemaCompatibility::BOTH
+};
+const char* _kSchemaCompatibilityNames[] = {
+ "NONE",
+ "BACKWARD",
+ "FORWARD",
+ "BOTH"
+};
+const std::map
_SchemaCompatibility_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4,
_kSchemaCompatibilityValues, _kSchemaCompatibilityNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kSchemaValidationValues[] = {
+ SchemaValidation::LATEST,
+ SchemaValidation::ALL
+};
+const char* _kSchemaValidationNames[] = {
+ "LATEST",
+ "ALL"
+};
+const std::map
_SchemaValidation_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2,
_kSchemaValidationValues, _kSchemaValidationNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
+int _kSchemaVersionStateValues[] = {
+ SchemaVersionState::INITIATED,
+ SchemaVersionState::START_REVIEW,
+ SchemaVersionState::CHANGES_REQUIRED,
+ SchemaVersionState::REVIEWED,
+ SchemaVersionState::ENABLED,
+ SchemaVersionState::DISABLED,
+ SchemaVersionState::ARCHIVED,
+ SchemaVersionState::DELETED
+};
+const char* _kSchemaVersionStateNames[] = {
+ "INITIATED",
+ "START_REVIEW",
+ "CHANGES_REQUIRED",
+ "REVIEWED",
+ "ENABLED",
+ "DISABLED",
+ "ARCHIVED",
+ "DELETED"
+};
+const std::map
_SchemaVersionState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8,
_kSchemaVersionStateValues, _kSchemaVersionStateNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
+
int _kFunctionTypeValues[] = {
FunctionType::JAVA
};
@@ -3999,6 +4065,26 @@ void SerDeInfo::__set_parameters(const
std::map & val)
this->parameters = val;
}
+void SerDeInfo::__set_description(const std::string& val) {
+ this->description = val;
+__isset.description = true;
+}
+
+void SerDeInfo::__set_serializerClass(const std::string& val) {
+ this->serializerClass = val;
+__isset.serializerClass = true;
+}
+
+void SerDeInfo::__set_deserializerClass(const std::string& val) {
+ this->deserializerClass = val;
+__isset.deserializerClass = true;
+}
+
+void SerDeInfo::__set_serdeType(const SerdeType::type val) {
+ this->serdeType = val;
+__isset.serdeType = true;
+}
+
uint32_t SerDeInfo::read(::apache::thrift::protocol::TProtocol* iprot) {
apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
@@ -4059,6 +4145,40 @@ uint32_t
SerDeInfo::read(::apache::thrift::protocol::TProtocol* iprot) {
xfer += iprot->skip(ftype);
}
break;
+ case 4:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->description);
+ this->__isset.description = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 5:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->serializerClass);
+ this->__isset.serializerClass = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 6:
+if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->deserializerClass);
+ this->__isset.deserializerClass = true;
+} else {
+ xfer += iprot->skip(ftype);
+}
+break;
+ case 7:
+if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast144;
+
