Apache Beam Model
What: sum, average or machine learning? used to be done with classic batch processing. Where: windowing with event time such as fixed, sliding or session. Wh...
Blog Posts
Recent posts
Groovy - missing method
Groovy missing method is used by the gradle syntax
Stream Process - watermark
Apache Beam with Spark streaming runner on Youtube
Spark Structured Stream Process - Watermark
Spark Structured Streaming Watermark Concept.
Kafka - GenericRecord vs SpecificRecord
Kafka has two types of record on producing and consuming Kafka messages which are called GenericRecord and SpecificRecord. Main difference between GenericRec...