[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# Package com.google.cloud.pubsublite.spark (1.0.0)\n\nVersion latestkeyboard_arrow_down\n\n- [1.0.0 (latest)](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark)\n- [0.4.5](/java/docs/reference/pubsublite-spark-sql-streaming/0.4.5/com.google.cloud.pubsublite.spark)\n- [0.3.4](/java/docs/reference/pubsublite-spark-sql-streaming/0.3.4/com.google.cloud.pubsublite.spark) \n\nClasses\n-------\n\n### [BaseDataStream](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.BaseDataStream)\n\n### [Constants](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.Constants)\n\n### [PslContinuousInputPartition](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslContinuousInputPartition)\n\n### [PslContinuousPartitionReader](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslContinuousPartitionReader)\n\n### [PslContinuousPartitionReaderFactory](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslContinuousPartitionReaderFactory)\n\n### [PslContinuousStream](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslContinuousStream)\n\n### [PslDataWriter](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslDataWriter)\n\n### [PslDataWriterFactory](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslDataWriterFactory)\n\n### [PslMicroBatchInputPartition](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslMicroBatchInputPartition)\n\n### [PslMicroBatchInputPartitionReader](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslMicroBatchInputPartitionReader)\n\n### [PslMicroBatchPartitionReaderFactory](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslMicroBatchPartitionReaderFactory)\n\n### [PslMicroBatchStream](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslMicroBatchStream)\n\n### [PslPartitionOffset](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslPartitionOffset)\n\n### [PslPartitionOffset.Builder](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslPartitionOffset.Builder)\n\n### [PslReadDataSourceOptions](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslReadDataSourceOptions)\n\n### [PslReadDataSourceOptions.Builder](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslReadDataSourceOptions.Builder)\n\n### [PslScanBuilder](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslScanBuilder)\n\nBoth Scan and ScanBuilder implementation, otherwise estimateStatistics() is not called due to bug\nin DataSourceV2Relation.\n\nInformation from\n\u003chttps://github.com/GoogleCloudDataproc/spark-bigquery-connector/blob/b0b2a8add37bd044e5a9976ce635bb4230957f29/spark-bigquery-dsv2/spark-3.1-bigquery/src/main/java/com/google/cloud/spark/bigquery/v2/BigQueryScanBuilder.java#L30\u003e\n\n### [PslSourceOffset](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslSourceOffset)\n\n### [PslSourceOffset.Builder](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslSourceOffset.Builder)\n\n### [PslSparkUtils](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslSparkUtils)\n\n### [PslTable](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslTable)\n\n### [PslTableProvider](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslTableProvider)\n\n### [PslWrite](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslWrite)\n\nPub/Sub Lite class for writing.\n\nNote that SupportsStreamingUpdateAsAppend is the same hack that [kafka](https://github.com/apache/spark/commit/db89b0e1b8bb98db6672f2b89e42e8a14e06e745)\nuses to opt-in to writing aggregates without requiring windowing.\n\n### [PslWriteDataSourceOptions](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslWriteDataSourceOptions)\n\n### [PslWriteDataSourceOptions.Builder](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslWriteDataSourceOptions.Builder)\n\n### [PslWriterCommitMessage](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.PslWriterCommitMessage)\n\n### [SparkSourceOffset](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.SparkSourceOffset)\n\n### [SparkStructs](/java/docs/reference/pubsublite-spark-sql-streaming/latest/com.google.cloud.pubsublite.spark.SparkStructs)"]]
