Package com.cognite.client.servicesV1

Class ConnectorServiceV1.ItemWriter

java.lang.Object

com.cognite.client.servicesV1.ConnectorServiceV1.ConnectorBase

com.cognite.client.servicesV1.ConnectorServiceV1.ItemWriter

All Implemented Interfaces:

Serializable

Enclosing class:

ConnectorServiceV1

public abstract static class ConnectorServiceV1.ItemWriter
extends ConnectorServiceV1.ConnectorBase

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ItemWriter()

Method Summary

Modifier and Type	Method	Description
abstract ResponseParser<String>	getDuplicatesResponseParser()
ConnectorServiceV1.ItemWriter	withDuplicatesResponseParser(ResponseParser<String> parser)	Configures the duplicates response parser to use.
ConnectorServiceV1.ItemWriter	withRequestExecutor(RequestExecutor requestExecutor)	Configure a specific RequestExecutor to handle the HTTP(S) request against the Cognnite API.
ResponseItems<String>	writeItems(Request items)	Executes an item-based write request.
CompletableFuture<ResponseItems<String>>	writeItemsAsync(Request items)	Executes an item-based write request asynchronously.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ItemWriter

public ItemWriter()

Method Details

getDuplicatesResponseParser

public abstract ResponseParser<String> getDuplicatesResponseParser()

withDuplicatesResponseParser

public ConnectorServiceV1.ItemWriter withDuplicatesResponseParser(ResponseParser<String> parser)

Configures the duplicates response parser to use. The default duplicates response parser looks for duplicates at the error.duplicates node in the response.

Parameters:

parser -

Returns:

withRequestExecutor

public ConnectorServiceV1.ItemWriter withRequestExecutor(RequestExecutor requestExecutor)

Configure a specific RequestExecutor to handle the HTTP(S) request against the Cognnite API.

Parameters:

requestExecutor - The RequestExecutor to use.

Returns:

ItemWriter with the configured RequestExecutor.

writeItems

public ResponseItems<String> writeItems(Request items)
                                 throws Exception

Executes an item-based write request. This method will block until the response is ready. The async version of this method is writeItemsAsync.

Parameters:

items -

Returns:

Throws:

Exception

writeItemsAsync

public CompletableFuture<ResponseItems<String>> writeItemsAsync(Request items)
                                                         throws Exception

Executes an item-based write request asynchronously.

Parameters:

items -

Returns:

Throws:

Exception