private void writeEventBatchToSerializer()

in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java [149:175]

27 lines of code
6 McCabe index (conditional complexity)


  private void writeEventBatchToSerializer()
      throws InterruptedException, WriteException {
    try {
      timedCall(new CallRunner1<Void>() {
        @Override
        public Void call() throws InterruptedException, StreamingException {
          try {
            for (Event event : batch) {
              try {
                serializer.write(txnBatch, event);
              } catch (SerializationError err) {
                LOG.info("Parse failed : {}  : {}", err.getMessage(), new String(event.getBody()));
              }
            }
            return null;
          } catch (IOException e) {
            throw new StreamingIOFailure(e.getMessage(), e);
          }
        }
      });
      batch.clear();
    } catch (StreamingException e) {
      throw new WriteException(endPoint, txnBatch.getCurrentTxnId(), e);
    } catch (TimeoutException e) {
      throw new WriteException(endPoint, txnBatch.getCurrentTxnId(), e);
    }
  }