Package com.cognite.client
Class DataPoints
- java.lang.Object
-
- com.cognite.client.DataPoints
-
- All Implemented Interfaces:
UpsertTarget<TimeseriesPointPost,TimeseriesPointPost>
public abstract class DataPoints extends Object implements UpsertTarget<TimeseriesPointPost,TimeseriesPointPost>
This class represents the Cognite timeseries api endpoint. It provides methods for readingTimeseriesPointand writingTimeseriesPointPost.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classDataPoints.FlatMapIterator<T>
-
Field Summary
Fields Modifier and Type Field Description protected static org.slf4j.LoggerLOG
-
Constructor Summary
Constructors Constructor Description DataPoints()
-
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 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<Item>deDuplicate(Collection<Item> itemList)De-duplicates a collection ofItem.List<Item>delete(List<Item> dataPoints)Deletes a set of dataPoints.abstract CogniteClientgetClient()protected Iterator<CompletableFuture<ResponseItems<String>>>getListResponseIterator(ResourceType resourceType, Request requestParameters)doublegetMaxFrequency(Request requestParameters, Instant startOfWindow, Instant endOfWindow)Calculate the max frequency of the TS items in the query.protected booleanitemsHaveId(Collection<Item> items)Returns true if all items contain either an externalId or id.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,Item>mapItemToId(Collection<Item> items)Maps all items to their externalId (primary) or id (secondary).static DataPointsof(CogniteClient client)Construct a newDataPointsobject using the provided configuration.protected List<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.Iterator<List<TimeseriesPoint>>retrieve(Request requestParameters)Returns allTimeseriesPointobjects that matches the filters set in theRequest.Iterator<List<TimeseriesPoint>>retrieveComplete(long... id)Retrieve allTimeseriesPoint/data points for the specified time series (id).Iterator<List<TimeseriesPoint>>retrieveComplete(String... externalId)Retrieve allTimeseriesPoint/data points for the specified time series (externalId).Iterator<List<TimeseriesPoint>>retrieveComplete(List<Item> items)Returns allTimeseriesPointobjects that matches the item specifications (externalId / id).List<TimeseriesPoint>retrieveFirst(long... id)Retrieve the first (eldest) data point for a time series.List<TimeseriesPoint>retrieveFirst(String... externalId)Retrieve the first (eldest) data point for a time series.List<TimeseriesPoint>retrieveFirst(List<Item> items)Retrieve the first (eldest) data point for a time series.protected List<String>retrieveJson(ResourceType resourceType, Collection<Item> items)Retrieve items by id.protected List<String>retrieveJson(ResourceType resourceType, Collection<Item> items, Map<String,Object> parameters)Retrieve items by id.List<TimeseriesPoint>retrieveLatest(long... id)Retrieves the latest (newest) data point for a time series.List<TimeseriesPoint>retrieveLatest(String... externalId)Retrieves the latest (newest) data point for a time series.List<TimeseriesPoint>retrieveLatest(List<Item> items)Retrieves the latest (newest) data point for a time series.protected List<Map<String,Object>>toRequestItems(Collection<Item> itemList)Converts a list ofItemto a request object structure (that can later be parsed to Json).UploadQueue<TimeseriesPointPost,TimeseriesPointPost>uploadQueue()Returns an upload queue.List<TimeseriesPointPost>upsert(List<TimeseriesPointPost> dataPoints)Creates or update a set ofTimeseriesPointPostobjects.
-
-
-
Method Detail
-
of
public static DataPoints of(CogniteClient client)
Construct a newDataPointsobject using the provided 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 assets api object.
-
retrieve
public Iterator<List<TimeseriesPoint>> retrieve(Request requestParameters) throws Exception
Returns allTimeseriesPointobjects that matches the filters set in theRequest. Please note that only root-level filter and aggregate specifications are supported. That is, per-item specifications of time filters and/or aggregations are not supported. If you need to apply different time and/or aggregation specifications, then these should be submitted in separate requests--each using root-level specifications. 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.Example:
API Reference - Retrieve data pointsList<TimeseriesPoint> results = new ArrayList<>(); client.timeseries().dataPoints() .retrieve(Request.create().withRootParameter("includeOutsidePoints", true)) .forEachRemaining(items-> results.addAll(items));- Parameters:
requestParameters- the filters to use for retrieving the timeseries.- Returns:
- an
Iteratorto page through the results set. - Throws:
Exception- See Also:
CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveComplete
public Iterator<List<TimeseriesPoint>> retrieveComplete(String... externalId) throws Exception
Retrieve allTimeseriesPoint/data points for the specified time series (externalId). Refer toretrieveComplete(List)for more information.Example:
API Reference - Retrieve data pointsList<TimeseriesPoint> results = new ArrayList<>(); client.timeseries().dataPoints() .retrieveComplete("10", "20") .forEachRemaining(result -> results.addAll(result));- Parameters:
externalId- TheexternalIdsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveComplete(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveComplete
public Iterator<List<TimeseriesPoint>> retrieveComplete(long... id) throws Exception
Retrieve allTimeseriesPoint/data points for the specified time series (id). Refer toretrieveComplete(List)for more information.Example:
API Reference - Retrieve data pointsList<TimeseriesPoint> results = new ArrayList<>(); client.timeseries().dataPoints() .retrieveComplete(10, 20) .forEachRemaining(result -> results.addAll(result));- Parameters:
id- Theidsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveComplete(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveComplete
public Iterator<List<TimeseriesPoint>> retrieveComplete(List<Item> items) throws Exception
Returns allTimeseriesPointobjects that matches the item specifications (externalId / id). 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.Example:
API Reference - Retrieve data pointsList<Item> byInternalIds = List.of(Item.newBuilder().setId(10).build()); client.timeseries().dataPoints() .retrieveComplete(byInternalIds) .forEachRemaining(result -> results.addAll(result));- Parameters:
items-- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieve(Request),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
upsert
public List<TimeseriesPointPost> upsert(@NotNull List<TimeseriesPointPost> dataPoints) throws Exception
Creates or update a set ofTimeseriesPointPostobjects.TimeseriesPointPostis the write-optimized version of a time series data point whileTimeseriesPointis the read-optimized version. If it is a newTimeseriesPointPostobject (based on theid / externalId + timestamp, then it will be created. If anTimeseriesPointobject already exists in Cognite Data Fusion, it will be updated. The algorithm runs as follows: 1. Write allTimeseriesPointPostobjects to the Cognite API. 2. If one (or more) of the objects fail, check if it is because of missing time series objects--create temp headers. 3. Retry the failedTimeseriesPointPostobjects.Example:
API Reference - Insert data points// Create the time series header. List<TimeseriesMetadata> upsertTimeseriesList = List.of(TimeseriesMetadata.newBuilder() .setExternalId("my-external-id") .setName("test_ts") .setIsString(false) .setIsStep(false) .setDescription("Description") .setUnit("TestUnits") .putMetadata("type", "sdk-data-generator") .putMetadata("sdk-data-generator", "sdk-data-generator") .build()); client.timeseries().upsert(upsertTimeseriesList); // Add time series data points. List<TimeseriesPointPost> dataPoints = List.of( TimeseriesPointPost.newBuilder() .setExternalId("my-external-id") .setTimestamp(Instant.parse("2020-12-03T10:15:30.00Z").toEpochMilli()) .setValueNum(ThreadLocalRandom.current().nextLong(-10, 20)) .build(), TimeseriesPointPost.newBuilder() .setExternalId("my-external-id") .setTimestamp(Instant.parse("2020-12-03T10:16:30.00Z").toEpochMilli()) .setValueNum(ThreadLocalRandom.current().nextLong(-10, 20)) .build() ); client.timeseries().dataPoints().upsert.upsert(dataPoints);- Specified by:
upsertin interfaceUpsertTarget<TimeseriesPointPost,TimeseriesPointPost>- Parameters:
dataPoints- The data points to upsert- Returns:
- The upserted data points
- Throws:
Exception- See Also:
CogniteClient,CogniteClient.timeseries()
-
uploadQueue
public UploadQueue<TimeseriesPointPost,TimeseriesPointPost> uploadQueue()
Returns an upload queue. The upload queue helps improve performance by batching items together before uploading them to Cognite Data Fusion. This queue is tuned with a capacity of 500k elements for high-throughput data points.- Returns:
- The upload queue.
-
retrieveLatest
public List<TimeseriesPoint> retrieveLatest(String... externalId) throws Exception
Retrieves the latest (newest) data point for a time series. Refer toretrieveLatest(List)for more information.Example:
API Reference - Retrieve latest data pointList<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveLatest("10", "20");- Parameters:
externalId- TheexternalIdsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveLatest(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveLatest
public List<TimeseriesPoint> retrieveLatest(long... id) throws Exception
Retrieves the latest (newest) data point for a time series. Refer toretrieveLatest(List)for more information.Example:
API Reference - Retrieve latest data pointList<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveLatest(10, 20);- Parameters:
id- Theidsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveLatest(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveLatest
public List<TimeseriesPoint> retrieveLatest(@NotNull List<Item> items) throws Exception
Retrieves the latest (newest) data point for a time series. TheItemmust specify the externalId / id of the time series. Optionally, you can specifyItem.exclusiveEndto set an upper time boundary. That is, the response will contain the latest data point before the upper time boundary.Example:
API Reference - Retrieve latest data pointList<Item> byInternalIds = List.of(Item.newBuilder().setId(10).build()); List<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveLatest(byInternalIds);- Parameters:
items- The time series to retrieve data point(s) from.- Returns:
- The latest data point(s)
- Throws:
Exception- See Also:
CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveFirst
public List<TimeseriesPoint> retrieveFirst(String... externalId) throws Exception
Retrieve the first (eldest) data point for a time series. Refer toretrieveFirst(List)for more information.Example:
API Reference - Retrieve data pointsList<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveFirst("10", "20");- Parameters:
externalId- TheexternalIdsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveFirst(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveFirst
public List<TimeseriesPoint> retrieveFirst(long... id) throws Exception
Retrieve the first (eldest) data point for a time series. Refer toretrieveFirst(List)for more information.Example:
API Reference - Retrieve data pointsList<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveFirst(10, 20);- Parameters:
id- Theidsof the time series to retrieve- Returns:
- The time series data points.
- Throws:
Exception- See Also:
retrieveFirst(List),CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
retrieveFirst
public List<TimeseriesPoint> retrieveFirst(@NotNull List<Item> items) throws Exception
Retrieve the first (eldest) data point for a time series. TheItemmust specify the externalId / id of the time series.Example:
API Reference - Retrieve data pointsList<Item> byInternalIds = List.of(Item.newBuilder().setId(10).build()); List<TimeseriesPoint> result = client.timeseries().dataPoints() .retrieveFirst(byInternalIds);- Parameters:
items- The time series to retrieve data point(s) from.- Returns:
- The first data point(s)
- Throws:
Exception- See Also:
CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints()
-
delete
public List<Item> delete(List<Item> dataPoints) throws Exception
Deletes a set of dataPoints. The dataPoints to delete are identified via theirexternalId / idby submitting a list ofItem.Example:
API Reference - Delete datapointsList<Item> deleteItemsInput = List.of(Item.newBuilder().setExternalId("1").build()); List<Item> deleteItemsResults = client.timeseries().dataPoints().delete(deleteItemsInput);- Parameters:
dataPoints-- Returns:
- Throws:
Exception- See Also:
CogniteClient,CogniteClient.timeseries(),Timeseries.dataPoints(),ApiBase.DeleteItems.deleteItems(List)
-
getMaxFrequency
public double getMaxFrequency(Request requestParameters, Instant startOfWindow, Instant endOfWindow) throws Exception
Calculate the max frequency of the TS items in the query. Only numeric data points are considered. In case of string data points, this method returns 0 (i.e. no splitting per time window for string time series). This method is intended for advanced use cases with distributed computing frameworks that implement their own split and parallelization algorithms.Example:
double maxFrequency = getMaxFrequency(requestParameters, Instant.ofEpochMilli(startTimestamp), Instant.ofEpochMilli(endTimestamp));- Parameters:
requestParameters-startOfWindow-endOfWindow-- Returns:
- Throws:
Exception
-
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.Example:
List<String> partitions = buildPartitionsList(getClient().getClientConfig().getNoListPartitions());- 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.Example:
Iterator<List<String>> result = listJson(resourceType, requestParameters, partitions);- 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- See Also:
listJson(ResourceType,Request,String,String...)
-
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.Example:
Iterator<List<String>> result = listJson(resourceType, requestParameters, partitionKey, partitions);- 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<Item> items) throws Exception
Retrieve items by id. Will ignore unknown ids by default.Example:
Collection<Item> items = //Collection of items with ids; List<String> result = retrieveJson(resourceType, items);- 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- See Also:
retrieveJson(ResourceType,Collection,Map)
-
retrieveJson
protected List<String> retrieveJson(ResourceType resourceType, Collection<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>.Example:
Collection<Item> items = //Collection of items with ids; Map<String, Object> parameters = //Parameters; List<String> result = retrieveJson(resourceType, items, parameters);
-
aggregate
protected 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.Example:
Aggregate aggregateResult = aggregate(resourceType,requestParameters);- 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.Example:
Request requestParams = addAuthInfo(request);- 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<Item> parseItems(List<String> input) throws Exception
Parses a list of item object in json representation to typed objects.Example:
List<String> input = //List of json; List<Item> resultList = parseItems(input);- Parameters:
input- the item list in Json string representation- Returns:
- the parsed item objects
- Throws:
Exception
-
toRequestItems
protected List<Map<String,Object>> toRequestItems(Collection<Item> itemList)
Converts a list ofItemto a request object structure (that can later be parsed to Json).Example:
Collection<Item> itemList = //Collection of items; List<Map<String, Object>> result = toRequestItems(itemList);- Parameters:
itemList- The items to parse.- Returns:
- The items in request item object form.
-
deDuplicate
protected List<Item> deDuplicate(Collection<Item> itemList)
De-duplicates a collection ofItem.Example:
Collection<Item> itemList = //Collection of items; List<Item> result = deDuplicate(itemList);- Parameters:
itemList-- Returns:
-
itemsHaveId
protected boolean itemsHaveId(Collection<Item> items)
Returns true if all items contain either an externalId or id.Example:
Collection<Item> items = //Collection of items; boolean result = itemsHaveId(items);- Parameters:
items-- Returns:
-
mapItemToId
protected Map<String,Item> mapItemToId(Collection<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.Example:
Collection<Item> items = //Collection of items; Map<String, Item> result = mapItemToId(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.Example:
String json = //String of json object String result = parseString(json, "name");- Parameters:
itemJson- The Json stringfieldName- The Json path to parse- Returns:
- The Json path as a
String.
-
-