August 2017
Beginner to intermediate
284 pages
6h 51m
English
In non-transactional topology, a spout emits a batch of tuples and doesn't guarantee what's in each batch. With a processing mechanism, we can divide the pipeline into two categories:
We can write a non-transactional spout by implementing the org.apache.storm.trident.spout.IBatchSpout interface.
This example shows how we can write a Trident spout:
public class FakeTweetSpout ...
Read now
Unlock full access