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/195d5bc2 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/195d5bc2 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/195d5bc2 Branch: refs/heads/1.0.x-branch Commit: 195d5bc2815f6df24d3a6c5a292c8009b8b8b2ae Parents: 92b6bcb Author: darionyaphet <[email protected]> Authored: Sun Jun 5 14:40:35 2016 +0800 Committer: P. Taylor Goetz <[email protected]> Committed: Thu Jun 9 15:41:03 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/195d5bc2/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";
