schedule the given scheduledthreadpoolexecutor to run at the given interval . concode_field_sep boolean instrumentationEnabled concode_elem_sep long DEFAULT_WRITER_METRICS_UPDATER_INTERVAL concode_elem_sep Optional<Meter> recordsInMeter concode_elem_sep MetricContext metricContext concode_elem_sep Optional<Meter> successfulWritesMeter concode_elem_sep Optional<Meter> bytesWrittenMeter concode_elem_sep String WRITER_METRICS_UPDATER_INTERVAL concode_elem_sep Optional<Meter> failedWritesMeter concode_elem_sep Optional<Timer> dataWriterTimer concode_elem_sep Optional<ScheduledThreadPoolExecutor> writerMetricsUpdater concode_elem_sep Optional<Meter> recordsWrittenMeter concode_elem_sep Closer closer concode_field_sep List<Tag<?>> generateTags concode_elem_sep void onSuccessfulWrite concode_elem_sep MetricContext getMetricContext concode_elem_sep ScheduledThreadPoolExecutor buildWriterMetricsUpdater concode_elem_sep void commit concode_elem_sep void regenerateMetrics concode_elem_sep void onException concode_elem_sep void run concode_elem_sep void beforeWrite concode_elem_sep void updateBytesWrittenMeter concode_elem_sep void setRecordsWrittenMeter concode_elem_sep long getWriterMetricsUpdaterInterval concode_elem_sep void switchMetricContext concode_elem_sep void switchMetricContext concode_elem_sep void writeImpl concode_elem_sep State getFinalState concode_elem_sep boolean isInstrumentationEnabled concode_elem_sep void updateRecordsWrittenMeter concode_elem_sep void write concode_elem_sep void close concode_elem_sep void setBytesWrittenMeter
ScheduledFuture < ? > function ( ScheduledThreadPoolExecutor arg0 , long arg1 ) { return arg0 . scheduleAtFixedRate ( new WriterMetricsUpdater ( ) , arg1 , arg1 , TimeUnit . MILLISECONDS ) ; }