(self, path, ceph_read=True, fs_read=False, mode="r")
| 53 | yield cur_line |
| 54 | |
| 55 | def load_data(self, path, ceph_read=True, fs_read=False, mode="r"): |
| 56 | if "s3://" not in path: |
| 57 | if not fs_read: |
| 58 | return open(path, mode) |
| 59 | else: |
| 60 | return open(path, mode).read() |
| 61 | else: |
| 62 | self.check_init() |
| 63 | |
| 64 | if ceph_read: |
| 65 | return self._iter_cpeh_lines(path) |
| 66 | else: |
| 67 | return self.client.get(path) |
| 68 | |
| 69 | @staticmethod |
| 70 | def load_pk(path, mode="r"): |
no test coverage detected