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
A control event payload for events sent by a worker that indicates it has finished sending all
data for a commit request.
-
Constructor Summary
ConstructorDescriptionDataComplete
(UUID commitId, List<TopicPartitionOffset> assignments) DataComplete
(org.apache.avro.Schema avroSchema) -
Method Summary
-
Constructor Details
-
DataComplete
public DataComplete(org.apache.avro.Schema avroSchema) -
DataComplete
-
-
Method Details
-
type
-
commitId
-
assignments
-
writeSchema
- Specified by:
writeSchema
in interfacePayload
-
getSchema
public org.apache.avro.Schema getSchema()- Specified by:
getSchema
in interfaceorg.apache.avro.generic.GenericContainer
-
put
- Specified by:
put
in interfaceorg.apache.avro.generic.IndexedRecord
-
get
- Specified by:
get
in interfaceorg.apache.avro.generic.IndexedRecord
-