kryo

0열

1답변

나는 kafka를 대기열 시스템으로 사용하는 데이터 파이프 라인에 몇 가지 응용 프로그램을 보유하고 있습니다. kryo 2.22를 사용하는 java7의 제작자 앱이 kafka (java7)를 생성한다면 kryo 4.0을 사용하는 java8의 소비자 앱이 데이터를 비 직렬화 할 수 있습니까? 다른 kryo 버전에서 짧은 데이터 직렬화/직렬화 해제가 가능합니까

1열

1답변

스파크 크립 인코더 ArrayIndexOutOfBoundsException

spark와 esri를 사용하여 일부 지리 데이터로 데이터 세트를 만들려고합니다. Foo에만 Point 필드가있는 경우 작동하지만 Point 이상의 다른 필드를 추가하면 ArrayIndexOutOfBoundsException이 발생합니다. 스레드 "주요"java.lang.ArrayIndexOutOfBoundsException의이 import com.esri

-1열

1답변

Kryo에서 LongMap 비 직렬화

필드에 scala.collection.mutable.LongMap 유형의 클래스가 있습니다. com.esotericsoftware.kryo.KryoException: java.lang.IllegalArgumentException: Can not set final scala.collection.mutable.LongMap field com.name.of.fi

1열

2답변

Kryo Serializer 런타임시 IllegalAccessError

우리는 Kryo Serializer를 사용하여 응용 프로그램 객체를 직렬화하여 카프카 스트림으로 푸시하려고합니다. 직렬화 방법은 private ThreadLocal<Kryo> kryos = new ThreadLocal<Kryo>() { protected Kryo initialValue() { Kryo kryo = new Kryo();

0열

1답변

잘못된 열 이름

나는 다음의 경우 클래스가 implicit def single[A](implicit c: ClassTag[A]): Encoder[A] = Encoders.kryo[A](c) implicit def tuple2[A1, A2](implicit e1: Encoder[A1], e2: Encoder[A2]): Encoder[(A1, A2)] = Enc

1열

1답변

Kryo는 필드에 사용되는 클래스를 자동으로 등록합니까?

Spark을 사용하면 Kryo가 권장되는 de/serializer이므로 Kryo를 사용하기로 결정했습니다. 내가 가진 말 : public Class1 { private Class2 field1; } 내가 클래스 1 & Class2의하거나 클래스 1은도 자동으로 Class2의 등록 등록을 모두 등록해야합니까?

1열

1답변

Spark Kryo Exception - 클래스가 등록되지 않았습니다. com.google.common.base.Present

Spark 1.6.0-cdh5.8.0을 사용하고 있습니다. 나는 Kryo를 사용하려고합니다. 나는 구아바를 가지고 있는데, 그것은 스파크가 사용하고있는 것이라고 생각하기 때문이다. 그러나 현재 클래스에 기본 표시가 있으므로 Kryo를 사용하여 직렬화 할 수 없습니다. 그래서 ... 누군가가이 문제를 해결하고 해결했습니다. 현재는 숨겨져 있기 때문에 다음 코

0열

1답변

Scala/Kryo가 제네릭 형식을 사용하는 메서드로 직렬화 된 개체를 읽는 방법?

Kryo를 사용하여 직렬화 된 객체를 읽는 것이 쉽습니다. 특정 클래스 유형을 알고있을 때 쉽습니다. 그러나 간단한 일반 유형을 사용하는 메소드를 작성하려면 어떻게해야합니까? 내가 컴파일 할 수없는 코드를 가지고 내가 가진 def load[T](path: String): T = { val instantiator = new ScalaKryoInsta

0열

1답변

Kryo java.lang.UnspportedOperationException

spry에서 the SAMRecord class에 대해 Kryo를 사용하려고하지만 런타임에 오류가 표시되는 중입니다. 이 오류의 의미를 이해하지 못합니다. 누구든지 설명 할 수 있습니까? 이 작업을하기 위해 Kryo가 변경해야하는 것은 무엇입니까? 문제는 멤버 변수 mAlignmentBlocks이 List<AlignmentBlock> 인 것입니다. Kryo

1열

1답변

어떻게 List 컬렉션을 Spark에 등록합니까?

Spark의 스칼라 코드에 List<someClassType> 유형 목록이 있습니다. kryo.register을 사용하여 어떻게 등록 할 수 있습니까? 나는 kryo.register 함수의 매개 변수가 무엇인지를 의미합니다.