Skip to content
This repository has been archived by the owner. It is now read-only.
Permalink
Browse files
CHUKWA-632. Added getter method for startOffset in AbstractProcessor.…
… (Abhijit Dhar via Eric Yang)

git-svn-id: https://svn.apache.org/repos/asf/incubator/chukwa/trunk@1411810 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
macroadster committed Nov 20, 2012
1 parent 837d311 commit 88379bf74b78c93331b1a8f10d610f38c73fd0d9
Show file tree
Hide file tree
Showing 2 changed files with 21 additions and 3 deletions.
@@ -24,6 +24,8 @@ Trunk (unreleased changes)

BUGS

CHUKWA-632. Added getter method for startOffset in AbstractProcessor. (Abhijit Dhar via Eric Yang)

CHUKWA-637. Fixed default cluster selection in hicc. (Eric Yang)

CHUKWA-654. Added additional check for getting row key. (Saisai Shao via Eric Yang)
@@ -36,8 +36,8 @@ public abstract class AbstractProcessor implements MapProcessor {
Calendar calendar = Calendar.getInstance();
byte[] bytes;
int[] recordOffsets;
int currentPos = 0;
int startOffset = 0;
protected int currentPos = 0;
protected int startOffset = 0;

protected ChukwaArchiveKey archiveKey = null;
protected ChukwaRecordKey key = new ChukwaRecordKey();
@@ -125,5 +125,21 @@ protected String nextLine() {
startOffset = recordOffsets[currentPos] + 1;
currentPos++;
return RecordConstants.recoverRecordSeparators("\n", log);
}
}

public int getCurrentPos() {
return currentPos;
}

public void setCurrentPos(int currentPos) {
this.currentPos = currentPos;
}

public int getStartOffset() {
return startOffset;
}

public void setStartOffset(int startOffset) {
this.startOffset = startOffset;
}
}

0 comments on commit 88379bf

Please sign in to comment.