org.apache.storm.sql.runtime

Interface ChannelHandler

All Known Implementing Classes:

AbstractChannelHandler

public interface ChannelHandler

DataListener provides an event-driven interface for the user to process series of events.

Method Summary

Modifier and Type	Method and Description
void	channelInactive(ChannelContext ctx) The producer of the data has indicated that the channel is no longer active.
void	dataReceived(ChannelContext ctx, Values data)
void	exceptionCaught(Throwable cause)
void	flush(ChannelContext ctx)
void	setSource(ChannelContext ctx, Object source)

Method Detail

dataReceived

void dataReceived(ChannelContext ctx,
                  Values data)

channelInactive

void channelInactive(ChannelContext ctx)

The producer of the data has indicated that the channel is no longer active.

Parameters:

ctx -

exceptionCaught

void exceptionCaught(Throwable cause)

flush

void flush(ChannelContext ctx)

setSource

void setSource(ChannelContext ctx,
               Object source)