[FLINK-1173] Add socket text stream as a data source for the streaming API