Class SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>

Enclosing class:
SchemaRegistrySubject

public abstract static class SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>> extends Asset.AssetBuilder<C,B>
  • Constructor Details Link icon

    • SchemaRegistrySubjectBuilder Link icon

      public SchemaRegistrySubjectBuilder()
  • Method Details Link icon

    • $fillValuesFrom Link icon

      protected B $fillValuesFrom(C instance)
      Overrides:
      $fillValuesFrom in class Asset.AssetBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>
    • typeName Link icon

      public B typeName(String typeName)
      Fixed typeName for SchemaRegistrySubjects.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>
      Returns:
      this.
    • asset Link icon

      public B asset(IAsset asset)
    • assets Link icon

      public B assets(Collection<? extends IAsset> assets)
    • clearAssets Link icon

      public B clearAssets()
    • inputToAirflowTask Link icon

      public B inputToAirflowTask(IAirflowTask inputToAirflowTask)
    • inputToAirflowTasks Link icon

      public B inputToAirflowTasks(Collection<? extends IAirflowTask> inputToAirflowTasks)
    • clearInputToAirflowTasks Link icon

      public B clearInputToAirflowTasks()
    • inputToProcess Link icon

      public B inputToProcess(ILineageProcess inputToProcess)
    • inputToProcesses Link icon

      public B inputToProcesses(Collection<? extends ILineageProcess> inputToProcesses)
    • clearInputToProcesses Link icon

      public B clearInputToProcesses()
    • inputToSparkJob Link icon

      public B inputToSparkJob(ISparkJob inputToSparkJob)
    • inputToSparkJobs Link icon

      public B inputToSparkJobs(Collection<? extends ISparkJob> inputToSparkJobs)
    • clearInputToSparkJobs Link icon

      public B clearInputToSparkJobs()
    • modelImplementedAttribute Link icon

      public B modelImplementedAttribute(IModelAttribute modelImplementedAttribute)
    • modelImplementedAttributes Link icon

      public B modelImplementedAttributes(Collection<? extends IModelAttribute> modelImplementedAttributes)
    • clearModelImplementedAttributes Link icon

      public B clearModelImplementedAttributes()
    • modelImplementedEntity Link icon

      public B modelImplementedEntity(IModelEntity modelImplementedEntity)
    • modelImplementedEntities Link icon

      public B modelImplementedEntities(Collection<? extends IModelEntity> modelImplementedEntities)
    • clearModelImplementedEntities Link icon

      public B clearModelImplementedEntities()
    • outputFromAirflowTask Link icon

      public B outputFromAirflowTask(IAirflowTask outputFromAirflowTask)
    • outputFromAirflowTasks Link icon

      public B outputFromAirflowTasks(Collection<? extends IAirflowTask> outputFromAirflowTasks)
    • clearOutputFromAirflowTasks Link icon

      public B clearOutputFromAirflowTasks()
    • outputFromProcess Link icon

      public B outputFromProcess(ILineageProcess outputFromProcess)
    • outputFromProcesses Link icon

      public B outputFromProcesses(Collection<? extends ILineageProcess> outputFromProcesses)
    • clearOutputFromProcesses Link icon

      public B clearOutputFromProcesses()
    • outputFromSparkJob Link icon

      public B outputFromSparkJob(ISparkJob outputFromSparkJob)
    • outputFromSparkJobs Link icon

      public B outputFromSparkJobs(Collection<? extends ISparkJob> outputFromSparkJobs)
    • clearOutputFromSparkJobs Link icon

      public B clearOutputFromSparkJobs()
    • schemaRegistrySchemaId Link icon

      public B schemaRegistrySchemaId(String schemaRegistrySchemaId)
      Unique identifier for schema definition set by the schema registry.
      Returns:
      this.
    • schemaRegistrySchemaType Link icon

      public B schemaRegistrySchemaType(SchemaRegistrySchemaType schemaRegistrySchemaType)
      Type of language or specification used to define the schema, for example: JSON, Protobuf, etc.
      Returns:
      this.
    • schemaRegistrySubjectBaseName Link icon

      public B schemaRegistrySubjectBaseName(String schemaRegistrySubjectBaseName)
      Base name of the subject, without -key, -value prefixes.
      Returns:
      this.
    • schemaRegistrySubjectGoverningAssetQualifiedName Link icon

      public B schemaRegistrySubjectGoverningAssetQualifiedName(String schemaRegistrySubjectGoverningAssetQualifiedName)
    • schemaRegistrySubjectGoverningAssetQualifiedNames Link icon

      public B schemaRegistrySubjectGoverningAssetQualifiedNames(Collection<? extends String> schemaRegistrySubjectGoverningAssetQualifiedNames)
    • clearSchemaRegistrySubjectGoverningAssetQualifiedNames Link icon

      public B clearSchemaRegistrySubjectGoverningAssetQualifiedNames()
    • schemaRegistrySubjectIsKeySchema Link icon

      public B schemaRegistrySubjectIsKeySchema(Boolean schemaRegistrySubjectIsKeySchema)
      Whether the subject is a schema for the keys of the messages (true) or not (false).
      Returns:
      this.
    • schemaRegistrySubjectLatestSchemaDefinition Link icon

      public B schemaRegistrySubjectLatestSchemaDefinition(String schemaRegistrySubjectLatestSchemaDefinition)
      Definition of the latest schema in the subject.
      Returns:
      this.
    • schemaRegistrySubjectLatestSchemaVersion Link icon

      public B schemaRegistrySubjectLatestSchemaVersion(String schemaRegistrySubjectLatestSchemaVersion)
      Latest schema version of the subject.
      Returns:
      this.
    • schemaRegistrySubjectSchemaCompatibility Link icon

      public B schemaRegistrySubjectSchemaCompatibility(SchemaRegistrySchemaCompatibility schemaRegistrySubjectSchemaCompatibility)
      Compatibility of the schema across versions.
      Returns:
      this.
    • self Link icon

      protected abstract B self()
      Specified by:
      self in class Asset.AssetBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>
    • build Link icon

      public abstract C build()
      Specified by:
      build in class Asset.AssetBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>
    • toString Link icon

      public String toString()
      Overrides:
      toString in class Asset.AssetBuilder<C extends SchemaRegistrySubject,B extends SchemaRegistrySubject.SchemaRegistrySubjectBuilder<C,B>>