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

Class AssociationCreateOrUpdateOp

java.lang.Object

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

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

Direct Known Subclasses:

AssociationCreateOp, AssociationUpsertOp

public abstract class AssociationCreateOrUpdateOp
extends AssociationOp

Field Summary

Fields inherited from class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

KEY_ASSOCIATION_TYPE, opType, VALUE_ASSOCIATION_TYPE

Constructor Summary

Constructors

Constructor	Description
AssociationCreateOrUpdateOp(OpType opType, 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)
void	validate(boolean dryRun)

Methods inherited from class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

getType, toJson

Methods inherited from class java.lang.Object

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

Constructor Details

AssociationCreateOrUpdateOp

public AssociationCreateOrUpdateOp(OpType opType,
 String subject,
 String associationType,
 LifecyclePolicy lifecycle,
 Boolean frozen,
 RegisterSchemaRequest schema,
 Boolean normalize)

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 AssociationOp

hashCode

public int hashCode()

Overrides:

hashCode in class AssociationOp

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 dryRun)

Specified by:

validate in class AssociationOp