IgniteTester.java

import java.time.Duration;
import java.util.Arrays;
import java.util.Optional;
import java.util.logging.Logger;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;

/**
 *
 * @author yigit
 */
public class App {
    
  public static void main(String[] args) {

    IgniteConfiguration cfg = new IgniteConfiguration();
        
    cfg.setClientMode(true); /* CLIENT NODE */
        
    cfg.setWorkDirectory("/tmp/");

    /* REPLACE WITH ACTUAL IPs*/
    TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
    ipFinder.setAddresses(Arrays.asList("IP OF NODE01","IP OF NODE02"));

    cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder));

    /* STARTING LOCAL CLIENT NODE */
    Ignite ignite=Ignition.start(cfg);
        
    /* GETTING THE REPLICATED CACHE BY ITS NAME */
    IgniteCache cache=ignite.getOrCreateCache("myReplicatedCache");