[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249708#comment-15249708
]
ASF GitHub Bot commented on FLINK-3708:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1905#discussion_r60393928
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java
---
@@ -99,10 +116,26 @@
null,
false);
+ return flatSelect(patternFlatSelectFunction, outTypeInfo);
+ }
+
+ /**
+ * Applies a flat select function to the detected pattern sequence. For
each pattern sequence
+ * the provided {@link PatternFlatSelectFunction} is called. The
pattern flat select function
+ * can produce an arbitrary number of resulting elements.
+ *
+ * @param patternFlatSelectFunction The pattern flat select function
which is called for each
+ * detected pattern sequence.
+ * @param <R> Typ of the resulting elements
+ * @param outTypeInfo Explicit specification of output type.
+ * @return {@link DataStream} which contains the resulting elements
from the pattern flat select
+ * function.
+ */
+ public <R> DataStream<R> flatSelect(final PatternFlatSelectFunction<T,
R> patternFlatSelectFunction, TypeInformation<R> outTypeInfo) {
return patternStream.flatMap(
- new PatternFlatSelectMapper<T, R>(
-
patternStream.getExecutionEnvironment().clean(patternFlatSelectFunction)
- )).returns(outTypeInfo);
+ new PatternFlatSelectMapper<T, R>(
+
patternStream.getExecutionEnvironment().clean(patternFlatSelectFunction)
+ )).returns(outTypeInfo);
}
--- End diff --
Indentation off in this file.
> Scala API for CEP
> -----------------
>
> Key: FLINK-3708
> URL: https://issues.apache.org/jira/browse/FLINK-3708
> Project: Flink
> Issue Type: Improvement
> Components: CEP
> Affects Versions: 1.1.0
> Reporter: Till Rohrmann
> Assignee: Stefan Richter
>
> Currently, The CEP library does not support Scala case classes, because the
> {{TypeExtractor}} cannot handle them. In order to support them, it would be
> necessary to offer a Scala API for the CEP library.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
