kryo

1зной

1ответ

десериализации Java объектов от Кафки потребителя

У меня есть Кафка Потребителя, в настоящее время настроен: kafkaProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()); kafkaProps.put(ConsumerConfig.VALUE_DESERI

java apache-kafka kryo 2016-08-15

---

4зной

1ответ

Kryo: десериализовать старую версию класса

Мне нужно изменить класс, добавив два новых параметра. Этот класс сериализуется с Kryo. В настоящее время я сохраняю информацию, относящуюся к этому классу, среди прочего, как RDD, каждый раз, когда я

scala serialization apache-spark spark-streaming kryo 2016-08-23

---

1зной

1ответ

Spark kryo encoder ArrayIndexOutOfBoundsException

Я пытаюсь создать набор данных с некоторыми геоданными, используя искру и esri. Если Foo имеет только поле Point, оно будет работать, но если я добавлю другие поля за пределами Point, я получаю ArrayI

scala apache-spark kryo 2016-07-21

---

0зной

1ответ

Ошибки при помощи Kryo сериалайзер искры с буферами протокола Java, которые имеют массивы строк

Я поражающая ошибку при использовании протокола Java классов буфера в качестве объектной модели для РДА в работах Спарка, Для моего приложения, моя, прото файл имеет свойства, которые являются повторя

java scala apache-spark kryo 2016-07-22

---

1зной

2ответ

Kryo Serializer IllegalAccessError во время выполнения

Мы пытаемся использовать сериализатор Kryo для сериализации нашего объекта приложения, чтобы протолкнуть их в поток kafka. Код сериализации private ThreadLocal<Kryo> kryos = new ThreadLocal<Kryo>() {

java kryo 2016-07-25

---

1зной

1ответ

Стратегия Serialization Spark - следует ли использовать Kryo исключительно?

Я новичок в искру. И еще новее к Крио. В моем искровом приложении я использую kryo для сериализации объектов значений, но просто использую интерфейс Serializable для объектов, в которых хранятся алгор

java apache-spark kryo 2016-09-14

---

0зной

1ответ

Неверные имен столбцов в наборе данных искрового

У меня есть следующий класс случая: case class Data[T](field1: String, field2: T) Я использую Kryo сериалайзер с следующими implicits для него: implicit def single[A](implicit c: ClassTag[A]): Encod

scala apache-spark-sql kryo 2016-09-19

---

0зной

1ответ

Как читать сериализованный объект методом, использующим общий тип Scala/Kryo?

Использование Kryo для чтения сериализованного объекта легко, когда я знаю конкретный тип класса, но если я хочу создать метод, который использует простой общий тип, как это сделать? У меня есть код,

scala kryo 2016-08-11

---