public class AsyncExecutorProvider extends Object
This class must be used to obtain a single instance of AsyncExecutor per storm executor.
| Constructor and Description |
|---|
AsyncExecutorProvider() |
| 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. |
public static <T> AsyncExecutor getLocal(com.datastax.driver.core.Session session, AsyncResultHandler<T> handler)
Returns a new AsyncExecutor per storm executor.
Copyright © 2021 The Apache Software Foundation. All rights reserved.