Можно ли в GridGain 6 получить экземпляр GridStreamer на удаленном узле и использовать его для добавления событий?
Идея в том, что мне нужна нода, которая может генерировать данные для потоковой обработки, но не участвовать в самой обработке.
Все узлы, запущенные с разделом StreamConfiguration, автоматически участвуют в обработке событий. А если нода запущена без секции StreamConfiguration — то ее Grid-экземпляр не видит других стримеров.
GridClient, похоже, не поддерживает потоковую передачу
Вы не можете получить экземпляр стримера на узле, на котором не настроен этот конкретный стример. Однако вы можете легко выполнить свое требование, предоставив GridStreamerEventRouter, который не будет направлять события на узлы, которые не должны участвовать в обработке событий.
Например, вы можете использовать маршрутизатор случайных событий с предикатом, который будет фильтровать узлы по пользовательскому атрибуту (вы можете установить пользовательские атрибуты для узла с помощью GridConfiguration.setUserAttributes(...)):
GridStreamerConfiguration streamCfg = new GridStreamerConfiguration();
//...
streamCfg.setRouter(new GridStreamerRandomEventRouter(new GridPredicate<GridNode>() {
@Override public boolean apply(GridNode node) {
return !"CLIENT".equals(node.attribute("STREAMER_ROLE"));
}
}));
