org.apache.storm.cassandra.query

Interface ContextQuery

All Superinterfaces:

Serializable

All Known Implementing Classes:

ContextQuery.BoundQueryContext, ContextQuery.BoundQueryNamedByFieldContext, ContextQuery.StaticContextQuery

public interface ContextQuery
extends Serializable

This interface may be used to retrieve a cassandra bound query either from storm config or the tuple being proceed.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ContextQuery.BoundQueryContext Default ContextQuery.BoundQueryContext implementation to retrieve a bound query identified by the provided key.
static class	ContextQuery.BoundQueryNamedByFieldContext Default ContextQuery.BoundQueryNamedByFieldContext implementation to retrieve a bound query named by the value of a specified tuple field.
static class	ContextQuery.StaticContextQuery Static implementation of ContextQuery interface.

Method Summary

Modifier and Type	Method and Description
String	resolves(Map<String,Object> config, ITuple tuple) Resolves a cassandra bound query.

Method Detail

resolves

String resolves(Map<String,Object> config,
                ITuple tuple)

Resolves a cassandra bound query.

Parameters:

config - the storm configuration

tuple - the tuple being proceed.

Returns:

a string bound query.