Class CassandraKeyspace.CassandraKeyspaceBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>>

Enclosing class:
CassandraKeyspace

public abstract static class CassandraKeyspace.CassandraKeyspaceBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>> extends Asset.AssetBuilder<C,B>
  • Constructor Details

    • CassandraKeyspaceBuilder

      public CassandraKeyspaceBuilder()
  • Method Details

    • $fillValuesFrom

      protected B $fillValuesFrom(C instance)
      Overrides:
      $fillValuesFrom in class Asset.AssetBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>>
    • typeName

      public B typeName(String typeName)
      Fixed typeName for CassandraKeyspaces.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>>
      Returns:
      this.
    • cassandraKeyspaceDurableWrites

      public B cassandraKeyspaceDurableWrites(Boolean cassandraKeyspaceDurableWrites)
      Indicates whether durable writes are enabled for the CassandraKeyspace.
      Returns:
      this.
    • cassandraKeyspaceName

      public B cassandraKeyspaceName(String cassandraKeyspaceName)
      Name of the keyspace for the Cassandra asset.
      Returns:
      this.
    • cassandraKeyspaceQuery

      public B cassandraKeyspaceQuery(String cassandraKeyspaceQuery)
      Query associated with the CassandraKeyspace.
      Returns:
      this.
    • putCassandraKeyspaceReplication

      public B putCassandraKeyspaceReplication(String putCassandraKeyspaceReplicationKey, String putCassandraKeyspaceReplicationValue)
    • cassandraKeyspaceReplication

      public B cassandraKeyspaceReplication(Map<? extends String,? extends String> cassandraKeyspaceReplication)
    • clearCassandraKeyspaceReplication

      public B clearCassandraKeyspaceReplication()
    • cassandraKeyspaceVirtual

      public B cassandraKeyspaceVirtual(Boolean cassandraKeyspaceVirtual)
      Indicates whether the CassandraKeyspace is virtual.
      Returns:
      this.
    • cassandraTableName

      public B cassandraTableName(String cassandraTableName)
      Name of the table for the Cassandra asset.
      Returns:
      this.
    • cassandraTableQualifiedName

      public B cassandraTableQualifiedName(String cassandraTableQualifiedName)
      Unique name of table for Cassandra asset
      Returns:
      this.
    • cassandraTable

      public B cassandraTable(ICassandraTable cassandraTable)
    • cassandraTables

      public B cassandraTables(Collection<? extends ICassandraTable> cassandraTables)
    • clearCassandraTables

      public B clearCassandraTables()
    • cassandraViewName

      public B cassandraViewName(String cassandraViewName)
      Name of view for Cassandra asset
      Returns:
      this.
    • cassandraViewQualifiedName

      public B cassandraViewQualifiedName(String cassandraViewQualifiedName)
      Unique name of view for Cassandra asset
      Returns:
      this.
    • cassandraView

      public B cassandraView(ICassandraView cassandraView)
    • cassandraViews

      public B cassandraViews(Collection<? extends ICassandraView> cassandraViews)
    • clearCassandraViews

      public B clearCassandraViews()
    • inputToAirflowTask

      public B inputToAirflowTask(IAirflowTask inputToAirflowTask)
    • inputToAirflowTasks

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

      public B clearInputToAirflowTasks()
    • inputToProcess

      public B inputToProcess(ILineageProcess inputToProcess)
    • inputToProcesses

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

      public B clearInputToProcesses()
    • inputToSparkJob

      public B inputToSparkJob(ISparkJob inputToSparkJob)
    • inputToSparkJobs

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

      public B clearInputToSparkJobs()
    • modelImplementedAttribute

      public B modelImplementedAttribute(IModelAttribute modelImplementedAttribute)
    • modelImplementedAttributes

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

      public B clearModelImplementedAttributes()
    • modelImplementedEntity

      public B modelImplementedEntity(IModelEntity modelImplementedEntity)
    • modelImplementedEntities

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

      public B clearModelImplementedEntities()
    • noSQLSchemaDefinition

      public B noSQLSchemaDefinition(String noSQLSchemaDefinition)
      Represents attributes for describing the key schema for the table and indexes.
      Returns:
      this.
    • outputFromAirflowTask

      public B outputFromAirflowTask(IAirflowTask outputFromAirflowTask)
    • outputFromAirflowTasks

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

      public B clearOutputFromAirflowTasks()
    • outputFromProcess

      public B outputFromProcess(ILineageProcess outputFromProcess)
    • outputFromProcesses

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

      public B clearOutputFromProcesses()
    • outputFromSparkJob

      public B outputFromSparkJob(ISparkJob outputFromSparkJob)
    • outputFromSparkJobs

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

      public B clearOutputFromSparkJobs()
    • self

      protected abstract B self()
      Specified by:
      self in class Asset.AssetBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>>
    • build

      public abstract C build()
      Specified by:
      build in class Asset.AssetBuilder<C extends CassandraKeyspace,B extends CassandraKeyspace.CassandraKeyspaceBuilder<C,B>>
    • toString

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