Class 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()
-
-
-
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()
-
commitId
public java.util.UUID commitId()
-
assignments
public java.util.List<TopicPartitionOffset> assignments()
-
writeSchema
public Types.StructType writeSchema()
- Specified by:
writeSchema
in interfacePayload
-
getSchema
public org.apache.avro.Schema getSchema()
- Specified by:
getSchema
in interfaceorg.apache.avro.generic.GenericContainer
-
put
public void put(int i, java.lang.Object v)
- Specified by:
put
in interfaceorg.apache.avro.generic.IndexedRecord
-
get
public java.lang.Object get(int i)
- Specified by:
get
in interfaceorg.apache.avro.generic.IndexedRecord
-
-