Я использую Kryo для десериализации класса, первоначально сериализованного в Spark.Kryo записывает...

Каков предпочтительный способ расширения сериализаторов в Kryo? Скажем, у меня есть класс B,...

Я пытаюсь зарегистрировать класс с массивом (Spark Java с активированным Kryo), журнал показывает...

Я использую Spark 2.4 и ссылаюсь на https://spark.apache.org/docs/latest/rdd-programming-guide

Я пытаюсь использовать Kryo Serializer в качестве serailzer по умолчанию в SpringBoot 2.1.Однако...

Я отправляю объект, который содержит большой трехмерный массив размером 2х45х45.В каждом слоте есть...

Я пытаюсь переписать алгоритм сопоставления карт Graphhopper в искру.Я хочу передать «информацию о...

Я получаю сообщение об ошибке, в котором говорится: «Нет настроенных привязок сериализации для...

У меня есть несколько весенних загрузочных приложений, запущенных покоем, и я хочу ускорить...

Я получаю следующую ошибку в моем приложении spark, когда оно пытается сериализовать поле protobuf,...

У меня есть проект Akka-cluster, разработанный на Java.Где я использовал сериализацию крио.Как я...

Просто общий вопрос, у меня есть приложение для потокового воспроизведения, которое получает данные...

У меня есть веб-приложение Java, которое подключается к Corda через RPC.Corda развернут Docker на...

Я пытаюсь зарегистрироваться ниже класса для сериализации Kryo в коде искры, но я получаю сообщение...

Я использую Kryo 5.0.0-RC1.У меня есть следующее исключение: java.lang.IndexOutOfBoundsException:...

1-Проблема У меня есть программа Spark , в которой используется Kryo , но не как часть Механика...

Я перехожу с Spark 1.6 на 2.3. Мне нужно зарегистрировать пользовательские классы в Kryo.Итак, что...

Я пытаюсь понять следующее утверждение из документации: Если конкретный класс объекта неизвестен и...

Я пытаюсь использовать библиотеку akka-kryo-serializer. Мне удается заставить его работать со...

При использовании Kryo обычно рекомендуется регистрировать классы, которые вы собираетесь...

Я получаю объект protobuf от Kafka в моем приложении Sparkstreaming, которое использует...

Когда я выполняю следующий простой код Spark: val trial = Try { require( requirement = false,...

После нескольких дней изучения того, почему мое приложение Flink не работает должным образом Я...

Я разрабатываю алгоритм дискретизации в мгновение ока, но у меня возникают проблемы с применением...

Я пытаюсь настроить Hazelcast в конфигурации клиент-сервер для использования с JCache API в клиенте