Create and update operation for Streaming data.
Added merge operation for entities.