[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249712#comment-15249712
]
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_r60394116
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java
---
@@ -61,19 +61,36 @@
public <R> DataStream<R> select(final PatternSelectFunction<T, R>
patternSelectFunction) {
// we have to extract the output type from the provided pattern
selection function manually
// because the TypeExtractor cannot do that if the method is
wrapped in a MapFunction
- TypeInformation<R> outTypeInfo =
TypeExtractor.getUnaryOperatorReturnType(
- patternSelectFunction,
- PatternSelectFunction.class,
- 1,
- -1,
- inputType,
- null,
- false);
+ TypeInformation<R> returnType =
TypeExtractor.getUnaryOperatorReturnType(
+ patternSelectFunction,
+ PatternSelectFunction.class,
+ 1,
+ -1,
+ inputType,
+ null,
+ false);
--- End diff --
Indentation
> 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)
