Guest User

Ignite config

a guest
Sep 17th, 2015
87
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.26 KB | None | 0 0
  1. TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
  2. TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
  3.  
  4. // Set initial IP addresses.
  5. // Note that you can optionally specify a port or a port range.
  6. ipFinder.setAddresses(Arrays.asList("10.0.0.xxx"));
  7. discoSpi.setIpFinder(ipFinder);                        
  8.  
  9. IgniteConfiguration igniteCfg = new IgniteConfiguration();
  10. igniteCfg.setMarshaller(new OptimizedMarshaller(true));
  11. igniteCfg.setPeerClassLoadingEnabled(false);
  12. igniteCfg.setDiscoverySpi(discoSpi);
  13.  
  14. CacheConfiguration<Long, com.xxx.model.MyExtPrimModel> myCfg = new CacheConfiguration<>(CACHE_NAME);
  15. myCfg.setCacheMode(CacheMode.PARTITIONED);
  16. myCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
  17. myCfg.setManagementEnabled(true);
  18.  
  19.  
  20. if(cacheMode.equalsIgnoreCase("off-heap")) {
  21.     myCfg.setMemoryMode(CacheMemoryMode.OFFHEAP_TIERED);
  22.     myCfg.setOffHeapMaxMemory(offHeapSizeGb * 1024L * 1024L * 1024L);
  23. }
  24.  
  25. FifoEvictionPolicy evctPolicy = new FifoEvictionPolicy();
  26.  
  27. // Store only 100,000 entries on-heap.
  28. evctPolicy.setMaxSize(maxEviction);
  29.  
  30. myCfg.setEvictionPolicy(evctPolicy);
  31.  
  32.  
  33. myCfg.setBackups(1);
  34.  
  35. myCfg.setIndexedTypes(Long.class, com.xxx.model.MyExtPrimModel.class);
  36.  
  37. ignite = Ignition.start(igniteCfg);
  38.  
  39. cache = ignite.getOrCreateCache(myCfg).withAsync();
Advertisement
Add Comment
Please, Sign In to add comment