#hazelcast #ignite
#hazelcast #ignite
Вопрос:
Как и у Hazelcast, у слушателя есть выселение на основе времени, есть ли такая политика в кэше Ignite Apache.
Я пытался,
setExpiryPolicyFactory(FactoryBuilder.factoryOf( new CreatedExpiryPolicy(new Duration(TimeUnit.SECONDS, 123))));
но это выселение на уровне кэша, мне нужна энергия состояния выселения начального уровня.
Можете ли вы предложить мне какую-либо политику или любой другой способ.
Ответ №1:
Вы можете сделать это следующим образом:
cache.withExpiryPolicy(new CreatedExpiryPolicy(new Duration(TimeUnit.SECONDS, 123))).put(k, v);
Срок действия будет применен только к этой записи.
Комментарии:
1. Спасибо. Еще одна вещь, которую нужно добавить. Как я могу отправить просроченную запись для конкретного слушателя. Как и в Hazelcast, мы можем добавить слушателя с помощью HazelcastInstance.GetMap().addEntryListener(«Класс _Some_Listener»). Есть ли какой-либо способ для Ignite.
2. Похоже, вы можете попробовать непрерывные запросы: apacheignite.readme.io/docs/continuous-queries
3. Привет, Валентин. извините, что сообщил вам поздно, это сработало. Спасибо.