Package org.apache.spark.sql.connector.write.streaming
package org.apache.spark.sql.connector.write.streaming
-
ClassDescriptionA factory of
DataWriter
returned byStreamingWrite.createStreamingWriterFactory(PhysicalWriteInfo)
, which is responsible for creating and initializing the actual data writer at executor side.An interface that defines how to write the data to data source in streaming queries.