Package com.illumon.iris.importers.merge

Class SyncOperator.ExecutorDriven

java.lang.Object

com.illumon.iris.importers.merge.SyncOperator.ExecutorDriven

All Implemented Interfaces:

SyncOperator

Direct Known Subclasses:

SyncOperator.Concurrent, SyncOperator.Final

Enclosing interface:

SyncOperator

public abstract static class SyncOperator.ExecutorDriven
extends Object
implements SyncOperator

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.importers.merge.SyncOperator

SyncOperator.Concurrent, SyncOperator.ExecutorDriven, SyncOperator.Final, SyncOperator.Immediate

Method Summary

Modifier and Type	Method	Description
boolean	awaitAll(long timeout, TimeUnit timeoutUnit)	Await successful termination of all synchronization tasks.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.illumon.iris.importers.merge.SyncOperator

finished, submitSyncTask

Method Details

awaitAll

public boolean awaitAll(long timeout, @NotNull TimeUnit timeoutUnit) throws InterruptedException, ExecutionException

Description copied from interface: SyncOperator

Await successful termination of all synchronization tasks.

Specified by:

awaitAll in interface SyncOperator

Parameters:

timeout - The timeout

timeoutUnit - Units for the timeout

Returns:

True on success, false if timed out

Throws:

InterruptedException - If this thread was interrupted while awaiting termination

ExecutionException - If one of the synchronization tasks reported an execution exception