flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tao xiao <xiaotao...@gmail.com>
Subject window function outputs two different values
Date Sat, 07 Jan 2017 12:30:43 GMT
Hi team,

I have a requirement that wants to output two different values from a time
window reduce function. Here is basic workflow

1. fetch data from Kafka
2. flow the data to a event session window. kafka source -> keyBy ->
session window -> reduce
3. inside the reduce function, count the number of data and also emit the
data itself to another operator for further processing

As the reduce function can only emit the count, I want to know how to also
emit the data as well?

View raw message