I don't understand what's mean that should use the trident if the message process must only once Can I process message only once using ack() and fail() on BaseRichSpout? If I don't need the trident's functions(eg. groupping, jonning..), Can I use the BaseRich?
I don't understand what's mean that should use trident if the message process must only once
55 Views Asked by 이진희 At
1
There are 1 best solutions below
Related Questions in APACHE-STORM
- How can I serialize a numpy array while preserving matrix dimensions?
- Logging from a storm bolt - where is it going?
- Storm Word Count Topology - Concept issue with number of executions
- Supervisor node will not connect to storm cluster
- Storm [ERROR] Async loop died
- How to export data from Cassandra to mongodb?
- Why is my streamparse topology definition complaining about a wrong number of arguments to thrift$mk-topology?
- storm caching in topology level available for all bolts
- java.lang.RuntimeException : no viable alternative at input '<EOF>'
- storm supervisor exits when processing event
- apache storm into node js
- Passing cmd line params to storm subprocesses
- storm-starter with intellij idea,maven project could not find class
- storm + kafka: understanding ack, fail and latency
- storm topology: one to many (random)
Related Questions in TRIDENT
- How to write transactional spout for storm trident
- Does Storm Trident newValueStream after persistentAggregate maintain partition from groupBy
- How to get previous state before counter update
- Why does the locaton of my animated circles flicker?
- issue on implementing transactional topology in trident
- Debugging JavaScript in Trident-based app
- DRPC Server error in storm
- KafkaTridentSpoutOpaque Repeated consumption the last message
- Should i use Trident to compute the global mean of tuples in Storm?
- Storm Trident Window Join
- Storm Trident State Query While Update
- Total number of non repeated words in each tweet
- Trident kafka transactional spout
- How to create serial TridentState bolts using partitionpersist in Apache Storm?
- I don't understand what's mean that should use trident if the message process must only once
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Storm supports "at least once" process, as the failed message will be handled again from the beginning, which will cause some repetition.
Trident is one way to support "exactly once" process.
So if you have to handle messages only once in storm ,you have to use trident.