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.Schemedeserialize in class org.apache.storm.kafka.StringSchemepublic org.apache.storm.tuple.Fields getOutputFields()
getOutputFields in interface org.apache.storm.spout.SchemegetOutputFields in class org.apache.storm.kafka.StringScheme