Package org.apache.cassandra.net

Class ForwardingInfo

java.lang.Object

org.apache.cassandra.net.ForwardingInfo

All Implemented Interfaces:

Serializable

public final class ForwardingInfo
extends Object
implements Serializable

A container used to store a node -> message_id map for inter-DC write forwarding. We pick one node in each external DC to forward the message to its local peers.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ForwardingInfo(List<InetAddressAndPort> targets, long[] messageIds)

Method Summary

Modifier and Type	Method	Description
void	forEach(BiConsumer<Long,InetAddressAndPort> biConsumer)	Apply the provided consumer to all (host, message_id) pairs.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ForwardingInfo

public ForwardingInfo(List<InetAddressAndPort> targets,
 long[] messageIds)

Method Details

forEach

public void forEach(BiConsumer<Long,InetAddressAndPort> biConsumer)

Apply the provided consumer to all (host, message_id) pairs.