|
101 | 101 | # pytype: skip-file |
102 | 102 |
|
103 | 103 | import typing |
| 104 | +import collections |
104 | 105 |
|
105 | 106 | import numpy as np |
106 | 107 |
|
|
122 | 123 | ('allow_duplicates', typing.Optional[bool]), |
123 | 124 | ('dynamic_read_poll_interval_seconds', typing.Optional[int]), |
124 | 125 | ('consumer_factory_fn_class', typing.Optional[str]), |
125 | | - ('consumer_factory_fn_params', typing.Optional[typing.Mapping[str, str]])]) |
| 126 | + ('consumer_factory_fn_params', typing.Optional[collections.abc.Mapping[str, str]])]) |
126 | 127 |
|
127 | 128 |
|
128 | 129 | def default_io_expansion_service(append_args=None): |
@@ -170,8 +171,8 @@ def __init__( |
170 | 171 | redistribute_num_keys=np.int32(0), |
171 | 172 | allow_duplicates=False, |
172 | 173 | dynamic_read_poll_interval_seconds: typing.Optional[int] = None, |
173 | | - consumer_factory_fn_class=None, |
174 | | - consumer_factory_fn_params=None): |
| 174 | + consumer_factory_fn_class: typing.Optional[collections.abc.Mapping] = None, |
| 175 | + consumer_factory_fn_params: typing.Optional[collections.abc.Mapping] = None): |
175 | 176 | """ |
176 | 177 | Initializes a read operation from Kafka. |
177 | 178 |
|
@@ -218,7 +219,7 @@ def __init__( |
218 | 219 | existing provided consumerFactoryFn. If not None, this will construct |
219 | 220 | Kafka consumers with a custom configuration. |
220 | 221 | :param consumer_factory_fn_params: A map which specifies the parameters for |
221 | | - the provided consumer_factory_fn_class. IF not None, the values in this |
| 222 | + the provided consumer_factory_fn_class. If not None, the values in this |
222 | 223 | map will be used when constructing the consumer_factory_fn_class object. |
223 | 224 | This cannot be null if the consumer_factory_fn_class is not null. |
224 | 225 | """ |
|
0 commit comments