Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit 65cca75

Browse files
committed
disable calcite
1 parent 037e885 commit 65cca75

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

python/pyhdk/hdk.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,9 @@
1010
ArrowStorage,
1111
DataMgr,
1212
SchemaMgr,
13+
# MemoryLevel,
1314
)
14-
from pyhdk._sql import Calcite, RelAlgExecutor, ExecutionResult
15+
from pyhdk._sql import RelAlgExecutor, ExecutionResult
1516
from pyhdk._execute import Executor, ResultSetRegistry
1617
from pyhdk._builder import QueryBuilder, QueryExpr, QueryNode
1718

@@ -2076,7 +2077,7 @@ def __init__(self, **kwargs):
20762077
self._schema_mgr = SchemaMgr()
20772078
self._schema_mgr.registerProvider(self._storage)
20782079
self._schema_mgr.registerProvider(rs_registry)
2079-
self._calcite = Calcite(self._schema_mgr, self._config)
2080+
# self._calcite = Calcite(self._schema_mgr, self._config)
20802081
self._executor = Executor(self._data_mgr, self._config)
20812082
self._builder = QueryBuilder(self._schema_mgr, self._config, self)
20822083

@@ -2870,6 +2871,9 @@ def if_then_else(self, cond, true_val, false_val):
28702871
"""
28712872
return self._builder.if_then_else(cond, true_val, false_val)
28722873

2874+
def clear_cache(self):
2875+
self._executor.clearMemory(self._data_mgr, 1)
2876+
28732877

28742878
def init(**kwargs):
28752879
if init._instance is None:

0 commit comments

Comments
 (0)