I'm new to flink and I have read
https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/metrics.html,
I am still unclear where do I read the metrics I added.
for example,
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(2);
List<String> wordList = Arrays.asList("Hive", "Presto", "Impala",
"Parquet","ORC","Hadoop", "Flink", "Spark", "Storm", "Tez", "Flink");
DataStreamSource<String> source = env.fromCollection(wordList);
DataStream<Tuple2<String, Integer>> dataStream = env.fromCollection(
wordList).map(new WordLengthCounter());
dataStream.print();
env.execute();
}
and
public class WordLengthCounter extends RichMapFunction<String,
Tuple2<String, Integer>> {
private static final long serialVersionUID = 1L;
private Counter counter;
@Override
public void open(Configuration config) {
this.counter = getRuntimeContext()
.getMetricGroup()
.counter("myCounter");
}
@Override
public Tuple2<String, Integer> map(String value) throws Exception {
this.counter.inc();
return new Tuple2<String, Integer>(value, value.length());
}
}
Now, where do I see the counter? Sorry for the naive question
can anyone point me to any good end-to-end "hello world" example for flink
metrics.