DataComplete

java.lang.Object
- org.apache.iceberg.connect.events.DataComplete

All Implemented Interfaces:

org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload
```
public class DataComplete
extends java.lang.Object
implements Payload
```
A control event payload for events sent by a worker that indicates it has finished sending all data for a commit request.

Constructor Summary

Constructors
Constructor	Description
`DataComplete(java.util.UUID commitId, java.util.List<TopicPartitionOffset> assignments)`
`DataComplete(org.apache.avro.Schema avroSchema)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.List<TopicPartitionOffset>`	`assignments()`
`java.util.UUID`	`commitId()`
`java.lang.Object`	`get(int i)`
`org.apache.avro.Schema`	`getSchema()`
`void`	`put(int i, java.lang.Object v)`
`PayloadType`	`type()`
`Types.StructType`	`writeSchema()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataComplete

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

DataComplete

public DataComplete(java.util.UUID commitId,
                    java.util.List<TopicPartitionOffset> assignments)

Method Detail
- type
```
public PayloadType type()
```
  Specified by:
  
  type in interface Payload
- commitId
```
public java.util.UUID commitId()
```
- assignments
```
public java.util.List<TopicPartitionOffset> assignments()
```
- 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,
                java.lang.Object v)
```
  Specified by:
  
  put in interface org.apache.avro.generic.IndexedRecord
- get
```
public java.lang.Object get(int i)
```
  Specified by:
  
  get in interface org.apache.avro.generic.IndexedRecord