streamer-test.java

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteDataStreamer;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.DataRegionConfiguration;
import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.util.IgniteStopwatch;

public class Program {
    public static void main(String[] args) {
        IgniteConfiguration serverCfg = new IgniteConfiguration()
                .setDataStorageConfiguration(
                        new DataStorageConfiguration()
                                .setDefaultDataRegionConfiguration(
                                        new DataRegionConfiguration().setName("default").setMaxSize(16000000000L)));

        IgniteConfiguration clientCfg = new IgniteConfiguration().setClientMode(true).setIgniteInstanceName("client");

        Ignite server = Ignition.start(serverCfg);
        Ignite client = Ignition.start(clientCfg);

        client.createCache("c");
        IgniteDataStreamer<Object, Object> streamer = client.dataStreamer("c");
        IgniteStopwatch sw = IgniteStopwatch.createStarted();

        for (int i = 0; i < 100000000; i++) {
            streamer.addData(i, i);

            if (i % 1000000 == 0) {
                System.out.println(i + " " + sw.elapsed() + " " + server.dataRegionMetrics("default").getPhysicalMemorySize() / 1000000000.0 + "GB");
            }
        }

        streamer.close();

        // i7-9700K, Ubuntu 20: 54 seconds, 7.4 GB data
        System.out.println(sw.elapsed());
    }
}