Package com.linkedin.venice.unit.kafka
Class InMemoryPubSubPosition
java.lang.Object
com.linkedin.venice.unit.kafka.InMemoryPubSubPosition
- All Implemented Interfaces:
Measurable
,PubSubPosition
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionint
long
Position wrapper is used to wrap the position type and the position value.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.linkedin.venice.pubsub.api.PubSubPosition
equals, getWireFormatBytes, hashCode
-
Constructor Details
-
InMemoryPubSubPosition
public InMemoryPubSubPosition(long offset)
-
-
Method Details
-
getNumericOffset
public long getNumericOffset()- Specified by:
getNumericOffset
in interfacePubSubPosition
-
getPositionWireFormat
Description copied from interface:PubSubPosition
Position wrapper is used to wrap the position type and the position value. This is used to serialize and deserialize the position object when sending and receiving it over the wire.- Specified by:
getPositionWireFormat
in interfacePubSubPosition
- Returns:
- the position wrapper
-
getHeapSize
public int getHeapSize()- Specified by:
getHeapSize
in interfaceMeasurable
-