本文整理了Java中org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.getKryoInstance()方法的一些代码示例，展示了KryoSerializer.getKryoInstance()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KryoSerializer.getKryoInstance()方法的具体详情如下：
包路径：org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer
类名称：KryoSerializer
方法名：getKryoInstance

KryoSerializer.getKryoInstance介绍

[英]Returns the Chill Kryo Serializer which is implicitly added to the classpath via flink-runtime. Falls back to the default Kryo serializer if it can't be found.
[中]返回通过flink运行时隐式添加到类路径的Chill Kryo序列化程序。如果找不到，则返回默认的Kryo序列化程序。

代码示例

代码示例来源：origin: apache/flink

private void checkKryoInitialized() {
  if (this.kryo == null) {
    this.kryo = getKryoInstance();
    // Enable reference tracking. 
    kryo.setReferences(true);
    
    // Throwable and all subclasses should be serialized via java serialization
    // Note: the registered JavaSerializer is Flink's own implementation, and not Kryo's.
    //       This is due to a know issue with Kryo's JavaSerializer. See FLINK-6025 for details.
    kryo.addDefaultSerializer(Throwable.class, new JavaSerializer());
    // Add default serializers first, so that the type registrations without a serializer
    // are registered with a default serializer
    for (Map.Entry<Class<?>, ExecutionConfig.SerializableSerializer<?>> entry: defaultSerializers.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue().getSerializer());
    }
    for (Map.Entry<Class<?>, Class<? extends Serializer<?>>> entry: defaultSerializerClasses.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue());
    }
    KryoUtils.applyRegistrations(this.kryo, kryoRegistrations.values());
    kryo.setRegistrationRequired(false);
    kryo.setClassLoader(Thread.currentThread().getContextClassLoader());
  }
}

代码示例来源：origin: org.apache.flink/flink-core

private void checkKryoInitialized() {
  if (this.kryo == null) {
    this.kryo = getKryoInstance();
    // Enable reference tracking. 
    kryo.setReferences(true);
    
    // Throwable and all subclasses should be serialized via java serialization
    // Note: the registered JavaSerializer is Flink's own implementation, and not Kryo's.
    //       This is due to a know issue with Kryo's JavaSerializer. See FLINK-6025 for details.
    kryo.addDefaultSerializer(Throwable.class, new JavaSerializer());
    // Add default serializers first, so that the type registrations without a serializer
    // are registered with a default serializer
    for (Map.Entry<Class<?>, ExecutionConfig.SerializableSerializer<?>> entry: defaultSerializers.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue().getSerializer());
    }
    for (Map.Entry<Class<?>, Class<? extends Serializer<?>>> entry: defaultSerializerClasses.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue());
    }
    KryoUtils.applyRegistrations(this.kryo, kryoRegistrations.values());
    kryo.setRegistrationRequired(false);
    kryo.setClassLoader(Thread.currentThread().getContextClassLoader());
  }
}

代码示例来源：origin: com.alibaba.blink/flink-core

private void checkKryoInitialized() {
  if (this.kryo == null) {
    this.kryo = getKryoInstance();
    // Enable reference tracking. 
    kryo.setReferences(true);
    
    // Throwable and all subclasses should be serialized via java serialization
    // Note: the registered JavaSerializer is Flink's own implementation, and not Kryo's.
    //       This is due to a know issue with Kryo's JavaSerializer. See FLINK-6025 for details.
    kryo.addDefaultSerializer(Throwable.class, new JavaSerializer());
    // Add default serializers first, so that the type registrations without a serializer
    // are registered with a default serializer
    for (Map.Entry<Class<?>, ExecutionConfig.SerializableSerializer<?>> entry: defaultSerializers.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue().getSerializer());
    }
    for (Map.Entry<Class<?>, Class<? extends Serializer<?>>> entry: defaultSerializerClasses.entrySet()) {
      kryo.addDefaultSerializer(entry.getKey(), entry.getValue());
    }
    KryoUtils.applyRegistrations(this.kryo, kryoRegistrations.values());
    kryo.setRegistrationRequired(false);
    kryo.setClassLoader(Thread.currentThread().getContextClassLoader());
  }
}