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