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]