Repository: storm Updated Branches: refs/heads/1.0.x-branch 92b6bcb56 -> 1a50bec2c refs/heads/1.x-branch 6aee784d7 -> 71476b48d refs/heads/master bd4260e46 -> 02c4f6b40
expose TextFileReader public Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5fff9cc2 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5fff9cc2 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5fff9cc2 Branch: refs/heads/master Commit: 5fff9cc2438233fbd47757ba7d08a238a6e38fa8 Parents: 671e21e Author: darionyaphet <[email protected]> Authored: Sun Jun 5 14:40:35 2016 +0800 Committer: darionyaphet <[email protected]> Committed: Sun Jun 5 14:40:35 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/5fff9cc2/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java ---------------------------------------------------------------------- diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java index ac72d69..6da9860 100644 --- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java +++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java @@ -32,7 +32,7 @@ import java.util.List; import java.util.Map; // Todo: Track file offsets instead of line number -class TextFileReader extends AbstractFileReader { +public class TextFileReader extends AbstractFileReader { public static final String[] defaultFields = {"line"}; public static final String CHARSET = "hdfsspout.reader.charset"; public static final String BUFFER_SIZE = "hdfsspout.reader.buffer.bytes";
