You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sh...@apache.org on 2018/06/04 23:31:12 UTC
flink git commit: [hotfix][docs] add comment for
TestTableSourceFactory
Repository: flink
Updated Branches:
refs/heads/master 8868ff5b0 -> 055bc3e9d
[hotfix][docs] add comment for TestTableSourceFactory
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/055bc3e9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/055bc3e9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/055bc3e9
Branch: refs/heads/master
Commit: 055bc3e9d2c5e0275edbc8bc9d8c149465b70a85
Parents: 8868ff5
Author: Shuyi Chen <sh...@uber.com>
Authored: Mon Jun 4 16:30:34 2018 -0700
Committer: Shuyi Chen <sh...@uber.com>
Committed: Mon Jun 4 16:30:34 2018 -0700
----------------------------------------------------------------------
.../org/apache/flink/table/sources/TestTableSourceFactory.scala | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/055bc3e9/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sources/TestTableSourceFactory.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sources/TestTableSourceFactory.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sources/TestTableSourceFactory.scala
index b4aa08d..026ee0a 100644
--- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sources/TestTableSourceFactory.scala
+++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sources/TestTableSourceFactory.scala
@@ -26,6 +26,9 @@ import org.apache.flink.table.descriptors.ConnectorDescriptorValidator.{CONNECTO
import org.apache.flink.table.descriptors.FormatDescriptorValidator.{FORMAT_PROPERTY_VERSION, FORMAT_TYPE}
import org.apache.flink.types.Row
+/**
+ * Table source factory for testing.
+ */
class TestTableSourceFactory extends TableSourceFactory[Row] {
override def requiredContext(): util.Map[String, String] = {