代码如下所示kafkaSource.assignTimestampsAndWatermarks20)))
每当我试图编译上面的代码时，我都会看到一个错误：error: overlo
浏览 5提问于2020-11-23得票数 4
回答已采纳
我正在处理一个项目，并打开了Flink选项disableAutoGeneratedUID，以确保所有内容都具有适当的uid。但是，当我试图运行以下工作时，我遇到了一个错误：一年前，我在网上看到
浏览 1提问于2021-06-11得票数 0
回答已采纳
在以下代码中 WatermarkStrategy<transformation);}
assignTimestampsAndWatermarks
浏览 4提问于2022-10-28得票数 0
回答已采纳
我正在使用flink 1.12.0。试图将数据流转换为表A，并在tableA上运行sql查询，以便按下面的方式通过窗口进行聚合，我使用f2列作为时间戳数据类型字段。
浏览 5提问于2021-02-15得票数 0
回答已采纳
keyedStream = executionEnvironment
keyedStream.assignTimestampsAndWatermarks
浏览 0提问于2020-12-30得票数 0
回答已采纳
当使用joinStream连接两个流时，我不能设置joinStream的并行度，它总是为1 aStream.assignTimestampsAndWatermarks(new AWatermarks()) .join(bStream.assignTimestampsAndWatermarks(new BWatermarks())
浏览 15提问于2020-12-07得票数 0
Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarksstream.rebalance()
.assignTimestampsAndWatermarks(new MessageTimestampExtractor(maxTimeLag));
浏览 1提问于2016-03-16得票数 5
回答已采纳
如果我将我的时间特征设置为IngestionTime，我需要设置assignTimestampsAndWatermarks吗？streamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
我需要给datastream.assignTimestampsAndWatermarks我认为只有当时间特征是事件时间时，datastream.assignTimestampsAndWatermarks才是强制性的。不是吗？
浏览 134提问于2020-03-10得票数 2
回答已采纳
考虑一下我这样做：ds.assignTimestampsAndWatermarks(CustomAssigner).assignTimestampsAndWatermarks编辑 int timestamp;
String someDetail; &#
浏览 1提问于2019-02-08得票数 1
我尝试在使用来自AWS Kinesis的json消息时使用EventTimeSessionWindows。DataStream<SamplePojo> kinesis = env.addSource(new FlinkKinesisConsumer<>( new POJODeserializationSchema(),
DataStream<SamplePojo>
浏览 3提问于2017-03-19得票数 1
val streamA: DataStream[A] = kafkaStreamASourceOutput.assignTimestampsAndWatermarks( } )
val streamA: DataStream[B] = kafkaStreamBSourceOutput.assignTimestampsAndWatermarksstreamC.assignTimestampsAnd
浏览 4提问于2021-10-22得票数 0
回答已采纳
我想根据id连接Customer和Address对象。这些是我对客户主题的kafka流的输入{"id": 2,"name": "Swati" }{"id": 4,"name": "Amol" }
{"id": 5,"name": "Pooja"
浏览 17提问于2020-05-15得票数 0
keyBy工作前的assignTimestampsAndWatermarks： DataStream<Trip> trips =DataStream<FeaturizedTrip> featurizedUserTrips =
userTrips.process(new Featurization()).assignTimestampsAndWatermarks<
浏览 98提问于2019-04-17得票数 1
Tom", new Timestamp(new Date().getTime)), Person2("Jack", new Timestamp(new Date().getTime)))
ds.assignTimestampsAndWatermarks
浏览 2提问于2020-12-25得票数 0
回答已采纳
value.forEach(mockData -> out.collect(mockData)); } }); convertToPojo.assignTimestampsAndWatermarks
浏览 1提问于2018-11-22得票数 1
回答已采纳
1回答
目前，我正在尝试升级应用于数据流的方法调用assignTimestampsAndWatermarks。.name("Custom Source") .assignTimestampsAndWatermarks
浏览 1提问于2022-01-15得票数 0
回答已采纳
1回答
new StreamedApiLogRecordDeserializationSchema(),
apiLogRecords.assignTimestampsAndWatermarks
浏览 6提问于2017-08-28得票数 0
回答已采纳
秒滑动来计算消息的数量(下面的校验码)，但我需要帮助保存(或打印)延迟到达的丢弃消息，我尝试使用sideOutputLateData，但它对我不起作用 .assignTimestampsAndWatermarkssideOutputLateData：val sensorData = stream
.assignTimestampsAndWatermarks
浏览 7提问于2019-11-12得票数 0
env.addSource(readFromCouchBase...) .assignTimestampsAndWatermarks(
浏览 5提问于2022-09-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
