org.apache.storm.cassandra.trident.state

Class CassandraBackingMap.Options<T>

java.lang.Object

org.apache.storm.cassandra.trident.state.CassandraBackingMap.Options<T>

All Implemented Interfaces:

Serializable

Enclosing class:

CassandraBackingMap<T>

public static final class CassandraBackingMap.Options<T>
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Options(SimpleClientProvider clientProvider)

Method Summary

Modifier and Type	Method and Description
String	toString()
CassandraBackingMap.Options<T>	withGetMapper(CQLStatementTupleMapper getMapper)
CassandraBackingMap.Options<T>	withKeys(Fields keyFields)
CassandraBackingMap.Options<T>	withMaxParallelism(Integer maxParallelism)
CassandraBackingMap.Options<T>	withNonTransactionalBinaryState(String fieldName, Serializer<T> serializer)
CassandraBackingMap.Options<T>	withNonTransactionalJSONBinaryState(String fieldName)
CassandraBackingMap.Options<T>	withOpaqueBinaryState(String fieldName, Serializer<OpaqueValue<T>> serializer)
CassandraBackingMap.Options<T>	withOpaqueJSONBinaryState(String fieldName)
CassandraBackingMap.Options<T>	withPutMapper(CQLStatementTupleMapper putMapper)
CassandraBackingMap.Options<T>	withStateMapper(StateMapper<T> stateMapper)
CassandraBackingMap.Options<T>	withTransactionalBinaryState(String fieldName, Serializer<TransactionalValue<T>> serializer)
CassandraBackingMap.Options<T>	withTransactionalJSONBinaryState(String fieldName)

Methods inherited from class java.lang.Object

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

Constructor Detail

Options

public Options(SimpleClientProvider clientProvider)

Method Detail

withKeys

public CassandraBackingMap.Options<T> withKeys(Fields keyFields)

withStateMapper

public CassandraBackingMap.Options<T> withStateMapper(StateMapper<T> stateMapper)

withNonTransactionalJSONBinaryState

public CassandraBackingMap.Options<T> withNonTransactionalJSONBinaryState(String fieldName)

withNonTransactionalBinaryState

public CassandraBackingMap.Options<T> withNonTransactionalBinaryState(String fieldName,
                                                                      Serializer<T> serializer)

withTransactionalJSONBinaryState

public CassandraBackingMap.Options<T> withTransactionalJSONBinaryState(String fieldName)

withTransactionalBinaryState

public CassandraBackingMap.Options<T> withTransactionalBinaryState(String fieldName,
                                                                   Serializer<TransactionalValue<T>> serializer)

withOpaqueJSONBinaryState

public CassandraBackingMap.Options<T> withOpaqueJSONBinaryState(String fieldName)

withOpaqueBinaryState

public CassandraBackingMap.Options<T> withOpaqueBinaryState(String fieldName,
                                                            Serializer<OpaqueValue<T>> serializer)

withGetMapper

public CassandraBackingMap.Options<T> withGetMapper(CQLStatementTupleMapper getMapper)

withPutMapper

public CassandraBackingMap.Options<T> withPutMapper(CQLStatementTupleMapper putMapper)

withMaxParallelism

public CassandraBackingMap.Options<T> withMaxParallelism(Integer maxParallelism)

toString

public String toString()

Overrides:

toString in class Object