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]]