T
- The type created by the ingress deserializer.public interface KinesisIngressDeserializer<T>
extends java.io.Serializable
IngressRecord
s consumed from AWS Kinesis into data types
that are processed by the system.Modifier and Type | Method and Description |
---|---|
T |
deserialize(IngressRecord ingressRecord)
Deserialize an input value from a
IngressRecord consumed from AWS Kinesis. |
T deserialize(IngressRecord ingressRecord)
IngressRecord
consumed from AWS Kinesis.ingressRecord
- the IngressRecord
consumed from AWS Kinesis.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.