Package org.apache.iceberg.connect.events

Class DataWritten

java.lang.Object

org.apache.iceberg.connect.events.DataWritten

All Implemented Interfaces:

org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload

public class DataWritten
extends Object
implements Payload

A control event payload for events sent by a worker that contains the table data that has been written and is ready to commit.

Constructor Summary

Constructors

Constructor	Description
DataWritten(org.apache.avro.Schema avroSchema)
DataWritten(Types.StructType partitionType, UUID commitId, TableReference tableReference, List<DataFile> dataFiles, List<DeleteFile> deleteFiles)

Method Summary

Modifier and Type	Method	Description
UUID	commitId()
List<DataFile>	dataFiles()
List<DeleteFile>	deleteFiles()
Object	get(int i)
org.apache.avro.Schema	getSchema()
void	put(int i, Object v)
TableReference	tableReference()
PayloadType	type()
Types.StructType	writeSchema()

Methods inherited from class java.lang.Object

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

Constructor Details

DataWritten

public DataWritten(org.apache.avro.Schema avroSchema)

DataWritten

public DataWritten(Types.StructType partitionType,
 UUID commitId,
 TableReference tableReference,
 List<DataFile> dataFiles,
 List<DeleteFile> deleteFiles)

Method Details

type

public PayloadType type()

Specified by:

type in interface Payload

commitId

public UUID commitId()

tableReference

public TableReference tableReference()

dataFiles

public List<DataFile> dataFiles()

deleteFiles

public List<DeleteFile> deleteFiles()

writeSchema

public Types.StructType writeSchema()

Specified by:

writeSchema in interface Payload

getSchema

public org.apache.avro.Schema getSchema()

Specified by:

getSchema in interface org.apache.avro.generic.GenericContainer

put

public void put(int i,
 Object v)

Specified by:

put in interface org.apache.avro.generic.IndexedRecord

get

public Object get(int i)

Specified by:

get in interface org.apache.avro.generic.IndexedRecord