kind of stream processing between crawler and extractor