OCSP is a high performance stream processing system which is based on Spark. It supports multiple types of data input, such as Socket, files, Kafka etc. Besides, it can output the result as different types. Currently, OCSP supports output type of Kafka, Redis, HDFS etc. User does not need to know the detail of RDDs. Instead, a api function needs to be overwrittern to implement the logic.
User can use OCSP to build his streaming platform easily and quickly.
| Feature | Detailed feature |
|---|---|
| Event processing | Data reading |
| Data pre-processing | |
| Label enhancement | |
| Cache | |
| Event subscription | |
| Event output | |
| Configuration | Input configuration |
| Pre-processing configuration | |
| label configuration | |
| Processing configuration | |
| Subscription configuration | |
| System configuration | |
| Monitor | Metrics view |
| Status view | |
| Service Start/Stop |
-
Framework Details
OCSP consists of four components: Data input, Core processing, Configuration, Basic components as below:
-
UI
-
Stream status view
-
Stream configuration view
-
Stream creation view
-
