TypedDocumentIBulkSession

Functions

Link copied to clipboard
abstract suspend fun create(source: String, index: String? = null, id: String? = null, requireAlias: Boolean? = null, routing: String? = null)
Link copied to clipboard
inline suspend fun <T> BulkSession.create(doc: T, index: String? = null, id: String? = null, requireAlias: Boolean? = null, routing: String? = null)
Link copied to clipboard
abstract suspend fun delete(id: String, index: String? = null, requireAlias: Boolean? = null, routing: String? = null)
Link copied to clipboard
abstract suspend fun flush()
Link copied to clipboard
abstract suspend fun index(    source: String,     index: String? = null,     id: String? = null,     requireAlias: Boolean? = null,     ifSeqNo: Long? = null,     ifPrimaryTerm: Long? = null,     routing: String? = null)
Link copied to clipboard
inline suspend fun <T> BulkSession.index(doc: T, index: String? = null, id: String? = null, requireAlias: Boolean? = null, routing: String? = null)
Link copied to clipboard
abstract suspend fun update(    id: String,     script: Script,     index: String? = null,     requireAlias: Boolean? = null,     upsert: JsonObject? = null,     ifSeqNo: Long? = null,     ifPrimaryTerm: Long? = null,     routing: String? = null)
abstract suspend fun update(    id: String,     doc: String,     index: String? = null,     requireAlias: Boolean? = null,     docAsUpsert: Boolean? = null,     ifSeqNo: Long? = null,     ifPrimaryTerm: Long? = null,     routing: String? = null)
abstract suspend fun update(    id: String,     doc: JsonObject,     index: String? = null,     requireAlias: Boolean? = null,     docAsUpsert: Boolean? = null,     ifSeqNo: Long? = null,     ifPrimaryTerm: Long? = null,     routing: String? = null)
abstract suspend fun update(getDocumentResponse: SourceInformation, updateBlock: (T) -> T)
abstract suspend fun update(id: String, original: T, ifSeqNo: Long, ifPrimaryTerm: Long, updateBlock: (T) -> T)
Link copied to clipboard
inline suspend fun <T> BulkSession.update(doc: T, id: String, index: String? = null, requireAlias: Boolean? = null, docAsUpsert: Boolean? = null)
inline suspend fun <T> BulkSession.update(script: Script, id: String, upsert: T, index: String? = null, requireAlias: Boolean? = null)