1+ #! /bin/bash
2+ # Licensed to the Apache Software Foundation (ASF) under one or more
3+ # contributor license agreements. See the NOTICE file distributed with
4+ # this work for additional information regarding copyright ownership.
5+ # The ASF licenses this file to You under the Apache License, Version 2.0
6+ # (the "License"); you may not use this file except in compliance with
7+ # the License. You may obtain a copy of the License at
8+ #
9+ # http://www.apache.org/licenses/LICENSE-2.0
10+ #
11+ # Unless required by applicable law or agreed to in writing, software
12+ # distributed under the License is distributed on an "AS IS" BASIS,
13+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+ # See the License for the specific language governing permissions and
15+ # limitations under the License.
16+
17+ workload_folder=` dirname " $0 " `
18+ workload_folder=` cd " ${workload_folder} " ; pwd`
19+ root_folder=${workload_folder} /../../..
20+ root_folder=` cd " ${root_folder} " ; pwd`
21+ common_folder=${root_folder} /src/streambench/common/target
22+
23+
24+ KAFKA_FOLDER=/home/stream/mirror/kafka/kafka_2.11-0.8.2.2
25+ ZK_HOST=" sr502:2181,sr503:2181,sr504:2181"
26+ NUM_OF_RECORDS=5000000
27+ NUM_OF_THREADS=20
28+ REPORT_PATH=/home/stream/mirror/spark_metrics
29+
30+ ${KAFKA_FOLDER} /bin/kafka-topics.sh --zookeeper ${ZK_HOST} --list
31+
32+ read -p " Please input the args: <topic>" topic
33+
34+ java -cp ${common_folder} /streaming-bench-common-5.0-SNAPSHOT-jar-with-dependencies.jar \
35+ com.intel.hibench.streambench.common.metrics.MetricsReader \
36+ ${ZK_HOST} ${topic} ${REPORT_PATH} ${NUM_OF_RECORDS} ${NUM_OF_THREADS}
0 commit comments