Package cz.o2.proxima.direct.io.kafka
Class KafkaStreamElement
- java.lang.Object
-
- cz.o2.proxima.core.storage.StreamElement
-
- cz.o2.proxima.direct.io.kafka.KafkaStreamElement
-
- All Implemented Interfaces:
java.io.Serializable
public class KafkaStreamElement extends StreamElement
Data read from a kafka partition.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
KafkaStreamElement.KafkaStreamElementSerializer
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
toString()
-
Methods inherited from class cz.o2.proxima.core.storage.StreamElement
delete, delete, deleteWildcard, deleteWildcard, deleteWildcard, deleteWildcard, dump, equals, getParsed, getUuid, hashCode, hasSequentialId, isDelete, isDeleteWildcard, setParsed, upsert, upsert
-
-
-
-
Method Detail
-
toString
public java.lang.String toString()
- Overrides:
toString
in classStreamElement
-
-