File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -429,6 +429,10 @@ impl<D: AsyncDB> Runner<D> {
429429 self . validator = validator;
430430 }
431431
432+ pub fn with_hash_threshold ( & mut self , hash_threshold : usize ) {
433+ self . hash_threshold = hash_threshold;
434+ }
435+
432436 pub async fn apply_record ( & mut self , record : Record ) -> RecordOutput {
433437 match record {
434438 Record :: Statement { conditions, .. } if self . should_skip ( & conditions) => {
@@ -504,7 +508,7 @@ impl<D: AsyncDB> Runner<D> {
504508 Some ( SortMode :: ValueSort ) => todo ! ( "value sort" ) ,
505509 } ;
506510
507- if self . hash_threshold > 0 && rows. len ( ) > self . hash_threshold {
511+ if self . hash_threshold > 0 && rows. len ( ) * types . len ( ) > self . hash_threshold {
508512 let mut md5 = md5:: Context :: new ( ) ;
509513 for line in & rows {
510514 for value in line {
You can’t perform that action at this time.
0 commit comments