FusionInsight Stream is an enterprise-class, real-time data processing system. It processes massive, diverse, and complex data sets on a real-time basis to fulfill service requirements, such as real-time decision-making, recommendations, and presentations. It enables enterprises to uncover large hidden values from massive volumes of data, spot risks and opportunities, enhancing decision-making and process optimization.
The use of continuous query language (CQL) accelerates service development, enables tasks to be easily submitted to the Streaming platform for real-time processing, facilitates output of results, and allows tasks to be terminated at the appropriate time. Additionally, access control is implemented based on user types. As a result, only the user who creates the topology can view and manage the topology, preventing unauthorized operations. The Nimbus HA mechanism enhances cluster availability.
The use of continuous query language (CQL) accelerates service development, enables tasks to be easily submitted to the Streaming platform for real-time processing, facilitates output of results, and allows tasks to be terminated at the appropriate time. Additionally, access control is implemented based on user types. As a result, only the user who creates the topology can view and manage the topology, preventing unauthorized operations. The Nimbus HA mechanism enhances cluster availability.
A Streaming topology can be developed and compressed into a JAR file by using Storm APIs or referring to the CQL syntax manual. After the topology is submitted to the Streaming cluster, Nimbus automatically assigns it to the Supervisor node for processing. The topology logs can be viewed on the UI through the port provided by Logviewer.
If you have more questions, you can seek help from following ways:
