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 flat binary files, assuming a fixed length per record, generating one byte array per record. 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 binaryRecordsStream(directory: String, recordLength: Int): DStream[Array[Byte]]
Read now
Unlock full access