Function getPrimaryKeyIndices

delta/controller.go:616–625

Helper function to get the primary key indices.

(appender *DeltaAppender)

// Helper function to get the primary key indices.
func getPrimaryKeyIndices(appender *DeltaAppender) []int {
	schema := appender.BaseSchema()
	indices := make([]int, 0, 1)
	for i, col := range schema {
		if col.PrimaryKey {
			indices = append(indices, i+appender.NumAugmentedFields())
		}
	}
	return indices
}

// Helper function to get the primary key. For composite primary keys, `row()` is used.
func getPrimaryKeyStruct(schema sql.Schema) string {