Class ControllerClientBackedSystemSchemaInitializer

java.lang.Object
com.linkedin.venice.system.store.ControllerClientBackedSystemSchemaInitializer
All Implemented Interfaces:
Closeable, AutoCloseable

public class ControllerClientBackedSystemSchemaInitializer extends Object implements Closeable
  • Constructor Details

    • ControllerClientBackedSystemSchemaInitializer

      public ControllerClientBackedSystemSchemaInitializer(AvroProtocolDefinition protocolDefinition, String systemStoreCluster, org.apache.avro.Schema keySchema, UpdateStoreQueryParams storeMetadataUpdate, boolean autoRegisterPartialUpdateSchema, Optional<SSLFactory> sslFactory, String controllerUrl, String controllerD2ServiceName, Optional<com.linkedin.d2.balancer.D2Client> d2Client, String d2ZkHost, boolean enforceSslOnly)
  • Method Details

    • execute

      public void execute(Map<Integer,org.apache.avro.Schema> inputSchemas)
    • execute

      public void execute()
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable