public class DynamoDBStreamsSchema extends Object implements KinesisDeserializationSchema<com.amazonaws.services.dynamodbv2.model.Record>
|Constructor and Description|
|Modifier and Type||Method and Description|
Deserializes a Kinesis record's bytes.
Gets the data type (as a
public com.amazonaws.services.dynamodbv2.model.Record deserialize(byte message, 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.
message- 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).
public TypeInformation<com.amazonaws.services.dynamodbv2.model.Record> getProducedType()
TypeInformation) produced by this function or input format.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.