(self, txn_id)
| 228 | return open_txn_resp.txn_ids[0] |
| 229 | |
| 230 | def _commit_txn(self, txn_id): |
| 231 | commit_req = CommitTxnRequest() |
| 232 | commit_req.txnid = txn_id |
| 233 | return self.hive_client.commit_txn(commit_req) |
| 234 | |
| 235 | def _create_insert_only_acid_table(self, tbl, cols, part_cols=None): |
| 236 | part_part = ("partitioned by (%s)" % part_cols) if part_cols else "" |
no test coverage detected