public class PirkHashScheme
extends org.apache.storm.kafka.StringScheme
implements org.apache.storm.spout.Scheme
Constructor and Description |
---|
PirkHashScheme(org.apache.storm.Config conf) |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.Object> |
deserialize(java.nio.ByteBuffer bytes) |
org.apache.storm.tuple.Fields |
getOutputFields() |
public java.util.List<java.lang.Object> deserialize(java.nio.ByteBuffer bytes)
deserialize
in interface org.apache.storm.spout.Scheme
deserialize
in class org.apache.storm.kafka.StringScheme
public org.apache.storm.tuple.Fields getOutputFields()
getOutputFields
in interface org.apache.storm.spout.Scheme
getOutputFields
in class org.apache.storm.kafka.StringScheme