Package org.apache.pulsar.common.policies.data

Class SinkStatus.SinkInstanceStatus.SinkInstanceStatusData

java.lang.Object

org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData

Enclosing class:

SinkStatus.SinkInstanceStatus

public static class SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
extends Object

Status data of a Sink instance.

Field Summary

Fields

Modifier and Type	Field	Description
String	error
long	lastReceivedTime
List<ExceptionInformation>	latestSinkExceptions
List<ExceptionInformation>	latestSystemExceptions
long	numReadFromPulsar
long	numRestarts
long	numSinkExceptions
long	numSystemExceptions
long	numWrittenToSink
boolean	running
String	workerId

Constructor Summary

Constructors

Constructor	Description
SinkInstanceStatusData()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

running

public boolean running

error

public String error

numRestarts

public long numRestarts

numReadFromPulsar

public long numReadFromPulsar

numSystemExceptions

public long numSystemExceptions

latestSystemExceptions

public List<ExceptionInformation> latestSystemExceptions

numSinkExceptions

public long numSinkExceptions

latestSinkExceptions

public List<ExceptionInformation> latestSinkExceptions

numWrittenToSink

public long numWrittenToSink

lastReceivedTime

public long lastReceivedTime

workerId

public String workerId

Constructor Details

SinkInstanceStatusData

public SinkInstanceStatusData()