jdbc-protolib/src/main/java/com/streamsets/pipeline/lib/jdbc/multithread/JdbcBaseRunnable.java
private void initGaugeIfNeeded() {
    gaugeMap.put(THREAD_NAME, Thread.currentThread().getName());
    gaugeMap.put(STATUS, "");
    gaugeMap.put(TABLES_OWNED_COUNT, tableReadContextCache.size());
    gaugeMap.put(CURRENT_TABLE, "");
  }
private void initGaugeIfNeeded() {
    gaugeMap.put(THREAD_NAME, Thread.currentThread().getName());
    gaugeMap.put(STATUS, "");
    gaugeMap.put(TABLES_OWNED_COUNT, tableReadContextCache.size());
    gaugeMap.put(CURRENT_TABLE, "");
  }
private void initGaugeIfNeeded ( ) { gaugeMap . put ( THREAD_NAME , Thread . currentThread ( ) . getName ( ) ) ; gaugeMap . put ( STATUS , "" ) ; gaugeMap . put ( TABLES_OWNED_COUNT , tableReadContextCache . size ( ) ) ; gaugeMap . put ( CURRENT_TABLE , "" ) ; }
Initialize the gauge with needed information
Initialize the gauge with needed information