Политика выселения на основе времени в Apache Ignite

#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. Привет, Валентин. извините, что сообщил вам поздно, это сработало. Спасибо.