You can now set additional options in the configuration map.
public static final String TRIDENT_CASSANDRA_CQL_HOSTS = "trident.cassandra.cql.hosts";
public static final String TRIDENT_CASSANDRA_COMPRESSION = "trident.cassandra.compression";
public static final String TRIDENT_CASSANDRA_CONNECT_TIMEOUT = "trident.cassandra.connect.timeout";
public static final String TRIDENT_CASSANDRA_READ_TIMEOUT = "trident.cassandra.read.timeout";
public static final String TRIDENT_CASSANDRA_CLUSTER_NAME = "trident.cassandra.cluster.name";
public static final String TRIDENT_CASSANDRA_LOCAL_DATA_CENTER_NAME = "trident.cassandra.local.data.center.name";
public static final String TRIDENT_CASSANDRA_CONSISTENCY = "trident.cassandra.consistency";
public static final String TRIDENT_CASSANDRA_SERIAL_CONSISTENCY = "trident.cassandra.serial.consistency";
Also, CqlClientFactory is now abstract which allows us to configure them in different ways (ie, spring) when reusing code in a non-storm context.
You can now set additional options in the configuration map.
Also, CqlClientFactory is now abstract which allows us to configure them in different ways (ie, spring) when reusing code in a non-storm context.