Temp UDAction.java

UDAction.java

package org.smartdata.server.actions;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hdfs.DFSClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.smartdata.common.actions.ActionType;

import java.util.UUID;

/**
 *
 */
public class UDAction implements Action {
  private static final Logger LOG = LoggerFactory.getLogger(UDAction.class);

  public String storagePolicy;
  private String fileName;
  private Configuration conf;
  private DFSClient dfsClient;
  private String name = "UDAction";

  public UDAction() {

  }


  public String getName() {
    return name;
  }

  public Action initial(DFSClient client, Configuration conf, String[] args) {
    this.dfsClient = client;
    this.conf = conf;
    this.fileName = args[0];
    this.storagePolicy = args[1];
    return this;
  }

  public UUID run() {
    for (int i = 10; i> 0; i--) {
      LOG.info("User Defined Action {}", name);
    }
    return null;
  }

}