(self, json_line)
| 75 | Encoder.splitter = IdentitySplitter() |
| 76 | |
| 77 | def split(self, json_line): |
| 78 | data = json.loads(json_line) |
| 79 | output = {} |
| 80 | for key in self.args.json_keys: |
| 81 | text = data[key] |
| 82 | max_len = 1000000 |
| 83 | tokens_list = [Encoder.splitter.tokenize(text[i:i+max_len]) for i in range(0, len(text), max_len)] |
| 84 | output[key] = [tokens for partial in tokens_list for tokens in partial] |
| 85 | return json.dumps(output), len(json_line) |
| 86 | |
| 87 | def encode(self, json_line): |
| 88 | data = json.loads(json_line) |