flink table api监控及并行度相关问题

[周虓岗]

publicclassMyMapperextendsRichMapFunction<Long,Long>{privatetransientMetermeter;@Overridepublicvoidopen(Configurationconfig){this.meter=getRuntimeContext().getMetricGroup().meter("myMeter",newMyMeter());}@OverridepublicLongmap(Longvalue)throwsException{this.meter.markEvent();returnvalue;}}

默认的监控从open中获取meter，当使用table时没有这些api，如何才能监控


以及，table的sink算子怎么设置并行度