org.apache.storm.cassandra.executor

Class AsyncExecutorProvider

java.lang.Object

org.apache.storm.cassandra.executor.AsyncExecutorProvider

public class AsyncExecutorProvider
extends Object

This class must be used to obtain a single instance of AsyncExecutor per storm executor.

Constructor Summary

Constructors

Constructor and Description
AsyncExecutorProvider()

Method Summary

Modifier and Type	Method and Description
static <T> AsyncExecutor	getLocal(com.datastax.driver.core.Session session, AsyncResultHandler<T> handler) Returns a new AsyncExecutor per storm executor.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncExecutorProvider

public AsyncExecutorProvider()

Method Detail

getLocal

public static <T> AsyncExecutor getLocal(com.datastax.driver.core.Session session,
                                         AsyncResultHandler<T> handler)

Returns a new AsyncExecutor per storm executor.