id1.kt

class IcebergMetadataWriter {
    // In a real world usecase, you can create this dynamically from the data.
    val icebergTable: Table = icebergCatalog.loadTable(TableIdentifier.of(Namespace.of(NAMESPACE), TABLE_NAME))
    val appendFiles: AppendFiles = icebergTable.newAppend()

    // Lambda handler
    fun handle(sqsEvent: SQSEvent) {
        for (record in sqsEvent.records) {
            processRecord(record, tableObjs)
        }
        appendFiles.commit()
    }
}