File tree Expand file tree Collapse file tree 1 file changed +0
-10
lines changed
src/databricks/sql/backend/sea Expand file tree Collapse file tree 1 file changed +0
-10
lines changed Original file line number Diff line number Diff line change @@ -283,18 +283,8 @@ def __init__(
283283 # Initialize table and position
284284 self .table = self ._create_next_table ()
285285
286- def _get_chunk_link (self , chunk_index : int ) -> Optional ["ExternalLink" ]:
287- if chunk_index not in self ._chunk_index_to_link :
288- links = self ._sea_client .get_chunk_links (self ._statement_id , chunk_index )
289- self ._chunk_index_to_link .update ({link .chunk_index : link for link in links })
290- return self ._chunk_index_to_link .get (chunk_index , None )
291-
292286 def _create_next_table (self ) -> Union ["pyarrow.Table" , None ]:
293287 """Create next table by retrieving the logical next downloaded file."""
294- if not self ._current_chunk_link :
295- logger .debug ("SeaCloudFetchQueue: No current chunk link, returning" )
296- return None
297-
298288 if not self .download_manager :
299289 logger .debug ("SeaCloudFetchQueue: No download manager, returning" )
300290 return None
You can’t perform that action at this time.
0 commit comments