Package com.cognite.client.servicesV1

Class ConnectorServiceV1.SingleRequestItemReader<T>

java.lang.Object

com.cognite.client.servicesV1.ConnectorServiceV1.ConnectorBase

com.cognite.client.servicesV1.ConnectorServiceV1.SingleRequestItemReader<T>

All Implemented Interfaces:

ItemReader<T>, Serializable

Enclosing class:

ConnectorServiceV1

public abstract static class ConnectorServiceV1.SingleRequestItemReader<T>
extends ConnectorServiceV1.ConnectorBase
implements ItemReader<T>

Reads items from the Cognite API. This reader targets API endpoints which complete its operation in a single request.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SingleRequestItemReader()

Method Summary

Modifier and Type	Method	Description
ResponseItems<T>	getItems(Request items)	Executes a request to get items and blocks the thread until all items have been downloaded.
CompletableFuture<ResponseItems<T>>	getItemsAsync(Request items)	Executes an item-based request to get items asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Details

SingleRequestItemReader

public SingleRequestItemReader()

Method Details

getItems

public ResponseItems<T> getItems(Request items)
                          throws Exception

Executes a request to get items and blocks the thread until all items have been downloaded.

Specified by:

getItems in interface ItemReader<T>

Parameters:

items -

Returns:

Throws:

Exception

getItemsAsync

public CompletableFuture<ResponseItems<T>> getItemsAsync(Request items)
                                                  throws Exception

Executes an item-based request to get items asynchronously.

Specified by:

getItemsAsync in interface ItemReader<T>

Parameters:

items -

Returns:

Throws:

Exception