public final class RoutableProtobufKinesisIngressDeserializer extends java.lang.Object implements KinesisIngressDeserializer<com.google.protobuf.Message>
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Message |
deserialize(IngressRecord ingressRecord)
Deserialize an input value from a
IngressRecord consumed from AWS Kinesis. |
public com.google.protobuf.Message deserialize(IngressRecord ingressRecord)
KinesisIngressDeserializer
IngressRecord
consumed from AWS Kinesis.deserialize
in interface KinesisIngressDeserializer<com.google.protobuf.Message>
ingressRecord
- the IngressRecord
consumed from AWS Kinesis.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.