Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val timeWindowStoreName = "mehrofiq-countStore-timeWindow"
- val countStoreForLastEightHours =
- mergedStreamTable.count(TimeWindows.of(TimeUnit.HOURS.toMillis(8)) , timeWindowStoreName)
- val sessionWindowStoreName = "mehrofiq-countStore-sessionWindow"
- val countForSession =
- mergedStreamTable.count(SessionWindows.`with`(1000) , timeWindowStoreName)
Add Comment
Please, Sign In to add comment
