Package org.apache.iceberg.flink.sink.shuffle

Class AggregatedStatisticsSerializer.AggregatedStatisticsSerializerSnapshot

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics,AggregatedStatisticsSerializer>

org.apache.iceberg.flink.sink.shuffle.AggregatedStatisticsSerializer.AggregatedStatisticsSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics>

Enclosing class:

AggregatedStatisticsSerializer

public static class AggregatedStatisticsSerializer.AggregatedStatisticsSerializerSnapshot
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics,AggregatedStatisticsSerializer>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.OuterSchemaCompatibility

Constructor Summary

Constructors

Constructor	Description
AggregatedStatisticsSerializerSnapshot()	Constructor for read instantiation.
AggregatedStatisticsSerializerSnapshot(AggregatedStatisticsSerializer serializer)

Method Summary

Modifier and Type	Method	Description
protected AggregatedStatisticsSerializer	createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)
protected int	getCurrentOuterSnapshotVersion()
protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[]	getNestedSerializers(AggregatedStatisticsSerializer outerSerializer)

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveOuterSchemaCompatibility, resolveOuterSchemaCompatibility, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

resolveSchemaCompatibility

Constructor Details

AggregatedStatisticsSerializerSnapshot

public AggregatedStatisticsSerializerSnapshot()

Constructor for read instantiation.

AggregatedStatisticsSerializerSnapshot

public AggregatedStatisticsSerializerSnapshot(AggregatedStatisticsSerializer serializer)

Method Details

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics,AggregatedStatisticsSerializer>

getNestedSerializers

protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(AggregatedStatisticsSerializer outerSerializer)

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics,AggregatedStatisticsSerializer>

createOuterSerializerWithNestedSerializers

protected AggregatedStatisticsSerializer createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)

Specified by:

createOuterSerializerWithNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics,AggregatedStatisticsSerializer>