Hi Hari,
Iam trying to read data from a file which is stored in HDFS. Using Flume the
data is tailed and stored in HDFS.
Now I want to read this data using TextFileStream. Using the below mentioned
code Iam not able to fetch the
Data from a file which is stored in HDFS. Can anyone help me
I think you need to start your streaming job, then put the files there to
get them read. textFileStream doesn't read the existing files i believe.
Also are you sure the path is not the following? (no missing / in the
beginning?)
JavaDStreamString textStream = ssc.textFileStream(/user/