expose TextFileReader public Signed-off-by: P. Taylor Goetz <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1d29acda Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1d29acda Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1d29acda Branch: refs/heads/1.x-branch Commit: 1d29acdaaedba42f7ce8f73ea241e6ce9579d73a Parents: 6aee784 Author: darionyaphet <[email protected]> Authored: Sun Jun 5 14:40:35 2016 +0800 Committer: P. Taylor Goetz <[email protected]> Committed: Thu Jun 9 15:39:07 2016 -0400 ---------------------------------------------------------------------- .../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/1d29acda/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";
