Hi all
Using DataStream, How to implement a message and the
same message appears again 10 minutes later?
Thanks,
Jiazhi
Hi all
After grouping by users, message A
arrives. If message B also arrives later, and the time of message B is less
than that of message A within 10 minutes, mark the field in message A with Tag
= True. How to achieve this?
Thanks
Jiazhi
Hi all
When DataStream is converted to table, eventTime is
converted to rowTime. Rowtime is 8 hours slow. How to solve this problem?
Thanks
Jiazhi
Hi all
When I use SQL with UDTF, when I call the tableEnv.sqlQuery
() method, I throw the following error: Rowtime attributes must not be in the
input rows of a regular join. As a workaround you can cast the time attributes
of input tables to TIMESTAMP before. I used the to_timestamp functi
Hi all When I use SQL with UDTF, when I call the
tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes
must not be in the input rows of a regular join. As a workaround you can cast
the time attributes of input tables to TIMESTAMP before. I used the
to_timestamp functi
Hi all
Can only one thread run at a time for a slot? Or one
slot can run multiple threads in parallel at the same time?
Thanks,
Jiazhi
Hi all
How to use DataStream to load mysql data into the memory of
flink task when the task is initialized? Please give me a demo.
Thanks,
Jiazhi
Dear all:
How do I use the windowsState() method and the
globalState() method in process Windows Function? Can I give a demo?
Thanks,
Jiazhi
Deal All
I use the reduce operator after the TimeWindow
operator, whether to output one element after all elements in the current
window have been calculated according to reduce logic??
Thanks
Jiazhi
Hi all
When I get the processingTime in the processElement method
of the KeyedProcessFunction,
like ctx.timestamp(), which returns null, how do I get the
processingTime in processElement methoed?
Thanks,
Jiazhi
Hi all
I want to know which performance is faster, the DataStream API or the
Table API + SQL.
Thanks,
Jiazhi
Dear all:
How do I clear custom state in ProcessWindowsFunction? Because there is no
onTimer method in ProcessAllWindowFunction.
Thanks
Jiazhi
Deal all
Keyed state (ValueState, ReducingState, ListState, AggregatingState, MapState)
Supported in Keyed Stream, meaning only in KeyedProcessFunction? But in
practice, I can also use these states in ProcessAllWindowFunction and
ProcessWindowFunction. Why?
thank you
jiazhi
13 matches
Mail list logo