How does spark calculate the difference between the two pieces of data (kafka data source)?

Kotlin
IOS
VB.Net
SQL
Node.js
Swift
Ruby
Go
Oracle
Git
Laravel
Mongodb
Asp.Net
More...

the data source is kafka, and a field is a timestamp. We want to calculate the difference between the timestamps of the two pieces of data, and then add a new field to store this value and send it out.
I checked. Do you want to reducebykeyandwindow? With this, can you just set the window size to two batchtime? Is it possible that the two windows are too small and then there is no corresponding previous piece of data?
or if I set it to 10 batch time, is the result a difference of 10 times?
is there any other way?

Kafka mapreduce spark spark-streaming

Apr.20,2022

you can use spark DataFrame (or spark sql) windowing function.

Previous: React form check

Next: When creating a new terminal in IDE, why is the first input not on the same line as the terminal cursor?

False
Django, Why does the system automatically generate an empty session? every time the request is made?
Use python to convert dict1 to dict2, in the example. I tried for a long time but couldn't find a solution.
How to self-start the php-fpm service when building a LNMP environment with docker?
Can an array in react state be bound to a dom state using an element in the array?
Wechat browser version 6.6.5 cannot prevent the springback of pull-up and drop-down to the top under ios system.
In express+hbs, how do you define the routed data as a variable on the page?
How to use symbol reference of Iconfont in dva
How to elegantly add data to JSON objects?
Using node to build video streaming server
The proportional width of the echarts graph is inconsistent.
React uses axios to call the background data. After success, how to jump to the page based on the returned value?
I don't understand what a linux command means. Please explain it.
Vue introduces multiple components in vue-router by nesting named views, and does not refresh the same reference in other pages.
Running nodejs reports fewer errors ")"

The problem of getting the focus of input time tags in vue
Mini Program retweet function as a public method
Why will there be output if you add double?
Is there any library in react-native that can take screenshots of react-native-video videos?
Sharding-jdbc loop insert Times error