[FLINK-15912][table] Clean TableFactoryUtil

spotify · Feb 22, 2020 · 052eb77 · 052eb77
1 parent 4e92bdb
commit 052eb77
Showing 1 changed file with 0 additions and 29 deletions.
diff --git a/...flink-table-api-java/src/main/java/org/apache/flink/table/factories/TableFactoryUtil.java b/...flink-table-api-java/src/main/java/org/apache/flink/table/factories/TableFactoryUtil.java
@@ -24,7 +24,6 @@
 import org.apache.flink.table.sinks.TableSink;
 import org.apache.flink.table.sources.TableSource;
 
-import java.util.Map;
 import java.util.Optional;
 
 /**
@@ -60,34 +59,6 @@ public static <T> TableSink<T> findAndCreateTableSink(TableSinkFactory.Context c
  }
  }
 
- /**
- * Returns a table source matching the properties.
- */
- @SuppressWarnings("unchecked")
- private static <T> TableSource<T> findAndCreateTableSource(Map<String, String> properties) {
- try {
- return TableFactoryService
- .find(TableSourceFactory.class, properties)
- .createTableSource(properties);
- } catch (Throwable t) {
- throw new TableException("findAndCreateTableSource failed.", t);
- }
- }
-
- @SuppressWarnings("unchecked")
- private static <T> TableSink<T> findAndCreateTableSink(Map<String, String> properties) {
- TableSink tableSink;
- try {
- tableSink = TableFactoryService
- .find(TableSinkFactory.class, properties)
- .createTableSink(properties);
- } catch (Throwable t) {
- throw new TableException("findAndCreateTableSink failed.", t);
- }
-
- return tableSink;
- }
-
  /**
  * Creates a table sink for a {@link CatalogTable} using table factory associated with the catalog.
  */