Package com.linkedin.venice.controller.server

Class CreateVersion

java.lang.Object

com.linkedin.venice.controller.server.AbstractRoute

com.linkedin.venice.controller.server.CreateVersion

public class CreateVersion
extends AbstractRoute

This class will add a new version to the given store.

Constructor Summary

Constructors

Constructor	Description
CreateVersion(boolean sslEnabled, java.util.Optional<DynamicAccessController> accessController, boolean checkReadMethodForKafka, boolean disableParentRequestTopicForStreamPushes)

Method Summary

Modifier and Type	Method	Description
spark.Route	addVersionAndStartIngestion(Admin admin)	This function is only being used by store migration parent controllers, which write add version admin message.
spark.Route	emptyPush(Admin admin)
spark.Route	requestTopicForPushing(Admin admin)	Instead of asking Venice to create a version, pushes should ask venice which topic to write into.
spark.Route	uploadPushInfo(Admin admin)	Deprecated.
spark.Route	writeEndOfPush(Admin admin)

Methods inherited from class com.linkedin.venice.controller.server.AbstractRoute

getCertificate, getPrincipalId, hasAccessToStore, hasReadAccessToTopic, hasWriteAccessToTopic, isAclEnabled, isAllowListUser, isSslEnabled

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateVersion

public CreateVersion(boolean sslEnabled,
                     java.util.Optional<DynamicAccessController> accessController,
                     boolean checkReadMethodForKafka,
                     boolean disableParentRequestTopicForStreamPushes)

Method Detail

requestTopicForPushing

public spark.Route requestTopicForPushing(Admin admin)

Instead of asking Venice to create a version, pushes should ask venice which topic to write into. The logic below includes the ability to respond with an existing topic for the same push, allowing requests to be idempotent.

addVersionAndStartIngestion

public spark.Route addVersionAndStartIngestion(Admin admin)

This function is only being used by store migration parent controllers, which write add version admin message.

See Also:

Admin.addVersionAndStartIngestion(String, String, String, int, int, PushType, String, long, int, boolean, int)

uploadPushInfo

@Deprecated
public spark.Route uploadPushInfo(Admin admin)

Deprecated.

writeEndOfPush

public spark.Route writeEndOfPush(Admin admin)

See Also:

Admin.writeEndOfPush(String, String, int, boolean)

emptyPush

public spark.Route emptyPush(Admin admin)