弗林克：当我加计

不能使用计编译失败，则编译失败：弗林克：当我加计

def open(configuration: Configuration) { 
    getRuntimeContext() 
    .getMetricGroup() 
    .gauge("RecordConverter.latency", new Gauge[Int]() { 
     @Override 
     def getValue(): Int = { 
     return latency; 
     } 
    }); 
    }

====================== ======================================

error: overloaded method value gauge with alternatives: 
[ERROR] [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: String,x$2: G)G <and> 
[ERROR] [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: Int, x$2: G)G 
[ERROR] cannot be applied to (String, org.apache.flink.metrics.Gauge[Int]) 
[ERROR]   .gauge("RecordConverter.latency", new Gauge[Int]() { 
[ERROR]  ^

来源

2016-09-26 Pushpendra Jaiswal

您必须明确设置类型如下：

.gauge[Int, Gauge[Int]]("RecordConverter.latency"...

来源

2016-09-26 08:08:01

弗林克：当我加计

回答

相关问题