@@ -36,11 +36,11 @@ Simple Python Example
36
36
The first step to putting together a topology, is creating the bolts and spouts,
37
37
so let's assume we have the following bolt and spout:
38
38
39
- .. literalinclude :: ../../ examples/redis/src/bolts.py
39
+ .. literalinclude :: ../examples/redis/src/bolts.py
40
40
:language: python
41
41
:lines: 1-28
42
42
43
- .. literalinclude :: ../../ examples/redis/src/spouts.py
43
+ .. literalinclude :: ../examples/redis/src/spouts.py
44
44
:language: python
45
45
46
46
One important thing to note is that we have added an ``outputs `` attribute to
@@ -51,7 +51,7 @@ objects.
51
51
52
52
Now let's hook up the bolt to read from the spout:
53
53
54
- .. literalinclude :: ../../ examples/redis/topologies/wordcount_mem.py
54
+ .. literalinclude :: ../examples/redis/topologies/wordcount_mem.py
55
55
:language: python
56
56
57
57
.. note ::
@@ -72,7 +72,7 @@ The topology DSL fully supports JVM-based bolts and spouts via the
72
72
Here's an example of how we would use the
73
73
`Storm Kafka Spout <http://storm.apache.org/releases/current/storm-kafka.html >`_:
74
74
75
- .. literalinclude :: ../../ examples/kafka-jvm/topologies/pixelcount.py
75
+ .. literalinclude :: ../examples/kafka-jvm/topologies/pixelcount.py
76
76
:language: python
77
77
78
78
One limitation of the Thrift interface we use to send the topology to Storm is
@@ -127,7 +127,7 @@ attribute. The most common grouping is probably the
127
127
with the same value for the specified fields to the same executor. This can be
128
128
seen in the prototypical word count topology:
129
129
130
- .. literalinclude :: ../../ examples/redis/topologies/wordcount_mem.py
130
+ .. literalinclude :: ../examples/redis/topologies/wordcount_mem.py
131
131
:language: python
132
132
133
133
0 commit comments