Commit 4d0e3123 authored by COQUERY EMMANUEL's avatar COQUERY EMMANUEL
Browse files

typos

parent 621106b5
......@@ -120,7 +120,7 @@ exécuter le script python `stormmon.py`:
./monitor/stormmon.py
```
Si vous avez lancéPour visualiser le trafic dans votre topologie, vous avez l'interface
Pour visualiser le trafic dans votre topologie, vous avez l'interface
*ui* comme représenté sur les copies d'écran (seulement si vous utilisez les serveurs storm).
![Storm UI: Accueil](./images/stormui.png "stormui")
......@@ -140,7 +140,7 @@ deux boutons importants dans cette interface, sont les boutons:
Pour tuer une topologie:
- si vous avez lancer la topologie via `storm` ou `sparse submit`, vous pouvez utiliser le bouton kill dans l'interface
- si vous avez lancé la topologie via `storm` ou `sparse submit`, vous pouvez utiliser le bouton kill dans l'interface
- si vous avez lancé la topologie via `sparse run`, il suffit de l'arrêter dans la console (`^C`).
......
This diff is collapsed.
......@@ -32,11 +32,11 @@ class ExampleStatelessWindowedBolt(TicklessBatchingBolt):
Ce type de bolt accumule les tuples et déclenche un calcul à intervalles réguliers (15 secondes)).
Dans cet exemple, le bolt calcul le nombre de messages de la fenêtre.
Dans cet exemple, le bolt calcule le nombre de messages de la fenêtre.
"""
outputs = ["count"]
secs_between_batches = 15 # Taille de la fenêtre en secondes
secs_between_batches = 15 # Taille de la fenêtre en secondes
def initialize(self, strom_conf, context):
"""Initialise le bolt.
......@@ -53,6 +53,7 @@ class ExampleStatelessWindowedBolt(TicklessBatchingBolt):
result = len(tuples)
self.emit([result])
class ExampleStatefulBolt(Bolt):
"""Bolt conservant un état.
......@@ -61,7 +62,7 @@ class ExampleStatefulBolt(Bolt):
Dans cet exemple, le bolt calcule les valeurs maximales et minimales du premier composant des tuples reçus.
"""
outputs = ["min","max"]
outputs = ["min", "max"]
def initialize(self, strom_conf, context):
"""Initialise le bolt.
......@@ -71,7 +72,6 @@ class ExampleStatefulBolt(Bolt):
self.mini = None
self.maxi = None
def process(self, tup):
"""Traite un tuple."""
tupval = tup.value[0]
......@@ -81,6 +81,7 @@ class ExampleStatefulBolt(Bolt):
self.maxi = tupval
self.emit([self.mini, self.maxi])
class ExampleStatefulWindowedBolt(TicklessBatchingBolt):
"""Bolt utilisant une fenêtre.
......@@ -91,7 +92,7 @@ class ExampleStatefulWindowedBolt(TicklessBatchingBolt):
"""
outputs = ["maxcount"]
secs_between_batches = 15 # Taille de la fenêtre en secondes
secs_between_batches = 15 # Taille de la fenêtre en secondes
def initialize(self, strom_conf, context):
"""Initialise le bolt.
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment