585 |
} |
} |
586 |
|
|
587 |
foreach my $out ( @outputs ) { |
foreach my $out ( @outputs ) { |
588 |
if ( $out->can('add') ) { |
$out->add( $mfn, $ds ) if $out->can('add'); |
|
$out->add( $mfn, $ds ); |
|
|
} |
|
589 |
} |
} |
590 |
|
|
591 |
} |
} |
618 |
|
|
619 |
eval { $indexer->finish } if ($indexer && $indexer->can('finish')); |
eval { $indexer->finish } if ($indexer && $indexer->can('finish')); |
620 |
|
|
621 |
|
foreach my $out ( @outputs ) { |
622 |
|
$out->finish if $out->can('finish'); |
623 |
|
} |
624 |
|
|
625 |
my $dt = time() - $start_t; |
my $dt = time() - $start_t; |
626 |
$log->info("$total_rows records ", $indexer ? "indexed " : "", |
$log->info("$total_rows records ", $indexer ? "indexed " : "", |
627 |
sprintf("in %.2f sec [%.2f rec/sec]", |
sprintf("in %.2f sec [%.2f rec/sec]", |