You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by gj...@apache.org on 2021/11/22 19:39:31 UTC
[phoenix] branch 4.x updated: PHOENIX-6599 - Missing checked exceptions on SchemaRegistryRepository (#1355)
This is an automated email from the ASF dual-hosted git repository.
gjacoby pushed a commit to branch 4.x
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x by this push:
new 27299f0 PHOENIX-6599 - Missing checked exceptions on SchemaRegistryRepository (#1355)
27299f0 is described below
commit 27299f04da39b431fe6f0708c2173ba8af55524e
Author: Geoffrey Jacoby <gj...@apache.org>
AuthorDate: Mon Nov 22 13:37:40 2021 -0600
PHOENIX-6599 - Missing checked exceptions on SchemaRegistryRepository (#1355)
---
.../apache/phoenix/schema/export/DefaultSchemaRegistryRepository.java | 4 ++--
.../org/apache/phoenix/schema/export/SchemaRegistryRepository.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/export/DefaultSchemaRegistryRepository.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/export/DefaultSchemaRegistryRepository.java
index 35b514b..34785aa 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/export/DefaultSchemaRegistryRepository.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/export/DefaultSchemaRegistryRepository.java
@@ -49,12 +49,12 @@ public class DefaultSchemaRegistryRepository implements SchemaRegistryRepository
}
@Override
- public String getSchemaById(String schemaId) {
+ public String getSchemaById(String schemaId) throws IOException {
return schemaMap.get(schemaId);
}
@Override
- public String getSchemaByTable(PTable table) {
+ public String getSchemaByTable(PTable table) throws IOException {
return schemaMap.get(getSchemaId(table));
}
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/export/SchemaRegistryRepository.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/export/SchemaRegistryRepository.java
index 52a26e2..7f8a55e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/export/SchemaRegistryRepository.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/export/SchemaRegistryRepository.java
@@ -59,12 +59,12 @@ public interface SchemaRegistryRepository extends Closeable {
* @param schemaId schema identifier
* @return a schema
*/
- String getSchemaById(String schemaId);
+ String getSchemaById(String schemaId) throws IOException;
/**
* Return a schema from an external schema repository using information on a PTable
* @param table a Phoenix PTable for a table or view
* @return a schema
*/
- String getSchemaByTable(PTable table);
+ String getSchemaByTable(PTable table) throws IOException;
}