couchbase-protolib/src/main/java/com/streamsets/pipeline/stage/processor/couchbase/CouchbaseProcessor.java
private <T> Observable<T> handleError(Record record, Errors error, boolean passable) {
    return handleError(record, error, new RuntimeException(), passable);
  }
private <T> Observable<T> handleError(Record record, Errors error, boolean passable) {
    return handleError(record, error, new RuntimeException(), passable);
  }
private < T > Observable < T > handleError ( Record record , Errors error , boolean passable ) { return handleError ( record , error , new RuntimeException ( ) , passable ) ; }
Aggregates errors that occur during the processing of a batch.

@param record the record being written
@param error the error encountered while writing the record
@param passable whether the record can be optionally passed down the pipeline
@return an empty observable
Aggregates errors that occur during the processing of a batch .