public void updateOrInsertBy(String outputTableId, UpdateSet updateSetAttributes, Expression onUpdateExpression) {

        this.outputStream = new UpdateOrInsertStream(outputTableId, CURRENT_EVENTS,
                updateSetAttributes, onUpdateExpression);
    }
Method to set an updateOrInsertStream as the outputStream of the on-demand query

@param outputTableId       id of the table which is going to be queried
@param updateSetAttributes updateSet for the attributes which are going to be updated.
@param onUpdateExpression  expression for the update or insert operation defined in the on-demand query
modules/siddhi-query-api/src/main/java/io/siddhi/query/api/execution/query/OnDemandQuery.java