Hello! The code that you have provided will not have any edge over CacheStore.
I'm not sure that running two nodes on the same machine is a sound approach for benchmarking data load speed. Are you sure that performance is not sufficient? What is actual run time and your expectations? Regards, -- Ilya Kasnacheev вт, 18 февр. 2020 г. в 17:53, nithin91 < [email protected]>: > I am having two nodes running on local machine. > > Following is the logic i implemented to load data using Data Steamer.Can > you > please check whether the implementation is correct and also can you please > share sample code on how to push > entries to data streamer from multiple threads > > public class PerformanceCacheStore { > > public static void main(String[] args) throws Exception { > String url =".."; > > > > try( Ignite ignite = Ignition.start("Ignite-Client.xml"); > Connection conn = > DriverManager.getConnection(url,"..", ".."); > > PreparedStatement stmt = > conn.prepareStatement("select .. > where COUNTRY_CODE=? and > as_of_Date_Std=?"); > > > ) { > > IgniteDataStreamer<PieProductPerformanceKey, > PieProductPerformance> > stmr = ignite.dataStreamer("PieProductPerformanceCache"); > > stmt.setString(1,"USA"); > stmt.setString(2,"31-Dec-2019"); > > ResultSet rs = stmt.executeQuery(); > > > > while (rs.next()) { > PieProductPerformance perf=new > PieProductPerformance(); > /* > perf Setter Methods > > */ > > PieProductPerformanceKey perfkey=new > PieProductPerformanceKey(); > > /* > perfKey Setter Methods > > */ > > stmr.addData(perfkey, perf); > > } > > System.out.println("Completed"); > > } > > } > } > > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
