Package dev.vortex.spark.write

Class PartitionedVortexDataWriter.PartitionedWriterCommitMessage

java.lang.Object

dev.vortex.spark.write.PartitionedVortexDataWriter.PartitionedWriterCommitMessage

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.write.WriterCommitMessage

Enclosing class:

PartitionedVortexDataWriter

public static final class PartitionedVortexDataWriter.PartitionedWriterCommitMessage
extends Object
implements org.apache.spark.sql.connector.write.WriterCommitMessage, Serializable

Commit message that aggregates results from multiple partition writers.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
List<VortexWriterCommitMessage>	getPartitionMessages()	Returns the commit messages from each individual partition writer.

Methods inherited from class java.lang.Object

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

Method Details

getPartitionMessages

public List<VortexWriterCommitMessage> getPartitionMessages()

Returns the commit messages from each individual partition writer.