Serialized Form

  • Package io.github.flink.gcp.protobuf

    • Class io.github.flink.gcp.protobuf.ProtobufTypeInformation

      class ProtobufTypeInformation extends io.github.flink.gcp.protobuf.CrossVersionProtobufTypeInformation<T> implements Serializable
      serialVersionUID:
      1L

      • Serialization Methods

        • readObject
          private void readObject(ObjectInputStream input) throws IOException, ClassNotFoundException
          Reconstructs class-associated metadata, or rebuilds DynamicMessage descriptors, without serializing descriptors, parsers, or classloaders.
          Parameters:
          input - serialized job configuration
          Throws:
          IOException - if the configuration is corrupt or the resolved type is unsupported
          ClassNotFoundException - if a serialized class cannot be resolved

      • Serialized Fields

        • descriptorSet
          byte[] descriptorSet
          The deterministic encoding of the normalized descriptor closure for DynamicMessage values.
          Encoded FileDescriptorSet, or null for a generated class.
        • fullName
          String fullName
          The root message's full name for DynamicMessage values.
          Protobuf full name, or null for a generated class.
        • messageClass
          Class<T> messageClass
          The generated class or DynamicMessage represented by this instance.
          Concrete generated application class, resolved by the job deserializer, or DynamicMessage.
        • settings
          io.github.flink.gcp.protobuf.ProtobufSerializerSettings settings
          The serialization settings retained across Java serialization.
          Immutable wire and reader settings.

    • Class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

      class ProtobufTypeSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends com.google.protobuf.Message> implements Serializable
      serialVersionUID:
      1L

      • Serialization Methods

        • readObject
          private void readObject(ObjectInputStream input) throws IOException, ClassNotFoundException
          Reconstructs runtime metadata from the generated class resolved by the object input stream, or from the serialized DynamicMessage descriptors.
          Parameters:
          input - serialized job configuration
          Throws:
          IOException - if the configuration is corrupt or the resolved type is unsupported
          ClassNotFoundException - if a serialized class cannot be resolved

      • Serialized Fields

        • descriptorSet
          byte[] descriptorSet
          The deterministic encoding of the normalized descriptor closure for DynamicMessage values.
          Encoded FileDescriptorSet, or null for a generated class.
        • fullName
          String fullName
          The root message's full name for DynamicMessage values.
          Protobuf full name, or null for a generated class.
        • messageClass
          Class<T extends com.google.protobuf.Message> messageClass
          The generated class or DynamicMessage represented by this instance.
          Concrete generated application class, resolved by the job deserializer, or DynamicMessage.
        • settings
          io.github.flink.gcp.protobuf.ProtobufSerializerSettings settings
          The serialization settings retained across Java serialization.
          Immutable wire and reader settings.