public void startPartitionWatch() throws InterruptedException, ExecutionException {
        Future<?> task = m_es.submit(new PartitionWatchEvent());
        task.get();
    }
public void startPartitionWatch ( ) throws InterruptedException , ExecutionException { Future < ? > task = m_es . submit ( new PartitionWatchEvent ( ) ) ; task . get ( ) ; }
Initialized and start watching partition level cache, this function is blocking.
@throws InterruptedException
@throws ExecutionException