Add watermark support for stream data processing. This includes adding watermark event, watermark generator and integrate with planner and physical plan.