Please enable JavaScript.

Coggle requires JavaScript to display documents.

Streaming - Distributed Stream Computing Engine - Coggle Diagram

- - - - methods can be used for troubleshooting if you fail to use the Shell command of the Streaming client to view or submit a topology
        
        View the abnormal stack on the client to check whether the client is faulty.
        
        View the run logs of the active Nimbus to check whether the Nimbus server is abnormal.
    - - Excutor
        in a Worker Process runs one or more Excutor threads.
        each excutor can run one or more task instances of either Spout or Bolt
        
        task > unit that processes data
        each excutor have one or moretasks to excute
- - - - Real-time response with low delay
      - Data Computing before sharing
      - Continuous query
      - Event Driven
- - - - if not every message is required to be processed (allowing some message loss) > reliability mechanism can be disabled to ensure better performance
      - ways to disable reliability mechanism
        
        Setting config
        
        Using Spout to send messages through interfaces that restrict messge IDs
        
        Using Bolt to send messages in Unanchor mode
    - - None (Relibility Level > At Most once)
      - Ack (Relibility Level > At least once)
      - Trident (Relibility Level > Exactly once)