package com.cloudera.flume.master.commands;
import java.io.IOException;
import com.cloudera.flume.master.Command;
import com.cloudera.flume.master.Execable;
import com.cloudera.flume.master.FlumeMaster;
import com.google.common.base.Preconditions;
String node;
return node;
}
this.node = node;
}
return new Command("refresh", node);
}
return new Execable() {
@Override
public void exec(String[] argv)
throws IOException {
Preconditions.checkArgument(argv.length == 1);
FlumeMaster master = FlumeMaster.getInstance();
String node = argv[0];
master.getSpecMan().refresh(node);
}
};
}
}