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;
return new Command("updateAll");
}
return new Execable() {
@Override
public void exec(String[] argv)
throws IOException {
Preconditions.checkArgument(argv.length == 0);
FlumeMaster master = FlumeMaster.getInstance();
master.getSpecMan().updateAll();
}
};
}
}