Class BaseDataStream (1.0.0) 

publicclass BaseDataStreamimplementsSparkDataStream

Inheritance

java.lang.Object > BaseDataStream

Implements

org.apache.spark.sql.connector.read.streaming.SparkDataStream

Methods

commit(Offset end)

publicvoidcommit(Offsetend)
Parameter
Name Description
end org.apache.spark.sql.connector.read.streaming.Offset

deserializeOffset(String json)

publicSparkSourceOffsetdeserializeOffset(Stringjson)
Parameter
Name Description
json String
Returns
Type Description
SparkSourceOffset

initialOffset()

publicSparkSourceOffsetinitialOffset()
Returns
Type Description
SparkSourceOffset

stop()

publicvoidstop()

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025年10月30日 UTC.