Ich versuche Latenz von jeder Schraube in einer Topologie zu messen. Die Latenzzahlen von Storm reichen nicht aus, da wir Perzentile berechnen wollen. In meinem aktuellen Setup misst ich die Latenz der Schraube, indem ich die Zeit misst, die benötigt wird, um die Ausführungsmethode einschließlich des Aufrufs zum Senden abzuschließen. Die Annahme mit der obigen Methode ist, dass die Emulation des Kollektors sofort zurückkehrt, ohne dass die nächste Methode der Bolt-Instanzen aufgerufen wird, selbst wenn derselbe Executor zwischen der aktuellen Bolt-Instanz und der nächsten Bolt-Instanz in der Topologie geteilt wird.Meauring Latency von Storm Schrauben
0
A
Antwort
0
Indem Sie den Timer an den Anfang und das Ende Ihrer Execute-Methode (nach dem Emittieren) setzen, sollten Sie in Ordnung sein.
Verwandte Themen
- 1. Storm latency verursacht durch ack
- 2. Wie viele Schrauben kann Apache Storm handhaben?
- 3. Apache Storm, n Schrauben speichern Daten n Pipelines
- 4. Apache Storm: Veränderliches Objekt, das an verschiedene Schrauben ausgegeben wird
- 5. Confusing Storm-UI
- 6. Schrauben/Auslauf an einen bestimmten Supervisor senden
- 7. Sollte die gesamte Latenz einer Storm Topology der Summe der Schrauben gleich (oder nahe) sein?
- 8. Apache Storm Flux ändern Topologie
- 9. SIMD Latency Durchsatz
- 10. -Code Schrauben, wenn Ansichtsfenster
- 11. Low Latency DASH Nginx RTMP
- 12. Android BLE ScanCallback LOW LATENCY
- 13. Low Latency Desktopstreaming mit ffmpeg (p2p)
- 14. Wie schreibt man C++ - Storm und Thrift in Storm
- 15. Lamina vs Storm
- 16. Google GMS Aufgabe vs Schrauben Android Aufgabe
- 17. Hazelcast in der Nähe von Cache - große Get Latency
- 18. Running Storm UI
- 19. Wie man die Tupelverarbeitung in Storm stoppt und anderen Code ausführt
- 20. Storm Nachricht fehlgeschlagen
- 21. Blackberry storm touchEvents
- 22. Storm und Redis
- 23. Fehler mit zoekeeper & storm
- 24. Mehrdeutige Verwendung von 'weiter' Schrauben-Swift in Swift 3
- 25. Android: Wie synchronisiert man Abfragen mit Schrauben von Parse.com?
- 26. Apache Storm java.nio.channels.ClosedChannelException: null
- 27. Javascript Speichern Regexp Schrauben das Originalformat
- 28. Lesen von früher Offset Apache Storm
- 29. OpenCV - Apache Storm Auftreten von "UnzufriedenerLinkError"
- 30. Apache Storm Calling-Funktion von Python-Schraube
Bedeutet das, emit Methode ist asynchron? – user3612009
Nicht unbedingt. Emit fügt das Tupel wahrscheinlich zu einer internen Warteschlange hinzu, und die nächste Schraube liest aus der Warteschlange, wann immer es bereit ist, das nächste Tupel zu verarbeiten. Also unabhängig davon, was Sie bei der nächsten Schraube tun, emittieren immer die gleiche Zeit und es ist sehr billig Anweisung. Wenn Sie messen möchten, wie lange die Emission dauert, implementieren Sie einfach eine Schraube, die nur emittiert und misst. Sie können dann diese Zahl von der Schraube abziehen, die Sie tatsächlich messen. –
'wahrscheinlich fügt das Tupel hinzu' - Ja, ich nehme auch an, dass dies passiert, aber nur Bestätigung wollen. – user3612009