org.apache.streams.cassandra

Class CassandraConfiguration

java.lang.Object

org.apache.streams.cassandra.CassandraConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class CassandraConfiguration
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CassandraConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
String	getColumn() Column name
List<String>	getHosts() Cassandra hosts
String	getKeyspace() Keyspace
String	getPartitionKeyColumn() Partition Key column name
String	getPassword() Password
Long	getPort() Cassandra port
Ssl	getSsl() ssl details
String	getTable() Table
String	getUser() User
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setColumn(String column) Column name
void	setHosts(List<String> hosts) Cassandra hosts
void	setKeyspace(String keyspace) Keyspace
void	setPartitionKeyColumn(String partitionKeyColumn) Partition Key column name
void	setPassword(String password) Password
void	setPort(Long port) Cassandra port
void	setSsl(Ssl ssl) ssl details
void	setTable(String table) Table
void	setUser(String user) User
String	toString()
CassandraConfiguration	withAdditionalProperty(String name, Object value)
CassandraConfiguration	withColumn(String column)
CassandraConfiguration	withHosts(List<String> hosts)
CassandraConfiguration	withKeyspace(String keyspace)
CassandraConfiguration	withPartitionKeyColumn(String partitionKeyColumn)
CassandraConfiguration	withPassword(String password)
CassandraConfiguration	withPort(Long port)
CassandraConfiguration	withSsl(Ssl ssl)
CassandraConfiguration	withTable(String table)
CassandraConfiguration	withUser(String user)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CassandraConfiguration

public CassandraConfiguration()

Method Detail

getHosts

@BeanProperty(value="hosts")
public List<String> getHosts()

Cassandra hosts

Returns:

The hosts

setHosts

@BeanProperty(value="hosts")
public void setHosts(List<String> hosts)

Cassandra hosts

Parameters:

hosts - The hosts

withHosts

public CassandraConfiguration withHosts(List<String> hosts)

getPort

@BeanProperty(value="port")
public Long getPort()

Cassandra port

Returns:

The port

setPort

@BeanProperty(value="port")
public void setPort(Long port)

Cassandra port

Parameters:

port - The port

withPort

public CassandraConfiguration withPort(Long port)

getUser

@BeanProperty(value="user")
public String getUser()

User

Returns:

The user

setUser

@BeanProperty(value="user")
public void setUser(String user)

User

Parameters:

user - The user

withUser

public CassandraConfiguration withUser(String user)

getPassword

@BeanProperty(value="password")
public String getPassword()

Password

Returns:

The password

setPassword

@BeanProperty(value="password")
public void setPassword(String password)

Password

Parameters:

password - The password

withPassword

public CassandraConfiguration withPassword(String password)

getKeyspace

@BeanProperty(value="keyspace")
public String getKeyspace()

Keyspace

Returns:

The keyspace

setKeyspace

@BeanProperty(value="keyspace")
public void setKeyspace(String keyspace)

Keyspace

Parameters:

keyspace - The keyspace

withKeyspace

public CassandraConfiguration withKeyspace(String keyspace)

getTable

@BeanProperty(value="table")
public String getTable()

Table

Returns:

The table

setTable

@BeanProperty(value="table")
public void setTable(String table)

Table

Parameters:

table - The table

withTable

public CassandraConfiguration withTable(String table)

getPartitionKeyColumn

@BeanProperty(value="partitionKeyColumn")
public String getPartitionKeyColumn()

Partition Key column name

Returns:

The partitionKeyColumn

setPartitionKeyColumn

@BeanProperty(value="partitionKeyColumn")
public void setPartitionKeyColumn(String partitionKeyColumn)

Partition Key column name

Parameters:

partitionKeyColumn - The partitionKeyColumn

withPartitionKeyColumn

public CassandraConfiguration withPartitionKeyColumn(String partitionKeyColumn)

getColumn

@BeanProperty(value="column")
public String getColumn()

Column name

Returns:

The column

setColumn

@BeanProperty(value="column")
public void setColumn(String column)

Column name

Parameters:

column - The column

withColumn

public CassandraConfiguration withColumn(String column)

getSsl

@BeanProperty(value="ssl")
public Ssl getSsl()

ssl details

Returns:

The ssl

setSsl

@BeanProperty(value="ssl")
public void setSsl(Ssl ssl)

ssl details

Parameters:

ssl - The ssl

withSsl

public CassandraConfiguration withSsl(Ssl ssl)

toString

public String toString()

Overrides:

toString in class Object

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

withAdditionalProperty

public CassandraConfiguration withAdditionalProperty(String name,
                                                     Object value)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object