public class SinkStatus
extends Object
Sink
.
param: description Description of the source corresponding to this status param: offsetDesc Description of the current offset up to which data has been written by the sink
Modifier and Type | Method and Description |
---|---|
String |
description() |
String |
offsetDesc() |