org.apache.iceberg.spark.source

Class SparkMicroBatchStream

java.lang.Object

org.apache.iceberg.spark.source.SparkMicroBatchStream

All Implemented Interfaces:

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

public class SparkMicroBatchStream
extends java.lang.Object
implements org.apache.spark.sql.connector.read.streaming.MicroBatchStream

Method Summary

Modifier and Type	Method and Description
void	commit(org.apache.spark.sql.connector.read.streaming.Offset end)
org.apache.spark.sql.connector.read.PartitionReaderFactory	createReaderFactory()
org.apache.spark.sql.connector.read.streaming.Offset	deserializeOffset(java.lang.String json)
org.apache.spark.sql.connector.read.streaming.Offset	initialOffset()
org.apache.spark.sql.connector.read.streaming.Offset	latestOffset()
org.apache.spark.sql.connector.read.InputPartition[]	planInputPartitions(org.apache.spark.sql.connector.read.streaming.Offset start, org.apache.spark.sql.connector.read.streaming.Offset end)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

latestOffset

public org.apache.spark.sql.connector.read.streaming.Offset latestOffset()

Specified by:

latestOffset in interface org.apache.spark.sql.connector.read.streaming.MicroBatchStream

planInputPartitions

public org.apache.spark.sql.connector.read.InputPartition[] planInputPartitions(org.apache.spark.sql.connector.read.streaming.Offset start,
                                                                                org.apache.spark.sql.connector.read.streaming.Offset end)

Specified by:

planInputPartitions in interface org.apache.spark.sql.connector.read.streaming.MicroBatchStream

createReaderFactory

public org.apache.spark.sql.connector.read.PartitionReaderFactory createReaderFactory()

Specified by:

createReaderFactory in interface org.apache.spark.sql.connector.read.streaming.MicroBatchStream

initialOffset

public org.apache.spark.sql.connector.read.streaming.Offset initialOffset()

Specified by:

initialOffset in interface org.apache.spark.sql.connector.read.streaming.SparkDataStream

deserializeOffset

public org.apache.spark.sql.connector.read.streaming.Offset deserializeOffset(java.lang.String json)

Specified by:

deserializeOffset in interface org.apache.spark.sql.connector.read.streaming.SparkDataStream

commit

public void commit(org.apache.spark.sql.connector.read.streaming.Offset end)

Specified by:

commit in interface org.apache.spark.sql.connector.read.streaming.SparkDataStream

stop

public void stop()

Specified by:

stop in interface org.apache.spark.sql.connector.read.streaming.SparkDataStream