The running machine is 12 cores, which we put into 12 partitions and rules are evenly split across partitions. This is all organised by the engine, and not end user code. There are still a lot more improvements we can do, to get more optimal rule to partition assignment and to avoid sending all data to all partitions.
Next we’ll be turning out attention to long running fireUntilHalt stream use cases.
We don’t have any code yet that others can run, as it’s still a bit of hack. But as we progress, we’ll tidy things up and try and get it so others can try it.