Interface ChillSerializerRegistrar
-
public interface ChillSerializerRegistrarInterface for flink-core to interact with the FlinkChillPackageRegistrar in flink-java.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intgetNextRegistrationId()Returns the registration ID that immediately follows the last registered serializer.voidregisterSerializers(com.esotericsoftware.kryo.Kryo kryo)Registers all serializers with the givenKryo.
-
-
-
Method Detail
-
registerSerializers
void registerSerializers(com.esotericsoftware.kryo.Kryo kryo)
Registers all serializers with the givenKryo. All serializers are registered with specific IDs as a continuous block.- Parameters:
kryo- Kryo to register serializers with
-
getNextRegistrationId
int getNextRegistrationId()
Returns the registration ID that immediately follows the last registered serializer.- Returns:
- registration ID that should be used for the next serializer registration
-
-