Package com.linkedin.venice.meta

Interface Version

    • Field Detail

      • REAL_TIME_TOPIC_SUFFIX

        static final java.lang.String REAL_TIME_TOPIC_SUFFIX
        See Also:
        Constant Field Values

      • STREAM_REPROCESSING_TOPIC_SUFFIX

        static final java.lang.String STREAM_REPROCESSING_TOPIC_SUFFIX
        See Also:
        Constant Field Values

      • REPLICATION_METADATA_VERSION_ID_UNSET

        static final int REPLICATION_METADATA_VERSION_ID_UNSET
        Special number indicating no replication metadata version is set.
        See Also:
        Constant Field Values

      • VENICE_RE_PUSH_PUSH_ID_PREFIX

        static final java.lang.String VENICE_RE_PUSH_PUSH_ID_PREFIX
        Prefix used in push id to indicate the version's data source is coming from an existing version topic.
        See Also:
        Constant Field Values

    • Method Detail

      • getNumber

        int getNumber()

      • setNumber

        void setNumber​(int number)

      • getCreatedTime

        long getCreatedTime()

      • getAge

        java.time.Duration getAge()

      • setAge

        void setAge​(java.time.Duration age)

      • setCompressionStrategy

        void setCompressionStrategy​(CompressionStrategy compressionStrategy)

      • isLeaderFollowerModelEnabled

        default boolean isLeaderFollowerModelEnabled()

      • isNativeReplicationEnabled

        boolean isNativeReplicationEnabled()

      • setLeaderFollowerModelEnabled

        @Deprecated
default void setLeaderFollowerModelEnabled​(boolean leaderFollowerModelEnabled)
        Deprecated.

      • setNativeReplicationEnabled

        void setNativeReplicationEnabled​(boolean nativeReplicationEnabled)

      • getPushStreamSourceAddress

        java.lang.String getPushStreamSourceAddress()

      • setPushStreamSourceAddress

        void setPushStreamSourceAddress​(java.lang.String address)

      • setBufferReplayEnabledForHybrid

        void setBufferReplayEnabledForHybrid​(boolean bufferReplayEnabledForHybrid)

      • isChunkingEnabled

        boolean isChunkingEnabled()

      • setChunkingEnabled

        void setChunkingEnabled​(boolean chunkingEnabled)

      • isRmdChunkingEnabled

        boolean isRmdChunkingEnabled()

      • setRmdChunkingEnabled

        void setRmdChunkingEnabled​(boolean rmdChunkingEnabled)

      • getStoreName

        java.lang.String getStoreName()

      • getPushJobId

        java.lang.String getPushJobId()

      • setPushJobId

        void setPushJobId​(java.lang.String pushJobId)

      • setPartitionCount

        void setPartitionCount​(int partitionCount)

      • getPartitionCount

        int getPartitionCount()

      • setPartitionerConfig

        void setPartitionerConfig​(PartitionerConfig partitionerConfig)

      • isVersionSwapDeferred

        boolean isVersionSwapDeferred()

      • setVersionSwapDeferred

        void setVersionSwapDeferred​(boolean versionSwapDeferred)

      • getReplicationFactor

        int getReplicationFactor()

      • setReplicationFactor

        void setReplicationFactor​(int replicationFactor)

      • getMinActiveReplicas

        int getMinActiveReplicas()

      • getNativeReplicationSourceFabric

        java.lang.String getNativeReplicationSourceFabric()

      • setNativeReplicationSourceFabric

        void setNativeReplicationSourceFabric​(java.lang.String nativeReplicationSourceFabric)

      • isIncrementalPushEnabled

        boolean isIncrementalPushEnabled()

      • setIncrementalPushEnabled

        void setIncrementalPushEnabled​(boolean incrementalPushEnabled)

      • isBlobTransferEnabled

        boolean isBlobTransferEnabled()

      • setBlobTransferEnabled

        void setBlobTransferEnabled​(boolean blobTransferEnabled)

      • isUseVersionLevelIncrementalPushEnabled

        boolean isUseVersionLevelIncrementalPushEnabled()

      • setUseVersionLevelIncrementalPushEnabled

        void setUseVersionLevelIncrementalPushEnabled​(boolean versionLevelIncrementalPushEnabled)

      • setHybridStoreConfig

        void setHybridStoreConfig​(HybridStoreConfig hybridConfig)

      • getViewConfigs

        java.util.Map<java.lang.String,​ViewConfig> getViewConfigs()

      • setViewConfigs

        void setViewConfigs​(java.util.Map<java.lang.String,​ViewConfig> viewConfigMap)

      • isUseVersionLevelHybridConfig

        boolean isUseVersionLevelHybridConfig()

      • setUseVersionLevelHybridConfig

        void setUseVersionLevelHybridConfig​(boolean versionLevelHybridConfig)

      • isActiveActiveReplicationEnabled

        boolean isActiveActiveReplicationEnabled()

      • setActiveActiveReplicationEnabled

        void setActiveActiveReplicationEnabled​(boolean activeActiveReplicationEnabled)

      • getTimestampMetadataVersionId

        @Deprecated
