org.apache.hadoop.hbase.io

Class FileChangeWatcher

java.lang.Object

org.apache.hadoop.hbase.io.FileChangeWatcher

@InterfaceAudience.Private
public final class FileChangeWatcher
extends Object

Instances of this class can be used to watch a file for changes. When a file's modification time changes, the callback provided by the user will be called from a background thread. Modification are detected by checking the file's attributes every polling interval. Some things to keep in mind:

• The callback should be thread-safe.
• Changes that happen around the time the thread is started may be missed.
• There is a delay between a file changing and the callback firing.

This file was originally copied from the Apache ZooKeeper project, and then modified.

See Also:

Base revision

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FileChangeWatcher.FileChangeWatcherCallback

Constructor Summary

Constructors

Constructor and Description
FileChangeWatcher(Path filePath, String threadNameSuffix, Duration pollInterval, FileChangeWatcher.FileChangeWatcherCallback callback) Creates a watcher that watches filePath and invokes callback on changes.

Method Summary

Modifier and Type	Method and Description
void	start() Tells the background thread to start.
void	stop() Tells the background thread to stop.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileChangeWatcher

public FileChangeWatcher(Path filePath,
                         String threadNameSuffix,
                         Duration pollInterval,
                         FileChangeWatcher.FileChangeWatcherCallback callback)
                  throws IOException

Creates a watcher that watches filePath and invokes callback on changes.

Parameters:

filePath - the file to watch.

callback - the callback to invoke with events. event.kind() will return the type of event, and event.context() will return the filename relative to dirPath.

Throws:

IOException - if there is an error creating the WatchService.

Method Detail

start

public void start()

Tells the background thread to start. Does not wait for it to be running. Calling this method more than once has no effect.

stop

public void stop()

Tells the background thread to stop. Does not wait for it to exit.