scripts/pegasus_bench_run.sh

#!/bin/bash
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
# 
#   http://www.apache.org/licenses/LICENSE-2.0
# 
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.
#
# test pegasus_bench with thread 1~50

pwd="$( cd "$( dirname "$0"  )" && pwd )"
shell_dir="$( cd $pwd/.. && pwd )"
cd $shell_dir

TYPE=fillseq_pegasus # fillseq_pegasus or readrandom_pegasus
CLUSTER=127.0.0.1:34601,127.0.0.1:34602,127.0.0.1:34603
TABLE=temp

outdir=pegasus_bench_result
rm -rf $outdir
mkdir -p $outdir
echo "Thread	Count	Runtime	QPS	AvgLat	P99Lat"
for T in {1..50}
do
  N=10000
  outfile=$outdir/fill_t${T}.out
  ./run.sh bench -t $TYPE -n $N --cluster $CLUSTER --app_name $TABLE --thread_num $T --value_size 1000 &>$outfile
  Count=$((N*T))
  Runtime=`cat $outfile | grep 'ops/second in ([0-9,.]*) seconds' | tail -n 1 | grep -o ',[0-9.]*) seconds' | grep -o '[0-9.]\{6\}'`
  Throughput=`cat $outfile | grep $TYPE | grep -o '[0-9]* ops' | awk '{print $1}'`
  AvgLatency=`cat $outfile | grep 'Average:' | awk '{print $4}' | cut -d. -f1`
  P99Latency=`cat $outfile | grep 'Percentiles:' | grep -o 'P99: [0-9]*' | awk '{print $2}'`
  echo "$T	$Count	$Runtime	$Throughput	$AvgLatency	$P99Latency"
done