Apache Flink abstracts the state management complexities for application developers. It provides fault-tolerance with checkpointing and failure recovery mechanism. The state is required in a certain type of data processing e.g. when we are processing credit card transactions to…
Windowing is a crucial concept in stream processing frameworks or when we are dealing with an infinite amount of data. In…
Big data has many definitions but generally it refers to the data sets that doesn’t fit into your systems…