Начиная с текущей версии (0.3) преимущество Jet перед отправкой Runnable
в каждый раздел - это возможность выполнять группировку с помощью ключа, отличного от того, который используется в карте Hazelcast. Чтобы это работало в распределенной среде, вы должны отправить каждый элемент в блок обработки, отвечающий за его групповой ключ, и это то, что легко получить от Jet.
Кроме того, вы можете построить многоступенчатый каскад операций groupBy
, вы можете иметь вилки в потоке данных для повторного использования одного и того же промежуточного результата несколькими способами, вы можете построить конвейер, где распределяется задача ввода-вывода обработка данных, которые он считывает по всем ядрам ЦП и т. д., короче говоря, все преимущества, которые предлагает полномасштабный механизм расчета DAG.
К тому времени, когда он достигнет 1.0, Jet также будет поддерживать отказоустойчивую бесконечную обработку потока, окна с временным временем и многое другое.