import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.CloseOp; //导入依赖的package包/类
/**
 * Converts a Transaction Log operation into a NamespaceNotification
 * object.
 * @param op the Transaction Log operation.
 * @return the NamespaceNotification object or null if the type of
 *         the operation isn't supported to be transformed into a
 *         NamespaceNotification.
 */
static NamespaceNotification createNotification(FSEditLogOp op) {
  switch (op.opCode) {
    case OP_ADD:
      return new NamespaceNotification(((AddOp)op).path,
          EventType.FILE_ADDED.getByteValue(), op.getTransactionId());

    case OP_CLOSE:
      return new NamespaceNotification(((CloseOp)op).path,
          EventType.FILE_CLOSED.getByteValue(), op.getTransactionId());
      
    case OP_DELETE:
      return new NamespaceNotification(((DeleteOp)op).path,
          EventType.NODE_DELETED.getByteValue(), op.getTransactionId());
      
    case OP_MKDIR:
      return new NamespaceNotification(((MkdirOp)op).path,
          EventType.DIR_ADDED.getByteValue(), op.getTransactionId());
    default:
      return null;
  }
}
 

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.CloseOp; //导入依赖的package包/类
/** 
 * Add close lease record to edit log.
 */
public void logCloseFile(String path, INodeFile newNode) {
  CloseOp op = CloseOp.getInstance(cache.get())
    .setPath(path)
    .setReplication(newNode.getFileReplication())
    .setModificationTime(newNode.getModificationTime())
    .setAccessTime(newNode.getAccessTime())
    .setBlockSize(newNode.getPreferredBlockSize())
    .setBlocks(newNode.getBlocks())
    .setPermissionStatus(newNode.getPermissionStatus());
  
  logEdit(op);
}