Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5240#discussion_r162947784
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -125,6 +129,16 @@ abstract class StreamTableEnvironment(
}
}
+ /**
+ * Creates a table from a descriptor that describes the resulting table
schema, the source
+ * connector, the source encoding, and other properties.
+ *
+ * @param schema schema descriptor describing the table to create
+ */
+ def createTable(schema: Schema): StreamTableSourceDescriptor = {
--- End diff --
See comment on `BatchTableEnvironment`
---