default int getTimestampMetadataVersionId()
        Deprecated.
        Use getRmdVersionId() instead
        Get the replication metadata version id.
        Returns:
        the replication metadata version id

      • setTimestampMetadataVersionId

        @Deprecated
default void setTimestampMetadataVersionId​(int replicationMetadataVersionId)
        Deprecated.
        Use setRmdVersionId(int) instead
        Set the replication metadata version id.

      • cloneVersion

        Version cloneVersion()

      • getRmdVersionId

        int getRmdVersionId()

      • setRmdVersionId

        void setRmdVersionId​(int replicationMetadataVersionId)

      • kafkaTopicName

        java.lang.String kafkaTopicName()
        Kafka topic name is composed by store name and version.

        The Json deserializer will think it should be a field called kafkaTopicName if we use "getKafkaTopicName" here. So use "kafkaTopicName" directly here to avoid error when deserialize.

        Returns:
        kafka topic name.

      • parseStoreFromVersionTopic

        static java.lang.String parseStoreFromVersionTopic​(java.lang.String kafkaTopic)

      • parseVersionFromKafkaTopicName

        static int parseVersionFromKafkaTopicName​(java.lang.String kafkaTopic)
        This API works for both version topic and stream-reprocessing topics; other topic names will fail with IllegalArgumentException.

      • parseVersionFromVersionTopicName

        static int parseVersionFromVersionTopicName​(java.lang.String kafkaTopic)
        This API only works for version topic; other topic names will fail with IllegalArgumentException.

      • getLastIndexOfVersionSeparator

        static int getLastIndexOfVersionSeparator​(java.lang.String kafkaTopic)

      • composeKafkaTopic

        static java.lang.String composeKafkaTopic​(java.lang.String storeName,
                                          int versionNumber)

      • composeRealTimeTopic

        static java.lang.String composeRealTimeTopic​(java.lang.String storeName)

      • composeStreamReprocessingTopic

        static java.lang.String composeStreamReprocessingTopic​(java.lang.String storeName,
                                                       int versionNumber)

      • composeStreamReprocessingTopicFromVersionTopic

        static java.lang.String composeStreamReprocessingTopicFromVersionTopic​(java.lang.String versionTopic)

      • composeVersionTopicFromStreamReprocessingTopic

        static java.lang.String composeVersionTopicFromStreamReprocessingTopic​(java.lang.String kafkaTopic)

      • parseStoreFromRealTimeTopic

        static java.lang.String parseStoreFromRealTimeTopic​(java.lang.String kafkaTopic)

      • parseStoreFromStreamReprocessingTopic

        static java.lang.String parseStoreFromStreamReprocessingTopic​(java.lang.String kafkaTopic)

      • parseStoreFromKafkaTopicName

        static java.lang.String parseStoreFromKafkaTopicName​(java.lang.String kafkaTopic)
        Parse the store name of the given topic accordingly depending on the type of the kafka topic.
        Parameters:
        kafkaTopic - to parse.
        Returns:
        the store name or an empty string if the topic format doesn't match any of the known Venice topic formats.

      • isRealTimeTopic

        static boolean isRealTimeTopic​(java.lang.String kafkaTopic)

      • isStreamReprocessingTopic

        static boolean isStreamReprocessingTopic​(java.lang.String kafkaTopic)

      • isVersionTopicOrStreamReprocessingTopic

        static boolean isVersionTopicOrStreamReprocessingTopic​(java.lang.String kafkaTopic)
        Return true if the input topic name is a version topic or stream-reprocessing topic.

      • isATopicThatIsVersioned

        static boolean isATopicThatIsVersioned​(java.lang.String kafkaTopic)
        Determines if the the inputted topic is a topic which is versioned. Today that includes reprocessing topics, version topics, and view topics. This method is named this way in order to avoid confusion with the isVersionTopic (where the alternative would be isVersionedTopic).
        Parameters:
        kafkaTopic -
        Returns:

      • checkVersionSRTopic

        static boolean checkVersionSRTopic​(java.lang.String kafkaTopic,
                                   boolean checkSR)

      • isVersionTopic

        static boolean isVersionTopic​(java.lang.String kafkaTopic)
        Only return true if the input topic name is a version topic.

      • guidBasedDummyPushId

        static java.lang.String guidBasedDummyPushId()

      • numberBasedDummyPushId

        static java.lang.String numberBasedDummyPushId​(int number)

      • generateRePushId

        static java.lang.String generateRePushId​(java.lang.String pushId)

      • isPushIdRePush

        static boolean isPushIdRePush​(java.lang.String pushId)

      • containsHybridVersion

        static boolean containsHybridVersion​(java.util.List<Version> versions)