StreamTask类中包含StreamInputProcessor用来读取输入数据