Class BaseDataStream (0.4.5)
Stay organized with collections
Save and categorize content based on your preferences.
public class BaseDataStream implements SparkDataStream
Inheritance
java.lang.Object >
BaseDataStream
Implements
org.apache.spark.sql.connector.read.streaming.SparkDataStream
Methods
commit(Offset end)
public void commit(Offset end)
Parameter
Name | Description |
end | org.apache.spark.sql.connector.read.streaming.Offset
|
deserializeOffset(String json)
public SparkSourceOffset deserializeOffset(String json)
Parameter
Returns
initialOffset()
public SparkSourceOffset initialOffset()
Returns
stop()
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 2024-03-22 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]