Hi Pohl,

Thanks for getting back to me so quickly. I am looking for a sample example
where I can increment counters on each stage #1 thru #3 for DATASTREAM.
Then probably I can print it using slf4j.

Thanks,
Vijay

On Tue, Mar 23, 2021 at 6:35 AM Matthias Pohl <matth...@ververica.com>
wrote:

> Hi Vijayendra,
> thanks for reaching out to the Flink community. What do you mean by
> displaying it in your local IDE? Would it be ok to log the information out
> onto stdout? You might want to have a look at the docs about setting up a
> slf4j metrics report [1] if that's the case.
>
> Best,
> Matthias
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/monitoring/metrics.html#slf4j-orgapacheflinkmetricsslf4jslf4jreporter
>
> On Tue, Mar 23, 2021 at 2:09 AM Vijayendra Yadav <contact....@gmail.com>
> wrote:
>
>> Hi Team,
>>
>> Could you provide a sample how to pass Flink Datastream Source and sink
>> results to increment COUNTER and then I want to display the Counter in
>> Local IDE.
>> Counter to display for #1 through #3.
>>
>> 1) DataStream<byte[]> messageStream = env.addSource(Kinesis Source);
>> 2) DataStream<String> outputStream =
>> messageStream.rebalance().map(CustomMapFunction());
>> 3) outputStream.addSink(Streaming File Sink).
>>
>> public class MyMapper extends RichMapFunction<String, String> {
>>   private transient Counter counter;
>>
>>   @Override
>>   public void open(Configuration config) {
>>     this.counter = getRuntimeContext()
>>       .getMetricGroup()
>>       .counter("myCounter");
>>   }
>>
>>   @Override
>>   public String map(String value) throws Exception {
>>     this.counter.inc();
>>     return value;
>>   }}
>>
>>
>> Thanks,
>> Vijay
>>
>

Reply via email to