Merge pull request #211 from ni-ze/supportRsqldb

support emit and watermark