Thanks in advance. (This may be duplicate, as I forgot to put few other
details. )
I am basically using the sample xml provided for Ignite
TcpDiscoveryVmIpFinder, but with Cassandra third party persistence.
public Ignite startIgnite {
IgniteConfiguration cfg = new IgniteConfiguration();
CacheConfiguration<String, POJOExample> configuration = new
CacheConfiguration<String, POJOExample>();
configuration.setName("test-cache");
configuration.setIndexedTypes(String.class, POJOExample.class);
DataSource dataSource = new DataSource();
dataSource.setContactPoints("111.111.111.111"); // Here, I am basically
putting my remote server addresses.
RoundRobinPolicy robinPolicy = new RoundRobinPolicy();
dataSource.setLoadBalancingPolicy(robinPolicy);
dataSource.setReadConsistency("ONE");
dataSource.setWriteConsistency("ONE");
String persistenceSettingsXml = FileUtils.readFileToString(new
File(persistenceSettingsConfig), "utf-8");
KeyValuePersistenceSettings persistenceSettings = new
KeyValuePersistenceSettings(persistenceSettingsXml);
CassandraCacheStoreFactory cacheStoreFactory = new
CassandraCacheStoreFactory();
cacheStoreFactory.setDataSource(dataSource);
cacheStoreFactory.setPersistenceSettings(persistenceSettings);
configuration.setCacheStoreFactory(cacheStoreFactory);
configuration.setWriteThrough(true);
configuration.setReadThrough(true);
configuration.setWriteBehindEnabled(true);
// Setting cache configuration
cfg.setCacheConfiguration(configuration);
TcpDiscoverySpi spi = setTcp();
cfg.setPeerClassLoadingEnabled(true);
cfg.setDeploymentMode(DeploymentMode.CONTINUOUS);
cfg.setClientConnectorConfiguration(new ClientConnectorConfiguration());
// Override default discovery SPI.
cfg.setDiscoverySpi(spi);
// Starting Ignite
Ignite ignite = Ignition.getOrStart(cfg);
return ignite;
}
public TcpDiscoverySpi setTcp() {
TcpDiscoverySpi spi = new TcpDiscoverySpi();
TcpDiscoveryVmIpFinder ipFinder = new
TcpDiscoveryVmIpFinder();
// Set initial IP addresses.
// Note that you can optionally specify a port or a port
range.
ipFinder.setAddresses(Arrays.asList("111.111.111.111:47500..47509"));
spi.setIpFinder(ipFinder);
return spi;
}
Persistency Settings:
<persistence keyspace="ignite" table="odbc_test" ttl="86400">
<keyspaceOptions>
REPLICATION = {'class' : 'SimpleStrategy', 'replication_factor' : 1}
AND DURABLE_WRITES = true
</keyspaceOptions>
<tableOption>
comment = 'Cache test'
AND read_repair_chance = 0.2
</tableOption>
<keyPersistence class="java.lang.String" strategy="PRIMITIVE"
column="key"/>
<valuePersistence class="com.sample.ignite.POJOExample"
strategy="POJO"/>
</persistence>
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
