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() |