called after each record is read . concode_field_sep boolean instrumentationEnabled concode_elem_sep Optional<Timer> extractorTimer concode_elem_sep MetricContext metricContext concode_elem_sep Optional<Meter> dataRecordExceptionsMeter concode_elem_sep Optional<Meter> readRecordsMeter concode_elem_sep Closer closer concode_field_sep void beforeRead concode_elem_sep D readRecordImpl concode_elem_sep List<Tag<?>> generateTags concode_elem_sep MetricContext getMetricContext concode_elem_sep void switchMetricContext concode_elem_sep void switchMetricContext concode_elem_sep D readRecord concode_elem_sep State getFinalState concode_elem_sep boolean isInstrumentationEnabled concode_elem_sep void regenerateMetrics concode_elem_sep void onException concode_elem_sep void close
void function ( D arg0 , long arg1 ) { Instrumented . updateTimer ( this . extractorTimer , System . nanoTime ( ) - arg1 , TimeUnit . NANOSECONDS ) ; if ( arg0 != null ) { Instrumented . markMeter ( this . readRecordsMeter ) ; } }