public void deleteBy(String outputTableId, Expression onDeletingExpression) {

        this.outputStream = new DeleteStream(outputTableId, CURRENT_EVENTS, onDeletingExpression);
    }
Method to set a deleteStream as the outputStream of the on-demand query

@param outputTableId        id of the table which is going to be queried
@param onDeletingExpression expression for the delete operation defined in the on-demand query
modules/siddhi-query-api/src/main/java/io/siddhi/query/api/execution/query/OnDemandQuery.java