You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/01/04 15:11:46 UTC
[flink] branch master updated: [FLINK-11124][table] Add
private[flink] to TemporalTableFunction.create()
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 <ch...@gmail.com>
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 = {