This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b82b24d [FLINK-11124][table] Add private[flink] to
TemporalTableFunction.create()
b82b24d is described below
commit b82b24d720bdebd58ba507af98e68ab027790a4f
Author: hequn8128 <[email protected]>
AuthorDate: Tue Dec 11 10:59:04 2018 +0800
[FLINK-11124][table] Add private[flink] to TemporalTableFunction.create()
This closes #7271.
---
.../scala/org/apache/flink/table/functions/TemporalTableFunction.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala
index bbb9911..bf66848 100644
---
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala
+++
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala
@@ -65,7 +65,7 @@ class TemporalTableFunction private(
}
object TemporalTableFunction {
- def create(
+ private[flink] def create(
table: Table,
timeAttribute: Expression,
primaryKey: String): TemporalTableFunction = {
