Create and update operation for Streaming data.

Added merge operation for entities.