Class SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
java.lang.Object
org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
- Enclosing class:
SinkStatus.SinkInstanceStatus
Status data of a Sink instance.
-
Field Summary
Modifier and TypeFieldDescriptionlong
long
long
long
long
long
boolean
-
Constructor Summary
-
Method Summary
-
Field Details
-
running
public boolean running -
error
-
numRestarts
public long numRestarts -
numReadFromPulsar
public long numReadFromPulsar -
numSystemExceptions
public long numSystemExceptions -
latestSystemExceptions
-
numSinkExceptions
public long numSinkExceptions -
latestSinkExceptions
-
numWrittenToSink
public long numWrittenToSink -
lastReceivedTime
public long lastReceivedTime -
workerId
-
-
Constructor Details
-
SinkInstanceStatusData
public SinkInstanceStatusData()
-