public class SinkStatus
extends java.lang.Object
Sink
.
param: description Description of the source corresponding to this status param: offset Current offset up to which data has been written by the sink
Modifier and Type | Method and Description |
---|---|
java.lang.String |
description() |
org.apache.spark.sql.execution.streaming.Offset |
offset() |