Skip to content

Commit db9526a

Browse files
committed
by satanson
1 parent 199f13f commit db9526a

File tree

2 files changed

+19
-2
lines changed

2 files changed

+19
-2
lines changed

paste.pl

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,16 @@
1111
my @ifiles=map {open my $h, "<$_" or die "Open file '$_' error=$!";$h} @ARGV;
1212

1313
my @contents = map{my $h=$_;[map{chomp $_;$_} <$h>]} @ifiles;
14-
@contents = map {[@{$_}[0..$n-1]] } map{[@$_, ($fill) x $n]} @contents;
14+
if ($fill eq "_") {
15+
@contents = map {[@{$_}[0..$n-1]] } map{[ (@$_)x $n]} @contents;
16+
} else {
17+
@contents = map {[@{$_}[0..$n-1]] } map{[@$_, ($fill) x $n]} @contents;
18+
}
1519

1620
#print Dumper(\@contents);
17-
21+
if ($sep eq "\\t"){
22+
$sep = "\t";
23+
}
1824
for my $i (0..$n-1) {
1925
print join "$sep", map {$contents[$_][$i]} 0..$#contents;
2026
print "\n";

sr_index2.pl

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -118,11 +118,22 @@ ($)
118118
next;
119119
}
120120

121+
if (/\b(FragmentInstancePrepareTime|__MAX_OF_FragmentInstancePrepareTime):\s+(\S+)/) {
122+
$plan->{$fragment}{$1}=norm_time($2);
123+
$plan->{$fragment}{id}=$fragment;
124+
next;
125+
}
126+
121127
if (/\b(DegreeOfParallelism|TotalDegreeOfParallelism):\s+(\d+(?:(?:\.\d+)\w+)?)/) {
122128
$plan->{$fragment}{pipelines}{$pipeline}{$1}=norm_num($2);
123129
next;
124130
}
125131

132+
if (/\b(PendingTime|__MAX_OF_PendingTime):\s+(\S+)/) {
133+
$plan->{$fragment}{pipelines}{$pipeline}{$1}=norm_time($2);
134+
next;
135+
}
136+
126137
if (/\b(ActiveTime|DriverTotalTime|OverheadTime|ScheduleTime|PendingTime|InputEmptyTime|FirstInputEmptyTime|FollowupInputEmptyTime|OutputFullTime|PreconditionBlockTime):\s+(\S+)/) {
127138
$plan->{$fragment}{pipelines}{$pipeline}{$1}=norm_time($2);
128139
next;

0 commit comments

Comments
 (0)