private void closeImpl() throws StreamingException {
    state = HiveStreamingConnection.TxnState.INACTIVE;
    recordWriter.close();
    if (scheduledExecutorService != null) {
      scheduledExecutorService.shutdownNow();
    }
  }
Close the TransactionBatch.  This will abort any still open txns in this batch.

@throws StreamingException - failure when closing transaction batch
streaming/src/java/org/apache/hive/streaming/TransactionBatch.java