Add operations to `writer_net` that write the next batch of data. Operations added to the net must be thread-safe and unique, that is: multiple writers must be able to write to the dataset in parallel. Args: fields: a tuple of BlobReference containing the batch
(self, writer_net, fields)
| 159 | return self._schema |
| 160 | |
| 161 | def write(self, writer_net, fields): |
| 162 | """Add operations to `writer_net` that write the next batch of data. |
| 163 | |
| 164 | Operations added to the net must be thread-safe and unique, that is: |
| 165 | multiple writers must be able to write to the dataset in parallel. |
| 166 | |
| 167 | Args: |
| 168 | fields: a tuple of BlobReference containing the batch of data to |
| 169 | write. |
| 170 | """ |
| 171 | raise NotImplementedError('Writers must implement write.') |
| 172 | |
| 173 | def write_record(self, writer_net, fields): |
| 174 | if isinstance(fields, Field): |
no outgoing calls