July 2017
Intermediate to advanced
796 pages
18h 55m
English
Create an input stream that monitors a Hadoop-compatible filesystem for new files and reads them as text files (using a key as LongWritable, value as Text, and input format as TextInputFormat). Files must be written to the monitored directory by moving them from another location within the same filesystem. File names starting with . are ignored:
def textFileStream(directory: String): DStream[String]
Read now
Unlock full access