()
| 65 | chunks = None |
| 66 | |
| 67 | def is_loaded(): |
| 68 | with cluster.impala.cursor() as cursor: |
| 69 | try: |
| 70 | # If the part table exists, assume everything is already loaded. |
| 71 | cursor.execute("DESCRIBE %s.part" % target_db) |
| 72 | return True |
| 73 | except Exception as e: |
| 74 | if "AnalysisException" not in str(e): |
| 75 | raise |
| 76 | return False |
| 77 | |
| 78 | |
| 79 | def load(): |
no test coverage detected