Spark Structured Streaming
不断获取封装在RDMessage对象中的传感器测量记录(IoT),该对象记录协议中用于控制的消息类型。当消息到达时,将使用
Encoder<RDMeasurement> measurementEncoder = Encoders.bean(RDMeasurement.class)
检查它们并将其转换为数据集。,虽然流被正确读取并且RDMeasurement
对象被正确创建,但是输出流被设置为无或零,具体取决于数据类型。当我更改格式(.format("console")
)时,我在DeltaFrame表或控制台中看到这一点。,我这里错过了什么?出什么问题了?,请参阅下面最重要的Java代码段,每行输入遵循以下格式:,重构Java代码并添加调试代码段后,我能够识别错误。,参见重构:,上面注释的代码使我能够识别问题。,这篇关于电光为什么在三角洲湖表中写空的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,