File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/query/storages/system/src Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -167,8 +167,8 @@ impl TempFilesTable {
167167 let ctx = ctx. clone ( ) ;
168168 let builder = ListerStreamSourceBuilder :: with_lister_fut ( lister) ;
169169 builder
170- . with_limit_opt ( limit)
171- . with_chunk_size ( MAX_BATCH_SIZE )
170+ . limit_opt ( limit)
171+ . chunk_size ( MAX_BATCH_SIZE )
172172 . build ( move |entries| {
173173 counter += entries. len ( ) ;
174174 let block = Self :: block_from_entries ( & prefix, entries) ?;
@@ -255,17 +255,17 @@ where T: Future<Output = opendal::Result<Lister>> + Send + 'static
255255 }
256256 }
257257
258- pub fn with_limit ( mut self , limit : usize ) -> Self {
258+ pub fn limit ( mut self , limit : usize ) -> Self {
259259 self . limit = Some ( limit) ;
260260 self
261261 }
262262
263- pub fn with_limit_opt ( mut self , limit : Option < usize > ) -> Self {
263+ pub fn limit_opt ( mut self , limit : Option < usize > ) -> Self {
264264 self . limit = limit;
265265 self
266266 }
267267
268- pub fn with_chunk_size ( mut self , chunk_size : usize ) -> Self {
268+ pub fn chunk_size ( mut self , chunk_size : usize ) -> Self {
269269 self . chunk_size = chunk_size;
270270 self
271271 }
You can’t perform that action at this time.
0 commit comments