@@ -40,7 +40,7 @@ little interest to users.
5. Tag the release
-% git tag -am "Tagging version 0.x.y" 0.x.y
+% git tag -am "Tagging 0.x.y release" 0.x.y
6. Updating GitHub (this will take a while)
doc/Releasing.txt
@@ -12,70 +12,79 @@ import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class FsUtils {
- private static final Pattern LOOP_DIRNAME_PATTERN = Pattern.compile("(\\d+)-([^/]+)");
-
- public static Path makeLoopDir(FileSystem fs, Path outputDir, int loopNumber) throws IOException {
- String timestamp = new SimpleDateFormat("yyyyMMdd'T'HHmmss").format(new Date());
- Path loopDir = new Path(outputDir, "" + loopNumber + "-" + timestamp);
- fs.mkdirs(loopDir);
- return loopDir;
- }
-
- public static Path findLatestLoopDir(FileSystem fs, Path outputPath) throws IOException {
+ private static final Pattern LOOP_DIRNAME_PATTERN = Pattern
+ .compile("(\\d+)-([^/]+)");
+
+ public static Path makeLoopDir(FileSystem fs, Path outputDir, int loopNumber)
+ throws IOException {
+ String timestamp = new SimpleDateFormat("yyyyMMdd'T'HHmmss")
+ .format(new Date());
+ Path loopDir = new Path(outputDir, "" + loopNumber + "-" + timestamp);
+ fs.mkdirs(loopDir);
+ return loopDir;
+ }
+
+ public static Path findLatestLoopDir(FileSystem fs, Path outputPath)
+ throws IOException {
int bestLoop = -1;
- Path result = null;
-
- FileStatus[] subdirs = fs.listStatus(outputPath);
- for (FileStatus status : subdirs) {
- if (!status.isDir()) {
- continue;
- }
+ Path result = null;
- try {
- int curLoop = extractLoopNumber(status.getPath());
- if (curLoop > bestLoop) {
- bestLoop = curLoop;
- result = status.getPath();
- }
- } catch (InvalidParameterException e) {
- // ignore, though we shouldn't have random sub-dirs in the output directory.
- }
- }
+ FileStatus[] subdirs = fs.listStatus(outputPath);
+ for (FileStatus status : subdirs) {
+ if (!status.isDir()) {
+ continue;
+ }
- return result;
- }
+ try {
+ int curLoop = extractLoopNumber(status.getPath());
+ if (curLoop > bestLoop) {
+ bestLoop = curLoop;
+ result = status.getPath();
+ }
+ } catch (InvalidParameterException e) {
+ // ignore, though we shouldn't have random sub-dirs in the
+ // output directory.
+ }
+ }
- public static Path findNextLoopDir(FileSystem fs, Path outputPath, int loopNumber) throws IOException {
+ return result;
+ }
+
+ public static Path findNextLoopDir(FileSystem fs, Path outputPath,
+ int loopNumber) throws IOException {
int bestLoop = Integer.MAX_VALUE;
- Path result = null;
-
- FileStatus[] subdirs = fs.listStatus(outputPath);
- for (FileStatus status : subdirs) {
- if (!status.isDir()) {
- continue;
- }
+ Path result = null;
+
+ FileStatus[] subdirs = fs.listStatus(outputPath);
+ for (FileStatus status : subdirs) {
+ if (!status.isDir()) {
+ continue;
+ }
- try {
- int curLoop = extractLoopNumber(status.getPath());
- if ((curLoop > loopNumber) && (curLoop < bestLoop)) {
- bestLoop = curLoop;
- result = status.getPath();
- }
- } catch (InvalidParameterException e) {
- // ignore, though we shouldn't have random sub-dirs in the output directory.
- }
- }
+ try {
+ int curLoop = extractLoopNumber(status.getPath());
+ if ((curLoop > loopNumber) && (curLoop < bestLoop)) {
+ bestLoop = curLoop;
+ result = status.getPath();
+ }
+ } catch (InvalidParameterException e) {
+ // ignore, though we shouldn't have random sub-dirs in the
+ // output directory.
+ }
+ }
- return result;
- }
+ return result;
+ }
- public static int extractLoopNumber(Path inputPath) throws InvalidParameterException {
+ public static int extractLoopNumber(Path inputPath)
+ throws InvalidParameterException {
String dirName = inputPath.getName();
Matcher dirNameMatcher = LOOP_DIRNAME_PATTERN.matcher(dirName);
if (dirNameMatcher.matches()) {
return Integer.parseInt(dirNameMatcher.group(1));
} else {
- throw new InvalidParameterException(String.format("%s is not a valid loop directory name", dirName));
+ throw new InvalidParameterException(String.format(
+ "%s is not a valid loop directory name", dirName));
}
}
}
src/main/java/bixo/utils/FsUtils.java
src/main/java/bixo/utils/FSUtils.java
src/main/java/bixo/utils/IOUtils.java
6678c089a4ea7133f5b0bf0beaf4fe27abd0cb6b
871521a2c4555e3ef527389b4090753afd05450d
Ken Krugler
kkrugler@transpac.com
http://github.com/emi/bixo/commit/8efb04b0c9fa5f75cdf6b68ad3f369521b96a359
8efb04b0c9fa5f75cdf6b68ad3f369521b96a359
2009-10-27T10:58:45-07:00
2009-10-27T10:58:45-07:00
Merge branch 'master' into release
16aab4478b4dda45d1a8cbf38519fd9c02b903b1
Ken Krugler
kkrugler@transpac.com