public static class KafkaSource.BytesDeserializer extends Object implements org.apache.kafka.common.serialization.Deserializer<org.apache.hadoop.io.BytesWritable>
Deserializer
BytesWritable
BytesDeserializer()
void
close()
configure(Map<String,?> configProperties, boolean isKey)
org.apache.hadoop.io.BytesWritable
deserialize(String topic, byte[] valueBytes)
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public BytesDeserializer()
public void configure(Map<String,?> configProperties, boolean isKey)
configure
org.apache.kafka.common.serialization.Deserializer<org.apache.hadoop.io.BytesWritable>
public org.apache.hadoop.io.BytesWritable deserialize(String topic, byte[] valueBytes)
deserialize
public void close()
close
Closeable
AutoCloseable
Copyright © 2017 The Apache Software Foundation. All rights reserved.