Package com.linkedin.venice.meta

Enum DataReplicationPolicy

  • All Implemented Interfaces:
    java.io.Serializable, java.lang.Comparable<DataReplicationPolicy>
    public enum DataReplicationPolicy
extends java.lang.Enum<DataReplicationPolicy>
    The data replication policy determines which fabric to use for sending real-time writes from clients and where to direct servers for real-time data consumption. If active-active replication is enabled, the data replication policy is bypassed, as writes are sent to the local fabric.

    • Enum Constant Detail

      • NON_AGGREGATE

        public static final DataReplicationPolicy NON_AGGREGATE
        Default value. Samza job per colo pushes to local real-time topic. Leader SNs replicate data to local version topic.

      • AGGREGATE

        public static final DataReplicationPolicy AGGREGATE
        Single Samza job or Samza job per colo pushes to real-time topic in parent colo. Leader SNs in each colo replicate data from remote real-time topic to local version topic.

    • Method Detail

      • values

        public static DataReplicationPolicy[] values()
        Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: 
        for (DataReplicationPolicy c : DataReplicationPolicy.values())
    System.out.println(c);
        Returns:
        an array containing the constants of this enum type, in the order they are declared

      • valueOf

        public static DataReplicationPolicy valueOf​(java.lang.String name)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
        Parameters:
        name - the name of the enum constant to be returned.
        Returns:
        the enum constant with the specified name
        Throws:
        java.lang.IllegalArgumentException - if this enum type has no constant with the specified name
        java.lang.NullPointerException - if the argument is null

      • getValue

        public int getValue()

      • getDataReplicationPolicyMap

        public static java.util.Map<java.lang.Integer,​DataReplicationPolicy> getDataReplicationPolicyMap()

      • valueOf

        public static DataReplicationPolicy valueOf​(int value)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
        Parameters:
        value - the name of the enum constant to be returned.
        Returns:
        the enum constant with the specified name
        Throws:
        java.lang.IllegalArgumentException - if this enum type has no constant with the specified name
        java.lang.NullPointerException - if the argument is null