У меня есть сетка данных Ignite из пяти серверов (скажем, A, B, C, D и E). Разделенный кэш был распределен между этими пятью серверами с числом резервных копий, равным 1.
Я хочу хранить 100 миллионов записей в этом секционированном кеше. Но я хочу контролировать разбиение записей моего кеша на серверы Ignite.
Возможно ли, чтобы мой клиент Ignite поместил запись в кэш на определенный сервер (скажем, E)?
Единственный способ сделать это — реализовать собственную Функция сходства вместо тех, которые предоставляются из коробки. Однако я бы посоветовал вам переосмыслить этот подход, потому что он не масштабируется. Функции Affinity, включенные в Ignite, предназначены для обеспечения равномерного распределения на любом наборе узлов, поэтому вы можете динамически масштабировать вверх и вниз, когда вам это нужно. Ваш подход гораздо менее гибкий.
Также я бы порекомендовал вам просмотреть страницу документации о Affinity Collocation. Скорее всего, это даст вам подсказки о том, как лучше реализовать вашу логику.
И, наконец, не могли бы вы дать более подробную информацию о вашем варианте использования? Я буду рад дать несколько советов о том, как подойти к этому.
Affinity API, который можно получить с помощью Ignite.affinity() метода. Но для отправки совмещенного закрытия вы можете просто использовать методы IgniteCompute.affinityRun() и IgniteCompute.affinityCall().
- person Valentin Kulichenko; 13.12.2016
Affinity API для ручного расчета сопоставления. Я имел в виду только то, что affinityRun(), affinityCall() сделают эту работу за вас автоматически. Эти методы также гарантируют, что разделы не будут вытеснены до завершения ваших вычислений.
- person Valentin Kulichenko; 14.12.2016
