Package com.cognite.client
Class ThreeDNodes
- java.lang.Object
-
- com.cognite.client.ThreeDNodes
-
public abstract class ThreeDNodes extends Object
This class represents the Cognite 3D nodes api endpoint. It provides methods for readingThreeDNode.
-
-
Field Summary
Fields Modifier and Type Field Description protected static org.slf4j.LoggerLOG
-
Constructor Summary
Constructors Constructor Description ThreeDNodes()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected RequestaddAuthInfo(Request request)Adds the required authentication information into the request object.protected com.cognite.client.dto.Aggregateaggregate(ResourceType resourceType, Request requestParameters)Performs an item aggregation request to Cognite Data Fusion.protected List<String>buildPartitionsList(int noPartitions)Builds an array of partition specifications for parallel retrieval from the Cognite api.protected List<com.cognite.client.dto.Item>deDuplicate(Collection<com.cognite.client.dto.Item> itemList)De-duplicates a collection ofItem.Iterator<List<com.cognite.client.dto.ThreeDNode>>filter(Long modelId, Long revisionId)Returns allThreeDNodeobjects that matches the filters set in theRequest.Iterator<List<com.cognite.client.dto.ThreeDNode>>filter(Long modelId, Long revisionId, Request requestParameters)Returns allThreeDNodeobjects that matches the filters set in theRequest.Iterator<List<com.cognite.client.dto.ThreeDNode>>filter(Long modelId, Long revisionId, Request requestParameters, String... partitions)Returns allThreeDNodeobjects that matches the filters set in theRequest.abstract CogniteClientgetClient()protected Iterator<CompletableFuture<ResponseItems<String>>>getListResponseIterator(ResourceType resourceType, Request requestParameters)protected booleanitemsHaveId(Collection<com.cognite.client.dto.Item> items)Returns true if all items contain either an externalId or id.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId)Returns allThreeDNodeobjects.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId, Request requestParameters)Returns allThreeDNodeobjects that matches the filters set in theRequest.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId, Request requestParameters, String... partitions)Returns allThreeDNodeobjects that matches the filters set in theRequestfor the specified partitions.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId, Long nodeId)Returns all ancestorThreeDNodeobjects.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId, Long nodeId, Request requestParameters)Returns all ancestorThreeDNodeobjects that matches the filters set in theRequest.Iterator<List<com.cognite.client.dto.ThreeDNode>>list(Long modelId, Long revisionId, Long nodeId, Request requestParameters, String... partitions)Returns all ancestorThreeDNodeobjects that matches the filters set in theRequestfor the specified partitions.protected Iterator<List<String>>listJson(ResourceType resourceType, Request requestParameters, String... partitions)Will return the results from alist / filterapi endpoint.protected Iterator<List<String>>listJson(ResourceType resourceType, Request requestParameters, String partitionKey, String... partitions)Will return the results from alist / filterapi endpoint.protected Map<String,com.cognite.client.dto.Item>mapItemToId(Collection<com.cognite.client.dto.Item> items)Maps all items to their externalId (primary) or id (secondary).static ThreeDNodesof(CogniteClient client)Constructs a newThreeDNodesobject using the provided client configuration.protected List<com.cognite.client.dto.Item>parseItems(List<String> input)Parses a list of item object in json representation to typed objects.protected StringparseName(String json)Returns the name attribute value from a json input.protected StringparseString(String itemJson, String fieldName)Try parsing the specified Json path as aString.List<com.cognite.client.dto.ThreeDNode>retrieve(Long modelId, Long revisionId, List<com.cognite.client.dto.Item> items)Retrieves 3D Nodes by ids.protected List<String>retrieveJson(ResourceType resourceType, Collection<com.cognite.client.dto.Item> items)Retrieve items by id.protected List<String>retrieveJson(ResourceType resourceType, Collection<com.cognite.client.dto.Item> items, Map<String,Object> parameters)Retrieve items by id.protected List<Map<String,Object>>toRequestItems(Collection<com.cognite.client.dto.Item> itemList)Converts a list ofItemto a request object structure (that can later be parsed to Json).
-
-
-
Method Detail
-
of
public static ThreeDNodes of(CogniteClient client)
Constructs a newThreeDNodesobject using the provided client configuration. This method is intended for internal use--SDK clients should always useCogniteClientas the entry point to this class.- Parameters:
client- TheCogniteClientto use for configuration settings.- Returns:
- the 3D models available outputs api object.
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId) throws Exception
Returns allThreeDNodeobjects.- Throws:
Exception- See Also:
list(Long, Long, Request)
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId, Request requestParameters) throws Exception
Returns allThreeDNodeobjects that matches the filters set in theRequest. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. The 3D nodes are retrieved using multiple, parallel request streams towards the Cognite api. The number of parallel streams are set in theClientConfig.
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId, Request requestParameters, String... partitions) throws Exception
Returns allThreeDNodeobjects that matches the filters set in theRequestfor the specified partitions. This is method is intended for advanced use cases where you need direct control over the individual partitions. For example, when using the SDK in a distributed computing environment. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure.
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId, Long nodeId) throws Exception
Returns all ancestorThreeDNodeobjects.- Throws:
Exception- See Also:
list(Long, Long, Request)
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId, Long nodeId, Request requestParameters) throws Exception
Returns all ancestorThreeDNodeobjects that matches the filters set in theRequest. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. The 3D nodes are retrieved using multiple, parallel request streams towards the Cognite api. The number of parallel streams are set in theClientConfig.
-
list
public Iterator<List<com.cognite.client.dto.ThreeDNode>> list(Long modelId, Long revisionId, Long nodeId, Request requestParameters, String... partitions) throws Exception
Returns all ancestorThreeDNodeobjects that matches the filters set in theRequestfor the specified partitions. This is method is intended for advanced use cases where you need direct control over the individual partitions. For example, when using the SDK in a distributed computing environment. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure.
-
retrieve
public List<com.cognite.client.dto.ThreeDNode> retrieve(Long modelId, Long revisionId, List<com.cognite.client.dto.Item> items) throws Exception
Retrieves 3D Nodes by ids.- Parameters:
modelId- ID of ThreeDModel objectrevisionId- ID of ThreeDModelRevision objectitems- The item(s)idto retrieve- Returns:
- LIst of retrieved 3D Nodes.
- Throws:
Exception
-
filter
public Iterator<List<com.cognite.client.dto.ThreeDNode>> filter(Long modelId, Long revisionId) throws Exception
Returns allThreeDNodeobjects that matches the filters set in theRequest. Endpoint is nodes/list The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. The 3D nodes are retrieved using multiple, parallel request streams towards the Cognite api. The number of parallel streams are set in theClientConfig.
-
filter
public Iterator<List<com.cognite.client.dto.ThreeDNode>> filter(Long modelId, Long revisionId, Request requestParameters) throws Exception
Returns allThreeDNodeobjects that matches the filters set in theRequest. Endpoint is nodes/list The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. The 3D nodes are retrieved using multiple, parallel request streams towards the Cognite api. The number of parallel streams are set in theClientConfig.
-
filter
public Iterator<List<com.cognite.client.dto.ThreeDNode>> filter(Long modelId, Long revisionId, Request requestParameters, String... partitions) throws Exception
Returns allThreeDNodeobjects that matches the filters set in theRequest. Endpoint is nodes/list The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. The 3D nodes are retrieved using multiple, parallel request streams towards the Cognite api. The number of parallel streams are set in theClientConfig.
-
getClient
public abstract CogniteClient getClient()
-
buildPartitionsList
protected List<String> buildPartitionsList(int noPartitions)
Builds an array of partition specifications for parallel retrieval from the Cognite api. This specification is used as a parameter together with the filter / list endpoints. The number of partitions indicate the number of parallel read streams. Employ one partition specification per read stream.- Parameters:
noPartitions- The total number of partitions- Returns:
- a
Listof partition specifications
-
listJson
protected Iterator<List<String>> listJson(ResourceType resourceType, Request requestParameters, String... partitions) throws Exception
Will return the results from alist / filterapi endpoint. For example, thefilter assetsendpoint. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. This method support parallel retrieval via a set ofpartitionspecifications. The specified partitions will be collected and merged together before being returned via theIterator.- Parameters:
resourceType- The resource type to query / filter / list. Ex.event, asset, time series.requestParameters- The query / filter specification. Follows the Cognite api request parameters.partitions- An optional set of partitions to read via.- Returns:
- an
Iteratorover the results set. - Throws:
Exception
-
listJson
protected Iterator<List<String>> listJson(ResourceType resourceType, Request requestParameters, String partitionKey, String... partitions) throws Exception
Will return the results from alist / filterapi endpoint. For example, thefilter assetsendpoint. The results are paged through / iterated over via anIterator--the entire results set is not buffered in memory, but streamed in "pages" from the Cognite api. If you need to buffer the entire results set, then you have to stream these results into your own data structure. This method support parallel retrieval via a set ofpartitionspecifications. The specified partitions will be collected and merged together before being returned via theIterator.- Parameters:
resourceType- The resource type to query / filter / list. Ex.event, asset, time series.requestParameters- The query / filter specification. Follows the Cognite api request parameters.partitionKey- The key to use for the partitions in the read request. For examplepartitionorcursor.partitions- An optional set of partitions to read via.- Returns:
- an
Iteratorover the results set. - Throws:
Exception
-
retrieveJson
protected List<String> retrieveJson(ResourceType resourceType, Collection<com.cognite.client.dto.Item> items) throws Exception
Retrieve items by id. Will ignore unknown ids by default.- Parameters:
resourceType- The item resource type (Event,Asset, etc.) to retrieve.items- The item(s)externalId / idto retrieve.- Returns:
- The items in Json representation.
- Throws:
Exception
-
retrieveJson
protected List<String> retrieveJson(ResourceType resourceType, Collection<com.cognite.client.dto.Item> items, Map<String,Object> parameters) throws Exception
Retrieve items by id. This version allows you to explicitly set additional parameters for the retrieve request. For example:<"ignoreUnknownIds", true>and<"fetchResources", true>.- Parameters:
resourceType- The item resource type (Event,Asset, etc.) to retrieve.items- The item(s)externalId / idto retrieve.parameters- Additional parameters for the request. For example <"ignoreUnknownIds", true>- Returns:
- The items in Json representation.
- Throws:
Exception
-
aggregate
protected com.cognite.client.dto.Aggregate aggregate(ResourceType resourceType, Request requestParameters) throws Exception
Performs an item aggregation request to Cognite Data Fusion. The default aggregation is a total item count based on the (optional) filters in the request. Some resource types, for exampleEvent, supports multiple types of aggregation.- Parameters:
resourceType- The resource type to perform aggregation of.requestParameters- The request containing filters.- Returns:
- The aggregation result.
- Throws:
Exception- See Also:
- Cognite API v1 specification
-
addAuthInfo
protected Request addAuthInfo(Request request) throws Exception
Adds the required authentication information into the request object. If the request object already have complete auth info nothing will be added. The following authentication schemes are supported: 1) API key. When using an api key, this service will look up the corresponding project/tenant to issue requests to.- Parameters:
request- The request to enrich with auth information.- Returns:
- The request parameters with auth info added to it.
- Throws:
Exception
-
getListResponseIterator
protected Iterator<CompletableFuture<ResponseItems<String>>> getListResponseIterator(ResourceType resourceType, Request requestParameters) throws Exception
- Throws:
Exception
-
parseItems
protected List<com.cognite.client.dto.Item> parseItems(List<String> input) throws Exception
Parses a list of item object in json representation to typed objects.- Parameters:
input- the item list in Json string representation- Returns:
- the parsed item objects
- Throws:
Exception
-
toRequestItems
protected List<Map<String,Object>> toRequestItems(Collection<com.cognite.client.dto.Item> itemList)
Converts a list ofItemto a request object structure (that can later be parsed to Json).- Parameters:
itemList- The items to parse.- Returns:
- The items in request item object form.
-
deDuplicate
protected List<com.cognite.client.dto.Item> deDuplicate(Collection<com.cognite.client.dto.Item> itemList)
De-duplicates a collection ofItem.- Parameters:
itemList-- Returns:
-
itemsHaveId
protected boolean itemsHaveId(Collection<com.cognite.client.dto.Item> items)
Returns true if all items contain either an externalId or id.- Parameters:
items-- Returns:
-
mapItemToId
protected Map<String,com.cognite.client.dto.Item> mapItemToId(Collection<com.cognite.client.dto.Item> items)
Maps all items to their externalId (primary) or id (secondary). If the id function does not return any identity, the item will be mapped to the empty string. Via the identity mapping, this function will also perform deduplication of the input items.- Parameters:
items- the items to map to externalId / id.- Returns:
- the
Mapwith all items mapped to externalId / id.
-
parseString
protected String parseString(String itemJson, String fieldName)
Try parsing the specified Json path as aString.- Parameters:
itemJson- The Json stringfieldName- The Json path to parse- Returns:
- The Json path as a
String.
-
-