class HiveWriter {

  public void close() throws InterruptedException {
    batch.clear();
    abortRemainingTxns();
    closeTxnBatch();
    closeConnection();
    closed = true;
  }

    HiveWriter(HiveEndPoint endPoint, int txnsPerBatch,
             boolean autoCreatePartitions, long callTimeout,
             ExecutorService callTimeoutPool, String hiveUser,
             HiveEventSerializer serializer, SinkCounter sinkCounter);

}