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 © 2022 The Apache Software Foundation. All rights reserved.