You're looking in the right place. UpdateStatement extends ModificationStatement, and MS.execute calls into StorageProxy.mutate which is what does the partitioning and routing.
On Sat, Jun 11, 2016 at 2:30 PM, Mahdi Mohammadi <mah...@gmail.com> wrote: > Hi, > > When an INSERT command is received in a coordinator node, it uses a > partitioner to find out the node which is responsible for storing that row. > It then sends the command to that node to be further processed and stored > locally. > > I am looking for the place in the code which does the above. I tried > looking inside *UpdateStatement* class but couldn't find anything. I also > searched for places which use *IPartitioner* interface, but still no luck. > > Can someone help me with this? > > Best Regards > -- Jonathan Ellis Project Chair, Apache Cassandra co-founder, http://www.datastax.com @spyced
