class BackPressureStatsTrackerImpl implements BackPressureStatsTracker {

	public void shutDown() {
		synchronized (lock) {
			if (!shutDown) {
				operatorStatsCache.invalidateAll();
				pendingStats.clear();

				shutDown = true;
			}
		}
	}

	public  BackPressureStatsTrackerImpl(
			BackPressureRequestCoordinator coordinator,
			int cleanUpInterval,
			int refreshInterval);

}