Вопросы по теме 'kryo'
Сериализуйте несколько объектов в один файл с помощью Kryo
Насколько мне известно, сериализация / десериализация Kryo происходит для каждого объекта. Можно ли сериализовать несколько объектов в один файл ?. Одним из обходных путей, предложенных в другом аналогичном вопросе SO, было использование массива...
3337 просмотров
schedule
29.11.2021
Крионет. RMI. Время ответа истекло при попытке выполнить удаленный метод
Я пытаюсь запустить простой проект kryonet RMI с двумя отдельными клиентскими и серверными приложениями.
Но когда я пытаюсь выполнить метод удаления - это приводит к:
Exception in thread "main" com.esotericsoftware.kryonet.rmi.TimeoutException:...
282 просмотров
schedule
24.09.2021
Spark & Drools - Как сериализовать KieBase с помощью Kryo
Я использую Exception, пытаясь сериализовать объект KieBase в Spark.
Когда я выполняю следующий код:
val kieBase = kieContainer.getKieBase
val broadcastKieBase = spark.sparkContext.broadcast(kieBase)
Поднят...
451 просмотров
schedule
02.11.2021
Сериализуйте MinMaxPriorityQueue Guava
После нескольких дней исследования, почему мое приложение Flink не работает должным образом , я Я пришел к выводу, что проблема заключается в MinMaxPriorityQueue , который я использую.
Кажется, что эта структура не сериализуема. Я пробовал...
271 просмотров
schedule
24.09.2021
Как я могу использовать chill-avro для загрузки Avro GenericRecords в Spark?
Я пробовал использовать Avro GenericRecords в Spark, но получил исключение java.io.NotSerializableException: org.apache.avro.mapred.AvroWrapper
https://gist.github.com/rjurney/8b90e9b709d061cc0b94
Проект chill добавил поддержку Kryo / Avro для...
849 просмотров
schedule
26.02.2022
Невозможно работать с нестандартным типом после его кодирования? Набор данных Spark
Скажем, у вас есть это (решение для кодирования нестандартного типа взято из этого потока ):
// assume we handle custom type
class MyObj(val i: Int, val j: String)
implicit val myObjEncoder = org.apache.spark.sql.Encoders.kryo[MyObj]
val ds =...
274 просмотров
schedule
01.04.2022
Kryo сериализация/десериализация
Я пытаюсь использовать крио для сериализации и десериализации в двоичный код. Я думаю, что у меня работает сериализация, но я не могу десериализовать. Ниже приведен код, с которым я возился, но в конечном итоге я хочу сохранить byte[] и позже...
4968 просмотров
schedule
06.05.2022
Зарегистрируйте пользовательские классы для сериализации Kryo в Beam Spark runner
Я видел, что бегун Beam Spark использует BeamSparkRunnerRegistrator для крио-регистрации. Есть ли способ зарегистрировать пользовательские классы пользователей?
995 просмотров
schedule
26.06.2022
Регистрация класса в Kryo через twitter chill-scala
Я пытаюсь сериализовать экземпляр класса Scala, используя Kryo через библиотеку Chill-Scala Twitter. Это из библиотеки (внешняя банка), поэтому, я думаю, ее нужно зарегистрировать в Kryo.
Как зарегистрировать класс для (де)сериализации с помощью...
1505 просмотров
schedule
04.08.2022
Java Kryonet RSAPublicKeyImpl не зарегистрирован
Я пытаюсь отправить PublicKey (java.security.PublicKey) с сервера Kryonet клиенту, используя connection.sendTCP(key); . При этом я получаю это исключение:
Exception in thread "pool-1-thread-1" java.lang.IllegalArgumentException: Class is not...
202 просмотров
schedule
25.08.2022
Kryo java.lang.UnsportedOperationException
Я пытаюсь использовать Kryo в spark для класс SAMRecord , но во время выполнения отображается ошибка. Я не понимаю, что означает эта ошибка, кто-нибудь может объяснить? Что мне нужно изменить, чтобы Kryo работал с этим? Проблема связана с...
2212 просмотров
schedule
04.09.2022
NoSuchMethodError: DefaultKryoFactory — при попытке запустить топологию проекта storm-starter
Чтобы опробовать примеры storm-starter, я следую инструкциям на этой странице: https://github.com/apache/incubator-storm/tree/master/examples/storm-starter
После выполнения инструкций установка по умолчанию со storm 0.9.1 не выполняется, когда я...
748 просмотров
schedule
15.09.2022
Сохранение состояния игры в файл
Сейчас я нахожусь в точке, где мне нужно сохранить текущее состояние игры. Я использую libGDX, добавил в свой проект библиотеку kryo и провел некоторые тесты.
Вопрос:
Должен ли я переопределять файл при каждом сохранении или я могу...
273 просмотров
schedule
19.09.2022
Стратегия записи занятий с крио
Недавно я открыл для себя библиотеку kryonet, которая очень классная и отлично подходит для моих нужд.
Однако единственная проблема, с которой я столкнулся, заключается в разработке хорошей стратегии для регистрации всех классов, которые могут быть...
4317 просмотров
schedule
08.05.2023
KryoNet - Как запустить клиент с логическим значением xx = new clientprocess(); чтобы получить возвращаемое значение?
Я создаю небольшую многопользовательскую игру JAVA, используя kryonet для управления серверной/клиентской частью. У меня небольшой вопрос: в моей серверной программе я запускаю клиент с новым вызываемым методом "на" логическом значении:...
545 просмотров
schedule
18.07.2023
искра aparch, исключение NotSerializableException: org.apache.hadoop.io.Text
вот мой код:
val bg = imageBundleRDD.first() //bg:[Text, BundleWritable]
val res= imageBundleRDD.map(data => {
val desBundle = colorToGray(bg._2) //lineA:NotSerializableException:...
7238 просмотров
schedule
28.09.2023
Крио против Джексона
Я проверяю сериализацию Java, Kryo и Jackson.
Я создал крошечный код, который сериализует случайные объекты N раз. Я измеряю время сериализации и десериализации и размер объекта.
Я не очень доволен размером Kryo и Jackson, я читал о тестах, и...
3839 просмотров
schedule
13.02.2023
Невозможно сериализовать общий класс с общим полем в Kryo
У меня возникла странная проблема с Kryo. Я могу сериализовать универсальный класс (например, List) просто отлично. Я даже могу сериализовать универсальный класс, у которого нет общих полей. Однако, если я сериализую универсальный класс с...
1326 просмотров
schedule
30.07.2023
Как зарегистрировать много классов для Kryo Serializer? (например, все классы в пакете)
Регистрация всех классов для эффективной сериализации Kryo занимает много времени. Итак, я пытаюсь создать регистратор Kryo, который принимает пакет в качестве параметра (в Java или Scala). Мне интересно, как проще всего это сделать? (Конечно, с...
1790 просмотров
schedule
09.05.2023
Как работает двоичное кодирование в HBase?
Я сохраняю бриз SparseVectors в HBase, используя com.twitter.chill.KryoInjection для сериализации в массив байтов, который, похоже, работает нормально. Но затем я понял, что после чтения векторов из HBase некоторые значения отличаются/отсутствуют....
225 просмотров
schedule
26.07.2023
