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

Commit 061f4a2

Browse files
committed
disable calcite
1 parent 3bbd9c1 commit 061f4a2

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

@@ -2105,7 +2106,7 @@ def __init__(self, **kwargs):
21052106
self._schema_mgr = SchemaMgr()
21062107
self._schema_mgr.registerProvider(self._storage)
21072108
self._schema_mgr.registerProvider(rs_registry)
2108-
self._calcite = Calcite(self._schema_mgr, self._config)
2109+
# self._calcite = Calcite(self._schema_mgr, self._config)
21092110
self._executor = Executor(self._data_mgr, self._config)
21102111
self._builder = QueryBuilder(self._schema_mgr, self._config, self)
21112112

@@ -2899,6 +2900,9 @@ def if_then_else(self, cond, true_val, false_val):
28992900
"""
29002901
return self._builder.if_then_else(cond, true_val, false_val)
29012902

2903+
def clear_cache(self):
2904+
self._executor.clearMemory(self._data_mgr, 1)
2905+
29022906

29032907
def init(**kwargs):
29042908
if init._instance is None:

0 commit comments

Comments
 (0)