kryo

7열

1답변

에게 을 등록 거부 나는 그것을 등록한다 : kryo.register(classOf[MyClass[_]]) 내가 Log.TRACE()를 설정할 때 나는 다음과 같은 결과를 얻는다 : 00:11 TRACE: [kryo] Register class ID 51: com.my.package.MyClass (com.esotericsoftware.kryo.seri

1열

1답변

Kryo 직렬화 유형 감지

저는 Kryo IO를 직접 사용하여 저수준의 String, Longs 및 Doubles의 프리미티브 직렬화를 수행합니다. Kryo IO가 다시 읽을 때 직렬화 된 바이트에서 원시 데이터 형식을 자동으로 검색하는 방법이 있다면 궁금합니다. 문자열 배열에 10 개의 직렬화 된 값이 있는데 String, Long 또는 Doubles인지 여부를 알 수 없습니다.

0열

1답변

Java에서 클래스 이름이 변경되면서 이상한 오류가 발생했습니다.

kryo lib를 사용하여 객체를 직렬화합니다. 내가 오류 얻을 : (-> ArrayLisoSerialization ArrayListSerialization) Unable to find class: java.util.ArrayLisoSerialization 와 동료는 그 오류를 재현를 ... Kryo에서 해당 자바 클래스 이름이 변경되었습니다 보인다.

4열

1답변

apache spark에서 클래스 (작업 객체)의 kryo 직렬화가 역 직렬화 중에 null을 반환합니다.

Java Spark API를 사용하여 일부 테스트 응용 프로그램을 작성하고 있습니다. serializable 인터페이스를 확장하지 않는 클래스를 사용하고 있습니다. 그래서 응용 프로그램을 작동 시키려면 kryo serializer를 사용하여 클래스를 직렬화합니다. 하지만 내가 디버깅하는 동안 관찰 한 문제는 디 직렬화 중에 반환 된 클래스 객체는 null이

2열

1답변

Storm 0.9.1에서 Kryo 호환성 0.9.1 및 Titan 그래프 데이터베이스 0.4.2 with storage backend

Kryo 2.17을 사용하는 Storm 0.9.1을 사용하고 있습니다. 내부적으로 사용하는 titan 그래프 데이터베이스에 데이터를 삽입하는 모듈이 있습니다. java.lang.RuntimeException가 : com.esotericsoftware.kryo.KryoException : java.lang.IllegalArgumentException가 : 다

3열

1답변

Kryo 아파치 스파크에

스파크 문서는 당신이해야 할 모든 클래스를 등록하고 conf의 두 변수를 추가 것을 말한다 (텍스트, 텍스트)의 키/값 시퀀스 파일을 정렬하려고 할 때. class MyRegistrator extends KryoRegistrator { override def registerClasses(kryo: Kryo) { kryo.register(c

1열

1답변

Spark RDD에서 Kryo 파일 읽기

나는 스파크 & 스칼라 초보자입니다. 이 직렬화 내 개체 (myScalaObject)으로 파일을 생성하기위한 의사 코드는 import com.esotericsoftware.kryo.Kryo import com.esotericsoftware.kryo.io.Output val kryo:Kryo = new Kryo() val output:Output =

3열

1답변

sparkContext broadcast JedisPool이 작동하지 않습니다.

sparkContext.broadcast를 공유 redis 연결 풀 (JedisPool) 용 spark 스트리밍 응용 프로그램에서 사용하고있었습니다. 이 같은 코드 : lazy val redisPool = { val pool = Redis.createRedisPool(redisHost, redisPort) ssc.sparkContext.b

1열

1답변

컴파일 된 jar에 kryo 개체를 저장 하시겠습니까?

나는 HashMap을 보유하고 있으며 빠르게 액세스하고 싶습니다. 나는 log.info 내가 내지도에서 231,045 항목이 있음을 보여줍니다 내가 성공적으로 Input input = new Input(new FileInputStream("src/main/resources/locations50K.kryo")); Map<String, Locatio

0열

2답변

타이탄 데이터베이스에서 kryo로 객체 직렬화

타이탄 데이터베이스의 기본 객체를 직렬화합니다. 그러나 doesnt 일. 내 titan 데이터베이스에 등록하기 위해 객체를 직렬화하고 싶습니다. 그러나 나는 왜이 문제가 있는지 이해하지 못한다. 내 소스 코드를 게시하고 당신이 문서를 가지고 있다면 그것은 내가 받아 들일 수있는 즐거움이다. public class Attribute implements Kry