@@ -83,48 +83,6 @@ def emit(self, tup, tup_id=None, stream=None, direct_task=None,
83
83
direct_task = direct_task ,
84
84
need_task_ids = need_task_ids )
85
85
86
- def emit_many (self , tuples , stream = None , tup_ids = None , direct_task = None ,
87
- need_task_ids = True ):
88
- """Emit multiple tuples.
89
-
90
- :param tuples: a ``list`` of multiple Tuple payloads to send to
91
- Storm. All Tuples should contain only
92
- JSON-serializable data.
93
- :type tuples: list
94
- :param stream: the ID of the stream to emit these Tuples to. Specify
95
- ``None`` to emit to default stream.
96
- :type stream: str
97
- :param tup_ids: the ID for the Tuple. Leave this blank for an
98
- unreliable emit.
99
- :type tup_ids: list
100
- :param tup_ids: IDs for each of the Tuples in the list. Omit these for
101
- an unreliable emit.
102
- :type anchors: list
103
- :param direct_task: indicates the task to send the Tuple to.
104
- :type direct_task: int
105
- :param need_task_ids: indicate whether or not you'd like the task IDs
106
- the Tuple was emitted (default:
107
- ``True``).
108
- :type need_task_ids: bool
109
-
110
- .. deprecated:: 2.0.0
111
- Just call :py:meth:`Spout.emit` repeatedly instead.
112
- """
113
- if not isinstance (tuples , (list , tuple )):
114
- raise TypeError ('Tuples should be a list of lists/tuples, '
115
- 'received {!r} instead.' .format (type (tuples )))
116
-
117
- all_task_ids = []
118
- if tup_ids is None :
119
- tup_ids = itertools .repeat (None )
120
-
121
- for tup , tup_id in zip (tuples , tup_ids ):
122
- all_task_ids .append (self .emit (tup , stream = stream , tup_id = tup_id ,
123
- direct_task = direct_task ,
124
- need_task_ids = need_task_ids ))
125
-
126
- return all_task_ids
127
-
128
86
def _run (self ):
129
87
"""The inside of ``run``'s infinite loop.
130
88
0 commit comments