Stream Processing Service API Overview


EnOS™ Stream Processing Service provides query and management of stream processing jobs for application developers. For more information about the EnOS Stream Processing service, see Stream Processing.


For detailed information about EnOS™ APIs, see About EnOS API.


To get started with calling an EnOS API quickly, see Get Started with EnOS API.


Refer to the table below for the list of APIs, and whether they can be used by EnOS™ Cloud and EnOS™ Edge.

API List

API Name Description EnOS Cloud EnOS Edge
Get Stage State Get the intermediate state data of a specified operator in a stream processing pipeline. ×
Delete Stage State Delete the intermediate state data of a specified operator in a stream processing pipeline. ×
List Pipelines Get the list of stream processing pipelines in the organization by pages. ×
Get Pipeline Details Get the details of a specific stream processing pipeline. ×
Operate Pipeline Save, release, start, pause, and stop a stream processing pipeline. ×
Get Pipeline Offset and Lag Get the Kafka Offset and Lag of a specific stream processing pipeline. ×
Reset Pipeline Offset Reset the Kafka Offset of a specific stream processing pipeline. ×