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.
|
void |
deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> message,
Collector<T> out)
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.
|
void |
open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
public KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema)
public void open(DeserializationSchema.InitializationContext context) throws Exception
KafkaDeserializationSchema
KafkaDeserializationSchema.deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[], byte[]>)
and thus suitable for one time setup work.
The provided DeserializationSchema.InitializationContext
can be used to access
additional features such as e.g. registering user metrics.
open
in interface KafkaDeserializationSchema<T>
context
- Contextual information that can be used during initialization.Exception
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 void deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> message, Collector<T> out) throws Exception
KafkaDeserializationSchema
Can output multiple records through the Collector
. Note that number and size of
the produced records should be relatively small. Depending on the source implementation
records can be buffered in memory or collecting records might delay emitting checkpoint
barrier.
deserialize
in interface KafkaDeserializationSchema<T>
message
- The message, as a byte array.out
- The collector to put the resulting messages.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–2021 The Apache Software Foundation. All rights reserved.