网站首页
编程语言
数据库
系统相关
其他分享
编程问答
FlinkManager
2024-10-28
实时计算框架
代码demopublicstaticvoidmain(String[]args){FlinkManagermanager=newFlinkManager(FLINK_IBU_BI_UBT_CUSTOM_HOTEL_FAVORITE,IS_LOCAL);manager.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);manager.setParallelis