hdfs-file-notifiy-java-implementation

rust-gist-medium-monitoring-hadoop-job-5.java

HdfsAdmin admin = new HdfsAdmin(URI.create(args[0]), new Configuration());

DFSInotifyEventInputStream eventStream = admin.getInotifyEventStream(lastReadTxid);

while (true) {
  EventBatch batch = eventStream.take();
  System.out.println("TxId = " + batch.getTxid());
  
  for (Event event : batch.getEvents()) {
    System.out.println("event type = " + event.getEventType());
    switch (event.getEventType()) {
      case CREATE:
        CreateEvent createEvent = (CreateEvent) event;
        System.out.println("  path = " + createEvent.getPath());
        System.out.println("  owner = " + createEvent.getOwnerName());
        System.out.println("  ctime = " + createEvent.getCtime());
				break;
      case UNLINK:
        UnlinkEvent unlinkEvent = (UnlinkEvent) event;
        System.out.println("  path = " + unlinkEvent.getPath());
        System.out.println("  timestamp = " + unlinkEvent.getTimestamp());
        break;
      default:
	break;
    }
  }
}