This is an automated email from the ASF dual-hosted git repository.
johnbodley pushed a commit to branch john-bodley-remove-obsolete-db_engines
in repository https://gitbox.apache.org/repos/asf/superset.git
The following commit(s) were added to
refs/heads/john-bodley-remove-obsolete-db_engines by this push:
new bdbb2b788b Delete hive.py
bdbb2b788b is described below
commit bdbb2b788b45e113c993ea73f1b3d6fd9dfa4ceb
Author: John Bodley <[email protected]>
AuthorDate: Wed Jul 6 14:38:41 2022 -0700
Delete hive.py
---
superset/db_engines/hive.py | 67 ---------------------------------------------
1 file changed, 67 deletions(-)
diff --git a/superset/db_engines/hive.py b/superset/db_engines/hive.py
deleted file mode 100644
index 0c4094fe3e..0000000000
--- a/superset/db_engines/hive.py
+++ /dev/null
@@ -1,67 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-from typing import Optional, TYPE_CHECKING
-
-if TYPE_CHECKING:
- from pyhive.hive import Cursor
- from TCLIService.ttypes import TFetchOrientation
-
-# TODO: contribute back to pyhive.
-def fetch_logs( # pylint: disable=protected-access
- self: "Cursor",
- _max_rows: int = 1024,
- orientation: Optional["TFetchOrientation"] = None,
-) -> str:
- """Mocked. Retrieve the logs produced by the execution of the query.
- Can be called multiple times to fetch the logs produced after
- the previous call.
- :returns: list<str>
- :raises: ``ProgrammingError`` when no query has been started
- .. note::
- This is not a part of DB-API.
- """
- # pylint: disable=import-outside-toplevel
- from pyhive import hive
- from TCLIService import ttypes
- from thrift import Thrift
-
- orientation = orientation or ttypes.TFetchOrientation.FETCH_NEXT
- try:
- req = ttypes.TGetLogReq(operationHandle=self._operationHandle)
- logs = self._connection.client.GetLog(req).log
- return logs
- # raised if Hive is used
- except (ttypes.TApplicationException, Thrift.TApplicationException) as ex:
- if self._state == self._STATE_NONE:
- raise hive.ProgrammingError("No query yet") from ex
- logs = []
- while True:
- req = ttypes.TFetchResultsReq(
- operationHandle=self._operationHandle,
- orientation=ttypes.TFetchOrientation.FETCH_NEXT,
- maxRows=self.arraysize,
- fetchType=1, # 0: results, 1: logs
- )
- response = self._connection.client.FetchResults(req)
- hive._check_status(response)
- assert not response.results.rows, "expected data in columnar
format"
- assert len(response.results.columns) == 1, response.results.columns
- new_logs = hive._unwrap_column(response.results.columns[0])
- logs += new_logs
- if not new_logs:
- break
- return "\n".join(logs)
