Design and Implementation of Blocking Operators Over Data Streams

In order to deal with blocking operator effectively for the tuples in data stream,the principle of the continuous query over the data streams with punctuation is analyzed and researched.The data structure and processing rules for Group-by operator and the unbounded stateful operator Join is given.The result is ana- lyzed and evaluated.The testing result shows that embedding punctuation into data streams can improve the blocking operation and unbounded operation performance as well as decreasing the memory amount they need.