brilliant thanks it is working

here is the code for anyone else that will find this useful.

val igniteContext = new IgniteContext(sc, () =>{
                val tcpDiscoverySpi: TcpDiscoverySpi = new TcpDiscoverySpi
                val ipFinder: TcpDiscoveryVmIpFinder = new 
TcpDiscoveryVmIpFinder
                val addressList: java.util.List[String] = new 
java.util.ArrayList[String]
                addressList.add("127.0.0.1:47500")
                ipFinder.setAddresses(addressList)
                tcpDiscoverySpi.setIpFinder(ipFinder)
                tcpDiscoverySpi.setLocalAddress("127.0.0.1") 
                val igniteConf : IgniteConfiguration = new
IgniteConfiguration().setClientMode(true).setDiscoverySpi(tcpDiscoverySpi)
                igniteConf})



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Reply via email to