You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/01/09 08:13:12 UTC
[flink] 04/05: [hotfix][cep] Renamed TimerContext to TimeContext
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0a46510a7e87f350492f4e4889c006f87ae7c665
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Tue Jan 8 12:07:48 2019 +0100
[hotfix][cep] Renamed TimerContext to TimeContext
---
.../java/org/apache/flink/cep/functions/PatternProcessFunction.java | 4 ++--
.../org/apache/flink/cep/pattern/conditions/IterativeCondition.java | 4 ++--
.../org/apache/flink/cep/time/{TimerContext.java => TimeContext.java} | 2 +-
...imerContextTest.java => NFAIterativeConditionTimeContextTest.java} | 2 +-
4 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/functions/PatternProcessFunction.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/functions/PatternProcessFunction.java
index b8e6821..afc798f 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/functions/PatternProcessFunction.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/functions/PatternProcessFunction.java
@@ -20,7 +20,7 @@ package org.apache.flink.cep.functions;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.AbstractRichFunction;
-import org.apache.flink.cep.time.TimerContext;
+import org.apache.flink.cep.time.TimeContext;
import org.apache.flink.util.Collector;
import org.apache.flink.util.OutputTag;
@@ -64,7 +64,7 @@ public abstract class PatternProcessFunction<IN, OUT> extends AbstractRichFuncti
/**
* Gives access to time related characteristics as well as enables emitting elements to side outputs.
*/
- public interface Context extends TimerContext {
+ public interface Context extends TimeContext {
/**
* Emits a record to the side output identified by the {@link OutputTag}.
*
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/IterativeCondition.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/IterativeCondition.java
index 786cb08..ad45dab 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/IterativeCondition.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/IterativeCondition.java
@@ -20,7 +20,7 @@ package org.apache.flink.cep.pattern.conditions;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.Function;
-import org.apache.flink.cep.time.TimerContext;
+import org.apache.flink.cep.time.TimeContext;
import java.io.Serializable;
@@ -87,7 +87,7 @@ public abstract class IterativeCondition<T> implements Function, Serializable {
/**
* The context used when evaluating the {@link IterativeCondition condition}.
*/
- public interface Context<T> extends TimerContext {
+ public interface Context<T> extends TimeContext {
/**
* @return An {@link Iterable} over the already accepted elements
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimerContext.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimeContext.java
similarity index 97%
rename from flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimerContext.java
rename to flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimeContext.java
index 9b5db52..55e43b8 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimerContext.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/time/TimeContext.java
@@ -27,7 +27,7 @@ import org.apache.flink.cep.functions.PatternProcessFunction;
* {@link org.apache.flink.cep.pattern.conditions.IterativeCondition}
*/
@PublicEvolving
-public interface TimerContext {
+public interface TimeContext {
/**
* Timestamp of the element currently being processed.
diff --git a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimerContextTest.java b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimeContextTest.java
similarity index 97%
rename from flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimerContextTest.java
rename to flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimeContextTest.java
index 3f9b26a..3ebc65f 100644
--- a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimerContextTest.java
+++ b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAIterativeConditionTimeContextTest.java
@@ -38,7 +38,7 @@ import static org.apache.flink.cep.utils.NFATestUtilities.compareMaps;
/**
* Tests for accesing time properties from {@link IterativeCondition}.
*/
-public class NFAIterativeConditionTimerContextTest extends TestLogger {
+public class NFAIterativeConditionTimeContextTest extends TestLogger {
@Test
public void testEventTimestamp() throws Exception {