Package io.confluent.kafka.schemaregistry.client.rest.entities.requests

Class AssociationCreateOrUpdateInfo

java.lang.Object

io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

public class AssociationCreateOrUpdateInfo
extends Object

Constructor Summary

Constructors

Constructor	Description
AssociationCreateOrUpdateInfo(AssociationCreateOrUpdateOp op)
AssociationCreateOrUpdateInfo(String subject, String associationType, LifecyclePolicy lifecycle, Boolean frozen, RegisterSchemaRequest schema, Boolean normalize)

Method Summary

Modifier and Type	Method	Description
void	applyDefaults(boolean isCreate)	Applies defaults for an association that does not yet exist.
boolean	equals(Object o)
String	getAssociationType()
Boolean	getFrozen()
LifecyclePolicy	getLifecycle()
Boolean	getNormalize()
RegisterSchemaRequest	getSchema()
String	getSubject()
int	hashCode()
void	setAssociationType(String associationType)
void	setFrozen(Boolean frozen)
void	setLifecycle(LifecyclePolicy lifecycle)
void	setNormalize(Boolean normalize)
void	setSchema(RegisterSchemaRequest schema)
void	setSubject(String subject)
String	toJson()
void	validate(boolean isCreate, boolean dryRun)

Methods inherited from class java.lang.Object

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

Constructor Details

AssociationCreateOrUpdateInfo

public AssociationCreateOrUpdateInfo(String subject,
 String associationType,
 LifecyclePolicy lifecycle,
 Boolean frozen,
 RegisterSchemaRequest schema,
 Boolean normalize)

AssociationCreateOrUpdateInfo

public AssociationCreateOrUpdateInfo(AssociationCreateOrUpdateOp op)

Method Details

getSubject

public String getSubject()

setSubject

public void setSubject(String subject)

getAssociationType

public String getAssociationType()

setAssociationType

public void setAssociationType(String associationType)

getLifecycle

public LifecyclePolicy getLifecycle()

setLifecycle

public void setLifecycle(LifecyclePolicy lifecycle)

getFrozen

public Boolean getFrozen()

setFrozen

public void setFrozen(Boolean frozen)

getSchema

public RegisterSchemaRequest getSchema()

setSchema

public void setSchema(RegisterSchemaRequest schema)

getNormalize

public Boolean getNormalize()

setNormalize

public void setNormalize(Boolean normalize)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toJson

public String toJson()
              throws IOException

Throws:

IOException

applyDefaults

public void applyDefaults(boolean isCreate)

Applies defaults for an association that does not yet exist. Only call this while creating the association: an upsert that updates an existing one keeps that association's stored lifecycle and would be wrongly rejected here for carrying a schema.

For a create op a schema implies frozen STRONG, and frozen=false or WEAK alongside a schema are rejected. For an upsert op no schema is accepted at all, since a schema implies a topic-owned STRONG association and those can only be created together with the topic. Either way frozen and lifecycle are defaulted when null.

The matching check on an explicit STRONG lifecycle lives in the registry, which can exempt subjects in IMPORT mode.

Parameters:

isCreate - whether this is a create op rather than an upsert op

validate

public void validate(boolean isCreate,
 boolean dryRun)