org.springframework.xd.cassandra

Class CassandraSinkOptionsMetadata

java.lang.Object

org.springframework.xd.cassandra.CassandraSinkOptionsMetadata

public class CassandraSinkOptionsMetadata
extends java.lang.Object

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor and Description
CassandraSinkOptionsMetadata()

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.cassandra.core.ConsistencyLevel	getConsistencyLevel()
java.lang.String	getIngestQuery()
org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type	getQueryType()
org.springframework.cassandra.core.RetryPolicy	getRetryPolicy()
java.lang.String	getStatementExpression()
int	getTtl()
void	setConsistencyLevel(org.springframework.cassandra.core.ConsistencyLevel consistencyLevel)
void	setIngestQuery(java.lang.String ingestQuery)
void	setQueryType(org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type queryType)
void	setRetryPolicy(org.springframework.cassandra.core.RetryPolicy retryPolicy)
void	setStatementExpression(java.lang.String statementExpression)
void	setTtl(int ttl)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSinkOptionsMetadata

public CassandraSinkOptionsMetadata()

Method Detail

setConsistencyLevel

public void setConsistencyLevel(org.springframework.cassandra.core.ConsistencyLevel consistencyLevel)

setRetryPolicy

public void setRetryPolicy(org.springframework.cassandra.core.RetryPolicy retryPolicy)

setTtl

public void setTtl(int ttl)

setQueryType

public void setQueryType(org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type queryType)

setIngestQuery

public void setIngestQuery(java.lang.String ingestQuery)

setStatementExpression

public void setStatementExpression(java.lang.String statementExpression)

getConsistencyLevel

public org.springframework.cassandra.core.ConsistencyLevel getConsistencyLevel()

getRetryPolicy

public org.springframework.cassandra.core.RetryPolicy getRetryPolicy()

getTtl

@Min(value=0L)
public int getTtl()

getQueryType

@NotNull
public org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type getQueryType()

getIngestQuery

public java.lang.String getIngestQuery()

getStatementExpression

public java.lang.String getStatementExpression()