Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3816
Hi @iduanyingjie, the replacement for fold has not been implemented yet. So
you have to stick with `fold()` for now.
`fold`'s replacement will correspond to
`WindowedStream.aggregate(Aggrega
Github user iduanyingjie commented on the issue:
https://github.com/apache/flink/pull/3816
In this document
[https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/index.html#datastream-transformations](url)
`keyedStream.fold("start")((str, i) => { str
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3816
Actually, `KeyedStream.aggregate` is protected and thus not accessible.
You may, however, access
`WindowedStream#aggregate(AggregateFunction) ` and
`AllWindowedStream#aggregate(AggregateFuncti
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3816
Hi @caddac , you can use `AggregateFunction` and
`KeyedStream.aggregate(AggregationFunction aggregate)` instead of fold.
---
If your project is set up for it, you can reply to this email and have
Github user caddac commented on the issue:
https://github.com/apache/flink/pull/3816
Sorry for commenting on this closed PR, but can you point me to
documentation for what will replace fold? I'm starting a new project using 1.3
and don't want to use a deprecated API, but don't find mu
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3816
Cool, thanks for working on this (and the fold PR): ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not hav
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3816
merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the fea
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3816
I think we got them all now. I would have missed the one in
`TypeExtractor`...
LGTM (looks good to merge) now!
---
If your project is set up for it, you can reply to this email and have yo
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3816
Man that stuff is everywhere isn't it...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enab
