com.marklogic.client.dataservices

Interface InputOutputCaller.BulkInputOutputCaller<I,O>

Type Parameters:

I - The representation for document input

O - The representation for document output

All Superinterfaces:

IOEndpoint.BulkIOEndpointCaller

Enclosing interface:

InputOutputCaller<I,O>

public static interface InputOutputCaller.BulkInputOutputCaller<I,O>
extends IOEndpoint.BulkIOEndpointCaller

Provides an interface for completing a unit of work by repeated calls to the input-output endpoint.

See Also:

Bulk Data Services

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	InputOutputCaller.BulkInputOutputCaller.ErrorListener A function implementation that specifies the disposition of a failed call.

Nested classes/interfaces inherited from interface com.marklogic.client.dataservices.IOEndpoint.BulkIOEndpointCaller

IOEndpoint.BulkIOEndpointCaller.ErrorDisposition

Method Summary

Modifier and Type	Method and Description
void	accept(I input) Accepts an input item for the endpoint.
void	acceptAll(I[] input) Accepts multiple input items for the endpoint.
void	setErrorListener(InputOutputCaller.BulkInputOutputCaller.ErrorListener errorListener) Provides a callback specifies the disposition of a failed call.
void	setOutputListener(java.util.function.Consumer<O> listener) Specifies the function to call on receiving output from the endpoint.

Methods inherited from interface com.marklogic.client.dataservices.IOEndpoint.BulkIOEndpointCaller

awaitCompletion, interrupt

Method Detail

setOutputListener

void setOutputListener(java.util.function.Consumer<O> listener)

Specifies the function to call on receiving output from the endpoint.

Parameters:

listener - a function for processing the endpoint output

accept

void accept(I input)

Accepts an input item for the endpoint. Items are queued and submitted to the endpoint in batches.

Parameters:

input - one input item

acceptAll

void acceptAll(I[] input)

Accepts multiple input items for the endpoint. Items are queued and submitted to the endpoint in batches.

Parameters:

input - multiple input items.

setErrorListener

void setErrorListener(InputOutputCaller.BulkInputOutputCaller.ErrorListener errorListener)

Provides a callback specifies the disposition of a failed call.

Parameters:

errorListener - the lambda or other implementation of the error listener