Package | Description |
---|---|
org.apache.storm.cassandra | |
org.apache.storm.cassandra.bolt | |
org.apache.storm.cassandra.executor | |
org.apache.storm.cassandra.executor.impl |
Modifier and Type | Class and Description |
---|---|
class |
AbstractExecutionResultHandler
Default interface to define strategies to apply when a query is either succeed or failed.
|
class |
BaseExecutionResultHandler
Simple
ExecutionResultHandler which fail the incoming tuple when an DriverException is thrown. |
Modifier and Type | Method and Description |
---|---|
protected ExecutionResultHandler |
BaseCassandraBolt.getResultHandler() |
Modifier and Type | Method and Description |
---|---|
BaseCassandraBolt |
BaseCassandraBolt.withResultHandler(ExecutionResultHandler resultHandler) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionResultCollector.handle(OutputCollector collector,
ExecutionResultHandler handler) |
void |
ExecutionResultCollector.SucceedCollector.handle(OutputCollector collector,
ExecutionResultHandler handler)
Calls
onQuerySuccess(org.apache.storm.task.OutputCollector, org.apache.storm.tuple.Tuple) before acknowledging an single input tuple. |
void |
ExecutionResultCollector.FailedCollector.handle(OutputCollector collector,
ExecutionResultHandler handler)
|
Constructor and Description |
---|
BatchAsyncResultHandler(ExecutionResultHandler handler)
Creates a new
BatchAsyncResultHandler instance. |
SingleAsyncResultHandler(ExecutionResultHandler handler)
Creates a new
SingleAsyncResultHandler instance. |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.