(self, read_net)
| 99 | raise NotImplementedError('This reader cannot be resetted.') |
| 100 | |
| 101 | def read_record(self, read_net): |
| 102 | should_stop, fields = self.read(read_net) |
| 103 | if self._schema: |
| 104 | fields = from_blob_list(self._schema, fields) |
| 105 | return should_stop, fields |
| 106 | |
| 107 | def execution_step(self, reader_net_name=None, external_should_stop=None): |
| 108 | """Create an execution step with a net containing read operators. |