aws-lib/src/main/java/com/streamsets/pipeline/stage/origin/s3/AmazonS3Runnable.java
private void initGaugeIfNeeded() {
    gaugeMap.put(S3Constants.THREAD_NAME, Thread.currentThread().getName());
    gaugeMap.put(S3Constants.STATUS, "");
    gaugeMap.put(S3Constants.BUCKET, "");
    gaugeMap.put(S3Constants.OBJECT_KEY, "");
  }
private void initGaugeIfNeeded() {
    gaugeMap.put(S3Constants.THREAD_NAME, Thread.currentThread().getName());
    gaugeMap.put(S3Constants.STATUS, "");
    gaugeMap.put(S3Constants.BUCKET, "");
    gaugeMap.put(S3Constants.OBJECT_KEY, "");
  }
private void initGaugeIfNeeded ( ) { gaugeMap . put ( S3Constants . THREAD_NAME , Thread . currentThread ( ) . getName ( ) ) ; gaugeMap . put ( S3Constants . STATUS , "" ) ; gaugeMap . put ( S3Constants . BUCKET , "" ) ; gaugeMap . put ( S3Constants . OBJECT_KEY , "" ) ; }
Initialize the gauge with needed information
Initialize the gauge with needed information