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