@Internal public final class CommittableCollectorSerializer<CommT> extends Object implements SimpleVersionedSerializer<CommittableCollector<CommT>>
CommittableCollector
. Compatible to 1.14- StreamingCommitterState.Constructor and Description |
---|
CommittableCollectorSerializer(SimpleVersionedSerializer<CommT> committableSerializer,
int subtaskId,
int numberOfSubtasks) |
Modifier and Type | Method and Description |
---|---|
CommittableCollector<CommT> |
deserialize(int version,
byte[] serialized)
De-serializes the given data (bytes) which was serialized with the scheme of the indicated
version.
|
int |
getVersion()
Gets the version with which this serializer serializes.
|
byte[] |
serialize(CommittableCollector<CommT> committableCollector)
Serializes the given object.
|
public CommittableCollectorSerializer(SimpleVersionedSerializer<CommT> committableSerializer, int subtaskId, int numberOfSubtasks)
public int getVersion()
SimpleVersionedSerializer
getVersion
in interface SimpleVersionedSerializer<CommittableCollector<CommT>>
getVersion
in interface Versioned
public byte[] serialize(CommittableCollector<CommT> committableCollector) throws IOException
SimpleVersionedSerializer
SimpleVersionedSerializer.getVersion()
.serialize
in interface SimpleVersionedSerializer<CommittableCollector<CommT>>
committableCollector
- The object to serialize.IOException
- Thrown, if the serialization fails.public CommittableCollector<CommT> deserialize(int version, byte[] serialized) throws IOException
SimpleVersionedSerializer
deserialize
in interface SimpleVersionedSerializer<CommittableCollector<CommT>>
version
- The version in which the data was serializedserialized
- The serialized dataIOException
- Thrown, if the deserialization fails.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.