@Test public void testInstantiate() throws Exception { HiveEndPoint endPoint = new HiveEndPoint(metaStoreURI, dbName, tblName, partVals); SinkCounter sinkCounter = new SinkCounter(this.getClass().getName()); HiveWriter writer = new HiveWriter(endPoint, 10, true, timeout, callTimeoutPool, "flumetest", serializer, sinkCounter); writer.close(); }
public void close() throws InterruptedException { batch.clear(); abortRemainingTxns(); closeTxnBatch(); closeConnection(); closed = true; }
HiveWriter { public void close() throws InterruptedException { batch.clear(); abortRemainingTxns(); closeTxnBatch(); closeConnection(); closed = true; } }
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); }
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); @Override String toString(); int getRemainingTxns(); synchronized void write(final Event event); void flush(boolean rollToNext); void abort(); void heartBeat(); void close(); void closeConnection(); }
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); @Override String toString(); int getRemainingTxns(); synchronized void write(final Event event); void flush(boolean rollToNext); void abort(); void heartBeat(); void close(); void closeConnection();  }