Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5068#discussion_r153432702
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -60,4 +60,14 @@ trait TableSource[T] {
*/
def explainSource(): String = ""
+ /**
+ * Gets the name which is used by the visualization and logging during
runtime.
+ *
+ * @return Name of the [[TableSource]].
+ */
+ def getRuntimeName(): String = {
--- End diff --
Fine. I just added a default implementation in `TableSource` trait and kept
the existing ones in subclasses.
---
