You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by bl...@apache.org on 2019/05/21 22:34:19 UTC
[flink] branch master updated: [hotfix][table] Reformat method
signature of GenericInMemoryCatalog
This is an automated email from the ASF dual-hosted git repository.
bli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9980ab2 [hotfix][table] Reformat method signature of GenericInMemoryCatalog
9980ab2 is described below
commit 9980ab21b3786ecd4eeecab180d764a387472fc8
Author: bowen.li <bo...@gmail.com>
AuthorDate: Tue May 21 15:33:39 2019 -0700
[hotfix][table] Reformat method signature of GenericInMemoryCatalog
---
.../apache/flink/table/catalog/GenericInMemoryCatalog.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java
index 801aabb..64d5a8c 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java
@@ -105,7 +105,7 @@ public class GenericInMemoryCatalog implements Catalog {
@Override
public void createDatabase(String databaseName, CatalogDatabase db, boolean ignoreIfExists)
- throws DatabaseAlreadyExistException {
+ throws DatabaseAlreadyExistException {
checkArgument(!StringUtils.isNullOrWhitespaceOnly(databaseName));
checkNotNull(db);
@@ -119,8 +119,8 @@ public class GenericInMemoryCatalog implements Catalog {
}
@Override
- public void dropDatabase(String databaseName, boolean ignoreIfNotExists) throws DatabaseNotExistException,
- DatabaseNotEmptyException {
+ public void dropDatabase(String databaseName, boolean ignoreIfNotExists)
+ throws DatabaseNotExistException, DatabaseNotEmptyException {
checkArgument(!StringUtils.isNullOrWhitespaceOnly(databaseName));
if (databases.containsKey(databaseName)) {
@@ -145,7 +145,7 @@ public class GenericInMemoryCatalog implements Catalog {
@Override
public void alterDatabase(String databaseName, CatalogDatabase newDatabase, boolean ignoreIfNotExists)
- throws DatabaseNotExistException {
+ throws DatabaseNotExistException {
checkArgument(!StringUtils.isNullOrWhitespaceOnly(databaseName));
checkNotNull(newDatabase);
@@ -183,7 +183,7 @@ public class GenericInMemoryCatalog implements Catalog {
@Override
public void createTable(ObjectPath tablePath, CatalogBaseTable table, boolean ignoreIfExists)
- throws TableAlreadyExistException, DatabaseNotExistException {
+ throws TableAlreadyExistException, DatabaseNotExistException {
checkNotNull(tablePath);
checkNotNull(table);
@@ -208,7 +208,7 @@ public class GenericInMemoryCatalog implements Catalog {
@Override
public void alterTable(ObjectPath tablePath, CatalogBaseTable newTable, boolean ignoreIfNotExists)
- throws TableNotExistException {
+ throws TableNotExistException {
checkNotNull(tablePath);
checkNotNull(newTable);
@@ -248,7 +248,7 @@ public class GenericInMemoryCatalog implements Catalog {
@Override
public void renameTable(ObjectPath tablePath, String newTableName, boolean ignoreIfNotExists)
- throws TableNotExistException, TableAlreadyExistException {
+ throws TableNotExistException, TableAlreadyExistException {
checkNotNull(tablePath);
checkArgument(!StringUtils.isNullOrWhitespaceOnly(newTableName));