public class SourceStatus
extends java.lang.Object
Source
.
param: description Description of the source corresponding to this status param: offset Current offset of the source, if known
Modifier and Type | Method and Description |
---|---|
java.lang.String |
description() |
scala.Option<org.apache.spark.sql.execution.streaming.Offset> |
offset() |