flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [6/7] flink git commit: Fix Displayed CEP Operator Names
Date Mon, 18 Jul 2016 10:39:30 GMT
Fix Displayed CEP Operator Names


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3d8d1920
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3d8d1920
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3d8d1920

Branch: refs/heads/master
Commit: 3d8d1920f78f7c657fd933b2e83b45e111efa18b
Parents: 254379b
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Jul 7 14:48:13 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jul 18 11:16:03 2016 +0200

----------------------------------------------------------------------
 .../org/apache/flink/cep/operator/CEPOperatorUtils.java     | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/3d8d1920/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPOperatorUtils.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPOperatorUtils.java
b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPOperatorUtils.java
index a3fffa5..548be16 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPOperatorUtils.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CEPOperatorUtils.java
@@ -36,7 +36,6 @@ import org.apache.flink.types.Either;
 import java.util.Map;
 
 public class CEPOperatorUtils {
-	private static final String PATTERN_OPERATOR_NAME = "AbstractCEPPatternOperator";
 
 	/**
 	 * Creates a data stream containing the fully matching event patterns of the NFA computation.
@@ -64,7 +63,7 @@ public class CEPOperatorUtils {
 			TypeSerializer<K> keySerializer = keyedStream.getKeyType().createSerializer(keyedStream.getExecutionConfig());
 
 			patternStream = keyedStream.transform(
-				PATTERN_OPERATOR_NAME,
+				"KeyedCEPPatternOperator",
 				(TypeInformation<Map<String, T>>) (TypeInformation<?>) TypeExtractor.getForClass(Map.class),
 				new KeyedCEPPatternOperator<>(
 					inputSerializer,
@@ -74,7 +73,7 @@ public class CEPOperatorUtils {
 					nfaFactory));
 		} else {
 			patternStream = inputStream.transform(
-				PATTERN_OPERATOR_NAME,
+				"CEPPatternOperator",
 				(TypeInformation<Map<String, T>>) (TypeInformation<?>) TypeExtractor.getForClass(Map.class),
 				new CEPPatternOperator<T>(
 					inputSerializer,
@@ -119,7 +118,7 @@ public class CEPOperatorUtils {
 			TypeSerializer<K> keySerializer = keyedStream.getKeyType().createSerializer(keyedStream.getExecutionConfig());
 
 			patternStream = keyedStream.transform(
-				PATTERN_OPERATOR_NAME,
+				"TimeoutKeyedCEPPatternOperator",
 				eitherTypeInformation,
 				new TimeoutKeyedCEPPatternOperator<T, K>(
 					inputSerializer,
@@ -129,7 +128,7 @@ public class CEPOperatorUtils {
 					nfaFactory));
 		} else {
 			patternStream = inputStream.transform(
-				PATTERN_OPERATOR_NAME,
+				"TimeoutCEPPatternOperator",
 				eitherTypeInformation,
 				new TimeoutCEPPatternOperator<T>(
 					inputSerializer,


Mime
View raw message