public class IterationRecordSerializer<T> extends org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
IterationRecord
.Constructor and Description |
---|
IterationRecordSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> innerSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
copy(org.apache.flink.core.memory.DataInputView source,
org.apache.flink.core.memory.DataOutputView target) |
IterationRecord<T> |
copy(IterationRecord<T> from) |
IterationRecord<T> |
copy(IterationRecord<T> from,
IterationRecord<T> reuse) |
IterationRecord<T> |
createInstance() |
IterationRecord<T> |
deserialize(org.apache.flink.core.memory.DataInputView source) |
IterationRecord<T> |
deserialize(IterationRecord<T> reuse,
org.apache.flink.core.memory.DataInputView source) |
int |
deserializeNumber(org.apache.flink.core.memory.DataInputView source) |
org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>> |
duplicate() |
boolean |
equals(Object o) |
org.apache.flink.api.common.typeutils.TypeSerializer<T> |
getInnerSerializer() |
int |
getLength() |
int |
hashCode() |
boolean |
isImmutableType() |
void |
serialize(IterationRecord<T> record,
org.apache.flink.core.memory.DataOutputView target) |
void |
serializerNumber(int value,
org.apache.flink.core.memory.DataOutputView target)
Variant encoding for the epoch.
|
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<IterationRecord<T>> |
snapshotConfiguration() |
public IterationRecordSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> innerSerializer)
public org.apache.flink.api.common.typeutils.TypeSerializer<T> getInnerSerializer()
public boolean isImmutableType()
isImmutableType
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>> duplicate()
duplicate
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public IterationRecord<T> createInstance()
createInstance
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public IterationRecord<T> copy(IterationRecord<T> from)
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public IterationRecord<T> copy(IterationRecord<T> from, IterationRecord<T> reuse)
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public int getLength()
getLength
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public void serialize(IterationRecord<T> record, org.apache.flink.core.memory.DataOutputView target) throws IOException
serialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
IOException
public IterationRecord<T> deserialize(org.apache.flink.core.memory.DataInputView source) throws IOException
deserialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
IOException
public IterationRecord<T> deserialize(IterationRecord<T> reuse, org.apache.flink.core.memory.DataInputView source) throws IOException
deserialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
IOException
public void serializerNumber(int value, org.apache.flink.core.memory.DataOutputView target) throws IOException
IOException
public int deserializeNumber(org.apache.flink.core.memory.DataInputView source) throws IOException
IOException
public void copy(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target) throws IOException
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
IOException
public boolean equals(Object o)
equals
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public int hashCode()
hashCode
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<IterationRecord<T>> snapshotConfiguration()
snapshotConfiguration
in class org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.