StreamingQuery and StreamingAutoCommit implemented
logger added