Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- TcpDiscoverySpi discoSpi = 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("10.0.0.xxx"));
- discoSpi.setIpFinder(ipFinder);
- IgniteConfiguration igniteCfg = new IgniteConfiguration();
- igniteCfg.setMarshaller(new OptimizedMarshaller(true));
- igniteCfg.setPeerClassLoadingEnabled(false);
- igniteCfg.setDiscoverySpi(discoSpi);
- CacheConfiguration<Long, com.xxx.model.MyExtPrimModel> myCfg = new CacheConfiguration<>(CACHE_NAME);
- myCfg.setCacheMode(CacheMode.PARTITIONED);
- myCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
- myCfg.setManagementEnabled(true);
- if(cacheMode.equalsIgnoreCase("off-heap")) {
- myCfg.setMemoryMode(CacheMemoryMode.OFFHEAP_TIERED);
- myCfg.setOffHeapMaxMemory(offHeapSizeGb * 1024L * 1024L * 1024L);
- }
- FifoEvictionPolicy evctPolicy = new FifoEvictionPolicy();
- // Store only 100,000 entries on-heap.
- evctPolicy.setMaxSize(maxEviction);
- myCfg.setEvictionPolicy(evctPolicy);
- myCfg.setBackups(1);
- myCfg.setIndexedTypes(Long.class, com.xxx.model.MyExtPrimModel.class);
- ignite = Ignition.start(igniteCfg);
- cache = ignite.getOrCreateCache(myCfg).withAsync();
Advertisement
Add Comment
Please, Sign In to add comment