low-latency

Is your feature request related to a problem? Please describe.
So I'm working on a product that should allow schema-less ingestion out of the box. So my default ingestion method is via the influx line protocol.

But my challenge is that I also need to add indexes to some of the tags (symbols) after table creation. The problem is that the Influx Line protocol holds a lock to the table makin

This test throws NPE:

public class TestSlowAsyncMapper {
    @Test
    public void foo() {
        var hz = Hazelcast.newHazelcastInstance(newConfig());
        hz.getJet().newJob(newPipeline()).join();
    }

    private Pipeline newPipeline() {
        var p = Pipeline.create();
        p.readFrom(TestSources.itemStream(Integer.MAX_VALUE))
                .withNativeTimestamp

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource