@Internal public class KinesisStreamsStateSerializer extends AsyncSinkWriterStateSerializer<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>
AsyncSinkWriterStateSerializer
.Constructor and Description |
---|
KinesisStreamsStateSerializer() |
Modifier and Type | Method and Description |
---|---|
protected String |
deserializePartitionKeyFromStream(DataInputStream in) |
protected software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry |
deserializeRequestFromStream(long requestSize,
DataInputStream in) |
int |
getVersion()
Gets the version with which this serializer serializes.
|
protected void |
serializePartitionKeyToStream(String partitionKey,
DataOutputStream out) |
protected void |
serializeRequestToStream(software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry request,
DataOutputStream out) |
protected void |
validateExplicitHashKey(software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry request) |
deserialize, serialize
protected void serializeRequestToStream(software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry request, DataOutputStream out) throws IOException
serializeRequestToStream
in class AsyncSinkWriterStateSerializer<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>
IOException
protected void serializePartitionKeyToStream(String partitionKey, DataOutputStream out) throws IOException
IOException
protected void validateExplicitHashKey(software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry request)
protected software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry deserializeRequestFromStream(long requestSize, DataInputStream in) throws IOException
deserializeRequestFromStream
in class AsyncSinkWriterStateSerializer<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>
IOException
protected String deserializePartitionKeyFromStream(DataInputStream in) throws IOException
IOException
public int getVersion()
SimpleVersionedSerializer
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.