org.apache.storm.sql.runtime

Class AbstractValuesProcessor

java.lang.Object

org.apache.storm.sql.runtime.AbstractValuesProcessor

public abstract class AbstractValuesProcessor
extends Object

Subclass of AbstractTupleProcessor provides a series of tuple. It takes a series of iterators of Values and produces a stream of tuple.

The subclass implements the next() method to provide the output of the stream. It can choose to return null in next() to indicate that this particular iteration is a no-op. SQL processors depend on this semantic to implement filtering and nullable records.

Constructor Summary

Constructors

Constructor and Description
AbstractValuesProcessor()

Method Summary

Modifier and Type	Method and Description
abstract void	initialize(Map<String,DataSource> data, ChannelHandler result) Initialize the data sources.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractValuesProcessor

public AbstractValuesProcessor()

Method Detail

initialize

public abstract void initialize(Map<String,DataSource> data,
                                ChannelHandler result)

Initialize the data sources.

Parameters:

data - a map from the table name to the iterators of the values.