Class ConnectorServiceV1

    • Field Detail

      • LOG

        protected final org.slf4j.Logger LOG
    • Constructor Detail

      • ConnectorServiceV1

        public ConnectorServiceV1()
    • Method Detail

      • readAssetsAggregates

        public ItemReader<String> readAssetsAggregates()
        Read assets aggregates from Cognite.
        Returns:
      • readAssetsById

        public ItemReader<String> readAssetsById()
        Read assets by id from Cognite.
        Returns:
      • writeAssets

        public ConnectorServiceV1.ItemWriter writeAssets()
        Write Assets to Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateAssets

        public ConnectorServiceV1.ItemWriter updateAssets()
        Update Assets in Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteAssets

        public ConnectorServiceV1.ItemWriter deleteAssets()
        Delete Assets in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readEventsAggregates

        public ItemReader<String> readEventsAggregates()
        Read events aggregates from Cognite.
        Returns:
      • readEventsById

        public ItemReader<String> readEventsById()
        Read events by id from Cognite.
        Returns:
      • writeEvents

        public ConnectorServiceV1.ItemWriter writeEvents()
        Write Events to Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateEvents

        public ConnectorServiceV1.ItemWriter updateEvents()
        Update Events in Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteEvents

        public ConnectorServiceV1.ItemWriter deleteEvents()
        Delete Events in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readSequencesAggregates

        public ItemReader<String> readSequencesAggregates()
        Read sequences aggregates from Cognite.
        Returns:
      • readSequencesById

        public ItemReader<String> readSequencesById()
        Read sequences by id from Cognite.
        Returns:
      • writeSequencesHeaders

        public ConnectorServiceV1.ItemWriter writeSequencesHeaders()
        Write sequences headers to Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateSequencesHeaders

        public ConnectorServiceV1.ItemWriter updateSequencesHeaders()
        Update sequences headers in Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteSequencesHeaders

        public ConnectorServiceV1.ItemWriter deleteSequencesHeaders()
        Delete sequences headers in Cognite. Calling this method will return an ItemWriter
        Returns:
      • writeSequencesRows

        public ConnectorServiceV1.ItemWriter writeSequencesRows()
        Write sequences rows to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteSequencesRows

        public ConnectorServiceV1.ItemWriter deleteSequencesRows()
        Delete sequences rows in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readTsAggregates

        public ItemReader<String> readTsAggregates()
        Read timeseries aggregates from Cognite.
        Returns:
      • readTsById

        public ItemReader<String> readTsById()
        Read time series headers by id from Cognite.
        Returns:
      • writeTsHeaders

        public ConnectorServiceV1.ItemWriter writeTsHeaders()
        Write time series headers to Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateTsHeaders

        public ConnectorServiceV1.ItemWriter updateTsHeaders()
        Update time series headers in Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteTsHeaders

        public ConnectorServiceV1.ItemWriter deleteTsHeaders()
        Delete TS headers in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readTsDatapointsProto

        public ConnectorServiceV1.ResultFutureIterator<com.cognite.v1.timeseries.proto.DataPointListItem> readTsDatapointsProto​(Request queryParameters)
        Fetch timeseries datapoints from Cognite using protobuf encoding.
        Parameters:
        queryParameters - The parameters for the events query.
        Returns:
      • readTsDatapointsLatest

        public ItemReader<String> readTsDatapointsLatest()
        Read latest data point from Cognite.
        Returns:
      • writeTsDatapoints

        public ConnectorServiceV1.ItemWriter writeTsDatapoints()
        Write time series headers to Cognite. Calling this method will return an ItemWriter
        Returns:
      • writeTsDatapointsProto

        public ConnectorServiceV1.ItemWriter writeTsDatapointsProto()
        Write time series data points to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteDatapoints

        public ConnectorServiceV1.ItemWriter deleteDatapoints()
        Delete data points in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readRawRows

        public ConnectorServiceV1.ResultFutureIterator<String> readRawRows​(Request queryParameters)
        Fetch Raw rows from Cognite. This service can handle both single rows and large collection of rows.
        Parameters:
        queryParameters - The parameters for the raw query.
        Returns:
      • readRawRow

        public ItemReader<String> readRawRow()
        Fetch a single row by row key.
        Returns:
      • readCursorsRawRows

        public ItemReader<String> readCursorsRawRows()
        Read cursors for retrieving events in parallel. The results set is split into n partitions.
        Returns:
      • deleteRawRows

        public ConnectorServiceV1.ItemWriter deleteRawRows()
        Delete Assets in Cognite. Calling this method will return an ItemWriter
        Returns:
      • writeRawTableNames

        public ConnectorServiceV1.ItemWriter writeRawTableNames​(String dbName)
        Create Raw tables in a given database.
        Parameters:
        dbName - The name of the database to list tables from.
        Returns:
      • deleteRawTableNames

        public ConnectorServiceV1.ItemWriter deleteRawTableNames​(String dbName)
        Delete Raw tables from a given database.
        Parameters:
        dbName - The name of the database to list tables from.
        Returns:
      • readFilesAggregates

        public ItemReader<String> readFilesAggregates()
        Read files aggregates from Cognite.
        Returns:
      • readFilesById

        public ItemReader<String> readFilesById()
        Read files by id from Cognite.
        Returns:
      • readFileBinariesByIds

        public ConnectorServiceV1.FileBinaryReader readFileBinariesByIds()
        Read file binaries from Cognite. Returns an FileBinaryReader which can be used to read file binaries by id.
        Returns:
      • writeFileHeaders

        public ConnectorServiceV1.ItemWriter writeFileHeaders()
        Write files to Cognite. This is a two-step request with 1) post the file metadata / header and 2) post the file binary. This method returns an ItemWriter to which you can post the file metadata / header. I.e. it performs step 1), but not step 2). The response from the ItemWriter contains a URL reference for the file binary upload.
        Returns:
      • writeFileProto

        public ConnectorServiceV1.FileWriter writeFileProto()
        Write files to Cognite. This method returns an FileWriter to which you can post the FileContainer with file metadata / header. I.e. this writer allows you to post both the file header and the file binary in a single method call. The response contains the the metadata response item for the file.
        Returns:
      • updateFileHeaders

        public ConnectorServiceV1.ItemWriter updateFileHeaders()
        Update file headers to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteFiles

        public ConnectorServiceV1.ItemWriter deleteFiles()
        Delete Files (including headers) in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readLoginStatusByApiKey

        public com.cognite.client.dto.LoginStatus readLoginStatusByApiKey​(String host)
                                                                   throws Exception
        Get the login status from Cognite.
        Parameters:
        host -
        Returns:
        Throws:
        Exception
      • readRelationshipsById

        public ItemReader<String> readRelationshipsById()
        Read relationships by id from Cognite.
        Returns:
      • writeRelationships

        public ConnectorServiceV1.ItemWriter writeRelationships()
        Write relationships to Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateRelationships

        public ConnectorServiceV1.ItemWriter updateRelationships()
        Update relationships to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteRelationships

        public ConnectorServiceV1.ItemWriter deleteRelationships()
        Delete relationships in Cognite. Calling this method will return an ItemWriter
        Returns:
      • updateDataSets

        public ConnectorServiceV1.ItemWriter updateDataSets()
        Update data sets in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readDataSetsAggregates

        public ItemReader<String> readDataSetsAggregates()
        Read data sets aggregates from Cognite.
        Returns:
      • readDataSetsById

        public ItemReader<String> readDataSetsById()
        Read data sets by id from Cognite.
        Returns:
      • writeDataSets

        public ConnectorServiceV1.ItemWriter writeDataSets()
        Write data sets to Cognite. Calling this method will return an ItemWriter
        Returns:
      • writeLabels

        public ConnectorServiceV1.ItemWriter writeLabels()
        Write labels to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteLabels

        public ConnectorServiceV1.ItemWriter deleteLabels()
        Delete labels in Cognite. Calling this method will return an ItemWriter
        Returns:
      • readSecurityCategories

        public ConnectorServiceV1.ResultFutureIterator<String> readSecurityCategories​(Request queryParameters)
        Read security categories from Cognite.
        Parameters:
        queryParameters - The parameters for the security categories query.
        Returns:
      • writeSecurityCategories

        public ConnectorServiceV1.ItemWriter writeSecurityCategories()
        Write security categories to Cognite. Calling this method will return an ItemWriter
        Returns:
      • deleteSecurityCategories

        public ConnectorServiceV1.ItemWriter deleteSecurityCategories()
        Delete security categories in Cognite. Calling this method will return an ItemWriter
        Returns:
      • detectAnnotationsDiagrams

        public ItemReader<String> detectAnnotationsDiagrams()
        Detect references to assets and files in an engineering diagram and annotate the references with bounding boxes. Finds entities in the engineering diagram that match a list of entity names, for instance asset names. The P&ID must be a single-page PDF file.
        Returns:
      • convertDiagrams

        public ItemReader<String> convertDiagrams()
        Convert an engineering diagram in PDF format to an interactive SVG where the provided annotations are highlighted.
        Returns:
      • readEntityMatcherModels

        public ItemReader<String> readEntityMatcherModels()
        Create a reader for listing entity matcher models.
        Returns:
        An ItemReader for reading the models.
      • entityMatcherPredict

        public ItemReader<String> entityMatcherPredict()
        Create an entity matcher predict reader.
        Returns:
      • entityMatcherFit

        public Connector<String> entityMatcherFit()
        Create an entity matcher training executor.
        Returns: