@Test public void cleanup() { processor.cleanup(); }
@OnStopped public void cleanup() { validationResourceHolder.set(null); ComponentLog log = getLogger(); if (callTimeoutPool != null) { callTimeoutPool.shutdown(); try { while (!callTimeoutPool.isTerminated()) { callTimeoutPool.awaitTermination(callTimeout, TimeUnit.MILLISECONDS); } } catch (Throwable t) { log.warn("shutdown interrupted on " + callTimeoutPool, t); } callTimeoutPool = null; } ugi = null; }
PutHive3Streaming extends AbstractProcessor { @OnStopped public void cleanup() { validationResourceHolder.set(null); ComponentLog log = getLogger(); if (callTimeoutPool != null) { callTimeoutPool.shutdown(); try { while (!callTimeoutPool.isTerminated()) { callTimeoutPool.awaitTermination(callTimeout, TimeUnit.MILLISECONDS); } } catch (Throwable t) { log.warn("shutdown interrupted on " + callTimeoutPool, t); } callTimeoutPool = null; } ugi = null; } }
PutHive3Streaming extends AbstractProcessor { @OnStopped public void cleanup() { validationResourceHolder.set(null); ComponentLog log = getLogger(); if (callTimeoutPool != null) { callTimeoutPool.shutdown(); try { while (!callTimeoutPool.isTerminated()) { callTimeoutPool.awaitTermination(callTimeout, TimeUnit.MILLISECONDS); } } catch (Throwable t) { log.warn("shutdown interrupted on " + callTimeoutPool, t); } callTimeoutPool = null; } ugi = null; }  }
PutHive3Streaming extends AbstractProcessor { @OnStopped public void cleanup() { validationResourceHolder.set(null); ComponentLog log = getLogger(); if (callTimeoutPool != null) { callTimeoutPool.shutdown(); try { while (!callTimeoutPool.isTerminated()) { callTimeoutPool.awaitTermination(callTimeout, TimeUnit.MILLISECONDS); } } catch (Throwable t) { log.warn("shutdown interrupted on " + callTimeoutPool, t); } callTimeoutPool = null; } ugi = null; }  @Override Set<Relationship> getRelationships(); @OnScheduled void setup(final ProcessContext context); void onTrigger(ProcessContext context, ProcessSession session); @OnStopped void cleanup(); }
PutHive3Streaming extends AbstractProcessor { @OnStopped public void cleanup() { validationResourceHolder.set(null); ComponentLog log = getLogger(); if (callTimeoutPool != null) { callTimeoutPool.shutdown(); try { while (!callTimeoutPool.isTerminated()) { callTimeoutPool.awaitTermination(callTimeout, TimeUnit.MILLISECONDS); } } catch (Throwable t) { log.warn("shutdown interrupted on " + callTimeoutPool, t); } callTimeoutPool = null; } ugi = null; }  @Override Set<Relationship> getRelationships(); @OnScheduled void setup(final ProcessContext context); void onTrigger(ProcessContext context, ProcessSession session); @OnStopped void cleanup(); static final String HIVE_STREAMING_RECORD_COUNT_ATTR; static final Relationship REL_SUCCESS; static final Relationship REL_FAILURE; static final Relationship REL_RETRY; }