Class CassandraView.CassandraViewBuilder<C extends CassandraView,B extends CassandraView.CassandraViewBuilder<C,B>>

Enclosing class:
CassandraView

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

    • CassandraViewBuilder

      public CassandraViewBuilder()
  • Method Details

    • $fillValuesFrom

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

      public B typeName(String typeName)
      Fixed typeName for CassandraViews.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends CassandraView,B extends CassandraView.CassandraViewBuilder<C,B>>
      Returns:
      this.
    • cassandraColumn

      public B cassandraColumn(ICassandraColumn cassandraColumn)
    • cassandraColumns

      public B cassandraColumns(Collection<? extends ICassandraColumn> cassandraColumns)
    • clearCassandraColumns

      public B clearCassandraColumns()
    • cassandraKeyspace

      public B cassandraKeyspace(ICassandraKeyspace cassandraKeyspace)
      Keyspace containing the view.
      Returns:
      this.
    • cassandraKeyspaceName

      public B cassandraKeyspaceName(String cassandraKeyspaceName)
      Name of the keyspace for the Cassandra asset.
      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.
    • cassandraViewBloomFilterFPChance

      public B cassandraViewBloomFilterFPChance(Double cassandraViewBloomFilterFPChance)
      False positive chance for the Bloom filter in the CassandraView.
      Returns:
      this.
    • cassandraViewCRCCheckChance

      public B cassandraViewCRCCheckChance(Double cassandraViewCRCCheckChance)
      CRC check chance for the CassandraView.
      Returns:
      this.
    • putCassandraViewCaching

      public B putCassandraViewCaching(String putCassandraViewCachingKey, String putCassandraViewCachingValue)
    • cassandraViewCaching

      public B cassandraViewCaching(Map<? extends String,? extends String> cassandraViewCaching)
    • clearCassandraViewCaching

      public B clearCassandraViewCaching()
    • cassandraViewComment

      public B cassandraViewComment(String cassandraViewComment)
      Comment describing the CassandraView.
      Returns:
      this.
    • putCassandraViewCompaction

      public B putCassandraViewCompaction(String putCassandraViewCompactionKey, String putCassandraViewCompactionValue)
    • cassandraViewCompaction

      public B cassandraViewCompaction(Map<? extends String,? extends String> cassandraViewCompaction)
    • clearCassandraViewCompaction

      public B clearCassandraViewCompaction()
    • cassandraViewDCLocalReadRepairChance

      public B cassandraViewDCLocalReadRepairChance(Double cassandraViewDCLocalReadRepairChance)
      DC-local read repair chance for the CassandraView.
      Returns:
      this.
    • cassandraViewDefaultTTL

      public B cassandraViewDefaultTTL(Long cassandraViewDefaultTTL)
      Default time-to-live (TTL) for the CassandraView.
      Returns:
      this.
    • cassandraViewGCGraceSeconds

      public B cassandraViewGCGraceSeconds(Long cassandraViewGCGraceSeconds)
      Grace period for garbage collection in the CassandraView.
      Returns:
      this.
    • cassandraViewIncludeAllColumns

      public B cassandraViewIncludeAllColumns(Boolean cassandraViewIncludeAllColumns)
      Whether to include all columns in the CassandraView.
      Returns:
      this.
    • cassandraViewMaxIndexInterval

      public B cassandraViewMaxIndexInterval(Long cassandraViewMaxIndexInterval)
      Maximum index interval for the CassandraView.
      Returns:
      this.
    • cassandraViewMembtableFlushPeriodInMS

      public B cassandraViewMembtableFlushPeriodInMS(Long cassandraViewMembtableFlushPeriodInMS)
      Memtable flush period (in milliseconds) for the CassandraView.
      Returns:
      this.
    • cassandraViewMinIndexInterval

      public B cassandraViewMinIndexInterval(Long cassandraViewMinIndexInterval)
      Minimum index interval for the CassandraView.
      Returns:
      this.
    • 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.
    • cassandraViewQuery

      public B cassandraViewQuery(String cassandraViewQuery)
      Query used in the CassandraView.
      Returns:
      this.
    • cassandraViewReadRepairInterval

      public B cassandraViewReadRepairInterval(Long cassandraViewReadRepairInterval)
      Read repair interval for the CassandraView.
      Returns:
      this.
    • cassandraViewSpeculativeRetry

      public B cassandraViewSpeculativeRetry(String cassandraViewSpeculativeRetry)
      SpeculativeRetry setting for the CassandraView.
      Returns:
      this.
    • cassandraViewTableId

      public B cassandraViewTableId(String cassandraViewTableId)
      ID of the base table in the CassandraView.
      Returns:
      this.
    • cassandraViewWhereClause

      public B cassandraViewWhereClause(String cassandraViewWhereClause)
      Where clause used for the CassandraView query.
      Returns:
      this.
    • 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 CassandraView,B extends CassandraView.CassandraViewBuilder<C,B>>
    • build

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

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