Index

B C D E G H I L M N O P R S T W
All Classes and Interfaces|All Packages|Serialized Form

B

build() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation.Builder

Validates the generated class or root descriptor and the settings and captures an independent immutable result.

C

canEqual(Object) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Restricts equality to this final implementation.

copy(DataInputView, DataOutputView) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Copies the original frame without parsing its payload.

copy(T) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Returns the input reference because supported message values are immutable.

copy(T, T) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Returns the input reference without modifying the reuse value or validating either value.

createInstance() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Returns the default instance of the configured message type.

createSerializer(SerializerConfig) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Creates a native serializer with this type information's immutable settings.

createTypeInfo(Type, Map<String, TypeInformation<?>>) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInfoFactory

Validates a concrete generated class and creates type information preserving that class.

D

deserialize(DataInputView) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Reads exactly one frame with an empty extension registry and configured size/depth limits.

deserialize(T, DataInputView) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Reads one frame using ProtobufTypeSerializer.deserialize(DataInputView) without modifying the reuse value.

deterministicSerialization(boolean) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation.Builder

Enables deterministic payload writing, without promising canonical bytes or message keys.

duplicate() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Creates a serializer sharing immutable metadata with independent mutable scratch storage.

E

equals(Object) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Compares the exact class, full message name, normalized descriptor content, and all settings.

equals(Object) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Compares exact class identity, full name, normalized descriptor content, and every serializer setting.

G

getArity() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

getCurrentVersion() - Method in class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

getCurrentVersion() - Method in class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

getLength() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Reports variable-length framing, including the four-byte length prefix.

getTotalFields() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

getTypeClass() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

H

hashCode() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

hashCode() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Hashes message identity, settings, and the framing/normalization versions.

I

io.github.flink.gcp.protobuf - package io.github.flink.gcp.protobuf

Native Protocol Buffers serialization for Flink DataStream generated full-runtime messages and DynamicMessage values of an explicit root descriptor.

isBasicType() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

isImmutableType() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Reports that message values are immutable.

isKeyType() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Declares message keys unsupported with every setting.

isTupleType() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

L

largePayloadAliasing(boolean) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation.Builder

Sets whether values decoded from a payload above 4 KiB may share the array that holds it.

M

maxMessageSize(int) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation.Builder

Sets the payload byte limit, excluding the four-byte frame prefix.

N

newBuilder(Descriptors.Descriptor) - Static method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Creates a reusable builder for DynamicMessage type information with the same defaults as ProtobufTypeInformation.of(Class).

newBuilder(Class<T>) - Static method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Creates a reusable builder with the same defaults as ProtobufTypeInformation.of(Class).

O

of(Descriptors.Descriptor) - Static method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Creates DynamicMessage type information for a root descriptor with the same defaults as ProtobufTypeInformation.of(Class); equivalent to newBuilder(rootDescriptor).build().

of(Class<T>) - Static method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

Creates type information with deterministic writing disabled, a 64 MiB payload limit, a recursion limit of 100, and large-payload aliasing enabled.

P

ProtobufDynamicSerializerSnapshot - Class in io.github.flink.gcp.protobuf

Version-1 metadata for restoring DynamicMessage value serializers from their saved descriptors.

ProtobufDynamicSerializerSnapshot() - Constructor for class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

Creates an empty snapshot for Flink's versioned metadata reader.

ProtobufGeneratedSerializerSnapshot<T extends com.google.protobuf.Message> - Class in io.github.flink.gcp.protobuf

Version-1 metadata for restoring generated Protobuf value serializers.

ProtobufGeneratedSerializerSnapshot() - Constructor for class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

Creates an empty snapshot for Flink's versioned metadata reader.

ProtobufTypeInfoFactory - Class in io.github.flink.gcp.protobuf

Creates native type information with the default settings for full-runtime generated messages.

ProtobufTypeInfoFactory() - Constructor for class io.github.flink.gcp.protobuf.ProtobufTypeInfoFactory

Creates a stateless factory for configuration-based registration.

ProtobufTypeInformation<T> - Class in io.github.flink.gcp.protobuf

Native type information for immutable, generated full-runtime Protobuf values or DynamicMessage values of one root descriptor.

ProtobufTypeInformation.Builder<T extends com.google.protobuf.Message> - Class in io.github.flink.gcp.protobuf

Reusable builder for immutable native type information.

ProtobufTypeSerializer<T extends com.google.protobuf.Message> - Class in io.github.flink.gcp.protobuf

Native serializer for immutable, generated full-runtime Protobuf values or DynamicMessage values of one root descriptor.

R

readSnapshot(int, DataInputView, ClassLoader) - Method in class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

Validates metadata and normalizes the saved descriptors against their root, without loading any application class.

readSnapshot(int, DataInputView, ClassLoader) - Method in class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

Validates metadata without loading the saved generated class.

recursionLimit(int) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation.Builder

Sets the parser recursion budget, also enforced before writing a message.

resolveSchemaCompatibility(TypeSerializerSnapshot<DynamicMessage>) - Method in class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

Checks whether this new configuration can read values permitted by an old configuration.

resolveSchemaCompatibility(TypeSerializerSnapshot<T>) - Method in class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

Checks whether this new configuration can read values permitted by an old configuration.

restoreSerializer() - Method in class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

Rebuilds the saved descriptors and returns a reader with the saved settings.

restoreSerializer() - Method in class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

Resolves the generated class using the loader retained by this snapshot and checks that it can read the saved schema.

S

serialize(T, DataOutputView) - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Writes one length-prefixed Protobuf payload after validating its type, size, and depth.

snapshotConfiguration() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeSerializer

Captures versioned descriptors and settings for restoration by a compatible reader.

T

toString() - Method in class io.github.flink.gcp.protobuf.ProtobufTypeInformation

W

writeSnapshot(DataOutputView) - Method in class io.github.flink.gcp.protobuf.ProtobufDynamicSerializerSnapshot

Writes the fixed version-1 payload with deterministic descriptor bytes and their SHA-256.

writeSnapshot(DataOutputView) - Method in class io.github.flink.gcp.protobuf.ProtobufGeneratedSerializerSnapshot

Writes the fixed version-1 payload with deterministic descriptor bytes and their SHA-256.

B C D E G H I L M N O P R S T W
All Classes and Interfaces|All Packages|Serialized Form