T- The type created by the keyed deserialization schema.
@PublicEvolving public interface KinesisDeserializationSchema<T> extends Serializable, ResultTypeQueryable<T>
DeserializationSchema, this schema offers additional Kinesis-specific information about the record that may be useful to the user application.
|Modifier and Type||Method and Description|
Deserializes a Kinesis record's bytes.
Initialization method for the schema.
default void open(DeserializationSchema.InitializationContext context) throws Exception
deserialize(byte, java.lang.String, java.lang.String, long, java.lang.String, java.lang.String)and thus suitable for one time setup work.
DeserializationSchema.InitializationContext can be used to access
additional features such as e.g. registering user metrics.
context- Contextual information that can be used during initialization.
T deserialize(byte recordValue, String partitionKey, String seqNum, long approxArrivalTimestamp, String stream, String shardId) throws IOException
nullmay be returned. This informs the Flink Kinesis Consumer to process the Kinesis record without producing any output for it, i.e. effectively "skipping" the record.
recordValue- the record's value as a byte array
partitionKey- the record's partition key at the time of writing
seqNum- the sequence number of this record in the Kinesis shard
approxArrivalTimestamp- the server-side timestamp of when Kinesis received and stored the record
stream- the name of the Kinesis stream that this record was sent to
shardId- The identifier of the shard the record was sent to
nullif the message cannot be deserialized).
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.