Page History

@PublicEvolving
public interface SplitEnumeratorMetricGroupSourceReaderMetricGroup extends OperatorCoordinatorMetricGroupOperatorMetricGroup {
	Counter getNumRecordsInErrorsCounter();
	void setPendingBytesGauge(Gauge<Long> pendingBytesGauge);
	void setPendingRecordsGauge(Gauge<Long> pendingRecordsGauge);
	
	/** new addition */
	void setAssignedSplitsGauge(Gauge<Long> assignedSplitsGauge);
}