У меня есть топология Storm, которая включает в себя болты, которые кэшируют кортежи для последующих массовых записей, которые гораздо более эффективны.При некоторых обстоятельствах я хочу сбросить эти кэши и сбросить (эти кортежи уже упакованы) кортежи, ожидающие записи.Я намереваюсь отправить кортеж вниз по течению, чтобы сигнализировать об этом сбросе.Кажется, что для этого можно использовать группировку «все группировки», но кроме примера того, как подключить носители (один для выдачи сигнала, а другой для обычного потока обработки) к нижестоящим кэшам, я смог найтинет более подробных примеров того, как болт, который выполняет кэширование, будет обрабатывать этот входной кортеж.Кто-нибудь знает исчерпывающий пример того, как использовать «все группировки» в этом контенте?