Pure Soul

flink
flink

Timer on Flink

Timer on ProcessFunction and KeyedProcessFunction Flink distinguishes between two key notions of time: processing time and event time. Processing time refers to the system time at which an event is processed, whereas event time is explicitly defined or configu…

2024年5月29日 0条评论 1456点热度 0人点赞 ycq 阅读全文
flink

Loading data periodically in Flink

Stream API (SourceFunction, AbstractSourceFunction and RichSourceFunction) in Flink In Flink's streaming API, there is a critical interface named Function, which extends Serializable: public interface Function extends Serializable { } Nearly all streaming APIs…

2024年5月26日 0条评论 1673点热度 1人点赞 ycq 阅读全文

COPYRIGHT © 2021 oo2ee.com. ALL RIGHTS RESERVED.

THEME KRATOS MADE BY VTROIS