T
- The type created by the deserialization schema.@Internal public class KafkaDeserializationSchemaWrapper<T> extends Object implements KafkaDeserializationSchema<T>
Constructor and Description |
---|
KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema) |
Modifier and Type | Method and Description |
---|---|
T |
deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
Deserializes the Kafka record.
|
TypeInformation<T> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
boolean |
isEndOfStream(T nextElement)
Method to decide whether the element signals the end of the stream.
|
public KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema)
public T deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) throws Exception
KafkaDeserializationSchema
deserialize
in interface KafkaDeserializationSchema<T>
record
- Kafka record to be deserialized.Exception
public boolean isEndOfStream(T nextElement)
KafkaDeserializationSchema
isEndOfStream
in interface KafkaDeserializationSchema<T>
nextElement
- The element to test for the end-of-stream signal.public TypeInformation<T> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<T>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.