val specificHashtag = stream.map(status => status.getText())
val t = specificHashtag.filter(status => status contains "#Emergency")