kdrant-core/dev.kdrant.dsl/BatchUpdateBuilder

BatchUpdateBuilder

DSL for batchUpdate: accumulate point, vector and payload operations that Qdrant applies in the order they are added.

qdrant.batchUpdate("docs", wait = true) {
    upsert { point(1) { vector(0.1f, 0.2f); payload("lang" to "en") } }
    setPayload(payloadOf("reviewed" to true), byId(1))
    delete(byFilter { must { "stale" eq true } })
}

Constructors

BatchUpdateBuilder

constructor()

Functions

byFilter

fun byFilter(configure: FilterBuilder.() -> Unit): DeleteSelector

Select points by filter. An empty filter is rejected: on delete or clearPayload it would match every point in the collection.

byId

fun byId(ids: List<PointId>): DeleteSelector

Select points by id.

fun byId(vararg ids: PointId): DeleteSelector

Select points by id, e.g. setPayload(p, byId(1, 2)).

fun byId(vararg ids: Long): DeleteSelector

Select points by id, e.g. byId(1, 2) for numeric ids.

clearPayload

fun clearPayload(selector: DeleteSelector)

Clear all payload from the selected points.

delete

fun delete(selector: DeleteSelector)

Delete the selected points.

deletePayload

fun deletePayload(keys: List<String>, selector: DeleteSelector)

Delete keys from the selected points' payload.

deleteVectors

fun deleteVectors(vectors: List<String>, selector: DeleteSelector)

Delete the named vectors from the selected points.

overwritePayload

fun overwritePayload(payload: Payload, selector: DeleteSelector)

Replace the selected points' payload with payload.

setPayload

fun setPayload(payload: Payload, selector: DeleteSelector, key: String? = null)

Merge payload into the selected points' payload, optionally under the nested path key.

updateVectors

fun updateVectors(points: List<PointVectors>)

Update the vectors of existing points, keeping their payload.

upsert

fun upsert(configure: UpsertBuilder.() -> Unit)

Insert or replace points, using the same DSL as upsert.