org.apache.storm.cassandra.executor

Class ExecutionResultCollector.SucceedCollector

java.lang.Object

org.apache.storm.cassandra.executor.ExecutionResultCollector.SucceedCollector

All Implemented Interfaces:

ExecutionResultCollector

Enclosing interface:

ExecutionResultCollector

public static final class ExecutionResultCollector.SucceedCollector
extends Object
implements ExecutionResultCollector

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.cassandra.executor.ExecutionResultCollector

ExecutionResultCollector.FailedCollector, ExecutionResultCollector.SucceedCollector

Constructor Summary

Constructors

Constructor and Description
SucceedCollector(List<Tuple> inputs) Creates a new ExecutionResultCollector instance.
SucceedCollector(Tuple input) Creates a new ExecutionResultCollector instance.

Method Summary

Modifier and Type	Method and Description
void	handle(OutputCollector collector, ExecutionResultHandler handler) Calls ExecutionResultHandler.onQuerySuccess(org.apache.storm.task.OutputCollector, org.apache.storm.tuple.Tuple) before acknowledging an single input tuple.

Methods inherited from class java.lang.Object

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

Constructor Detail

SucceedCollector

public SucceedCollector(Tuple input)

Creates a new ExecutionResultCollector instance.

Parameters:

input - the input tuple.

SucceedCollector

public SucceedCollector(List<Tuple> inputs)

Creates a new ExecutionResultCollector instance.

Parameters:

inputs - the input tuple.

Method Detail

handle

public void handle(OutputCollector collector,
                   ExecutionResultHandler handler)

Calls ExecutionResultHandler.onQuerySuccess(org.apache.storm.task.OutputCollector, org.apache.storm.tuple.Tuple) before acknowledging an single input tuple.

Specified by:

handle in interface ExecutionResultCollector