Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5240#discussion_r162967648 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -18,28 +18,282 @@ package org.apache.flink.table.catalog -import java.util.{HashMap => JHashMap, Map => JMap} import java.lang.{Long => JLong} +import java.util.{HashMap => JHashMap, Map => JMap} -import org.apache.flink.table.api.TableSchema +import org.apache.flink.table.api.{TableException, TableSchema} +import org.apache.flink.table.catalog.ExternalCatalogTable.{TableTypeConnector, toConnectorDescriptor, toMetadataDescriptor, toStatisticsDescriptor} +import org.apache.flink.table.descriptors.DescriptorUtils.{connector, metadata} +import org.apache.flink.table.descriptors._ import org.apache.flink.table.plan.stats.TableStats +import scala.collection.JavaConverters._ + /** * Defines a table in an [[ExternalCatalog]]. - * - * @param tableType Table type, e.g csv, hbase, kafka - * @param schema Schema of the table (column names and types) - * @param properties Properties of the table - * @param stats Statistics of the table - * @param comment Comment of the table - * @param createTime Create timestamp of the table - * @param lastAccessTime Timestamp of last access of the table */ -case class ExternalCatalogTable( +class ExternalCatalogTable( --- End diff -- Add descriptions for constructor arguments
---