Interface ModelCommitBatchingClient.ModelCommitBatch

Enclosing interface:

ModelCommitBatchingClient

public static interface ModelCommitBatchingClient.ModelCommitBatch

Method Summary

Modifier and Type	Method	Description
CompletableFuture<CommitModelsResult>	add(int slot, CommitModels commit)	Adds a prepared commit at its reserved slot and returns a future for that commit's result.
default CompletableFuture<CommitModelsResult>	add(int slot, CommitModels commit, ModelCommitBatchingClient.ModelCommitCompletion completion)	Adds a commit whose post-commit work may be combined with other results in the same transport response.
void	fail(Throwable failure)	Fails the batch and its pending commit completions with the supplied cause.
void	flush()	Flushes pending commits according to the implementation's batch-release policy.
void	skip(int slot)	Marks a reserved slot as intentionally empty.

Method Details

add

CompletableFuture<CommitModelsResult> add(int slot,
 CommitModels commit)

Adds a prepared commit at its reserved slot and returns a future for that commit's result.

add

default CompletableFuture<CommitModelsResult> add(int slot,
 CommitModels commit,
 ModelCommitBatchingClient.ModelCommitCompletion completion)

Adds a commit whose post-commit work may be combined with other results in the same transport response. Implementations without grouped result support retain correct per-result completion.

skip

void skip(int slot)

Marks a reserved slot as intentionally empty.

flush

void flush()

Flushes pending commits according to the implementation's batch-release policy.

fail

void fail(Throwable failure)

Fails the batch and its pending commit completions with the supplied cause.