From ab87aa3e5555c7748aa8844b4cd998a2e549957f Mon Sep 17 00:00:00 2001 From: hequn8128 Date: Tue, 11 Dec 2018 10:59:04 +0800 Subject: [PATCH] [FLINK-11124][table] Add private[flink] to TemporalTableFunction.create() --- .../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 bbb9911c63f30..bf668480a0ad7 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 = {