Class CassandraTable.CassandraTableBuilder<C extends CassandraTable,B extends CassandraTable.CassandraTableBuilder<C,B>>

Enclosing class:
CassandraTable

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

    • CassandraTableBuilder Link icon

      public CassandraTableBuilder()
  • Method Details Link icon

    • $fillValuesFrom Link icon

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

      public B typeName(String typeName)
      Fixed typeName for CassandraTables.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends CassandraTable,B extends CassandraTable.CassandraTableBuilder<C,B>>
      Returns:
      this.
    • cassandraColumn Link icon

      public B cassandraColumn(ICassandraColumn cassandraColumn)
    • cassandraColumns Link icon

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

      public B clearCassandraColumns()
    • cassandraIndex Link icon

      public B cassandraIndex(ICassandraIndex cassandraIndex)
    • cassandraIndexes Link icon

      public B cassandraIndexes(Collection<? extends ICassandraIndex> cassandraIndexes)
    • clearCassandraIndexes Link icon

      public B clearCassandraIndexes()
    • cassandraKeyspace Link icon

      public B cassandraKeyspace(ICassandraKeyspace cassandraKeyspace)
      Keyspace containing the table.
      Returns:
      this.
    • cassandraKeyspaceName Link icon

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

      public B cassandraTableBloomFilterFPChance(Double cassandraTableBloomFilterFPChance)
      Bloom filter false positive chance for the CassandraTable.
      Returns:
      this.
    • cassandraTableCRCCheckChance Link icon

      public B cassandraTableCRCCheckChance(Double cassandraTableCRCCheckChance)
      CRC check chance for the CassandraTable.
      Returns:
      this.
    • putCassandraTableCaching Link icon

      public B putCassandraTableCaching(String putCassandraTableCachingKey, String putCassandraTableCachingValue)
    • cassandraTableCaching Link icon

      public B cassandraTableCaching(Map<? extends String,? extends String> cassandraTableCaching)
    • clearCassandraTableCaching Link icon

      public B clearCassandraTableCaching()
    • cassandraTableComment Link icon

      public B cassandraTableComment(String cassandraTableComment)
      Comment describing the CassandraTable's purpose or usage in Cassandra.
      Returns:
      this.
    • putCassandraTableCompaction Link icon

      public B putCassandraTableCompaction(String putCassandraTableCompactionKey, String putCassandraTableCompactionValue)
    • cassandraTableCompaction Link icon

      public B cassandraTableCompaction(Map<? extends String,? extends String> cassandraTableCompaction)
    • clearCassandraTableCompaction Link icon

      public B clearCassandraTableCompaction()
    • putCassandraTableCompression Link icon

      public B putCassandraTableCompression(String putCassandraTableCompressionKey, String putCassandraTableCompressionValue)
    • cassandraTableCompression Link icon

      public B cassandraTableCompression(Map<? extends String,? extends String> cassandraTableCompression)
    • clearCassandraTableCompression Link icon

      public B clearCassandraTableCompression()
    • cassandraTableDCLocalReadRepairChance Link icon

      public B cassandraTableDCLocalReadRepairChance(Double cassandraTableDCLocalReadRepairChance)
      Local read repair chance in Cassandra.
      Returns:
      this.
    • cassandraTableDefaultTTL Link icon

      public B cassandraTableDefaultTTL(Long cassandraTableDefaultTTL)
      Default time-to-live for the CassandraTable in Cassandra.
      Returns:
      this.
    • cassandraTableFlag Link icon

      public B cassandraTableFlag(String cassandraTableFlag)
    • cassandraTableFlags Link icon

      public B cassandraTableFlags(Collection<? extends String> cassandraTableFlags)
    • clearCassandraTableFlags Link icon

      public B clearCassandraTableFlags()
    • cassandraTableGCGraceSeconds Link icon

      public B cassandraTableGCGraceSeconds(Long cassandraTableGCGraceSeconds)
      Grace period for garbage collection in the CassandraTable.
      Returns:
      this.
    • cassandraTableId Link icon

      public B cassandraTableId(String cassandraTableId)
      Unique identifier for the CassandraTable.
      Returns:
      this.
    • cassandraTableMaxIndexInterval Link icon

      public B cassandraTableMaxIndexInterval(Long cassandraTableMaxIndexInterval)
      Maximum index interval for the CassandraTable.
      Returns:
      this.
    • cassandraTableMemtableFlushPeriodInMs Link icon

      public B cassandraTableMemtableFlushPeriodInMs(Long cassandraTableMemtableFlushPeriodInMs)
      Memtable flush period for the CassandraTable (in milliseconds).
      Returns:
      this.
    • cassandraTableMinIndexInterval Link icon

      public B cassandraTableMinIndexInterval(Long cassandraTableMinIndexInterval)
      Minimum index interval for the CassandraTable.
      Returns:
      this.
    • cassandraTableName Link icon

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

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

      public B cassandraTableQuery(String cassandraTableQuery)
      Query used to create the CassandraTable in Cassandra.
      Returns:
      this.
    • cassandraTableReadRepairChance Link icon

      public B cassandraTableReadRepairChance(Double cassandraTableReadRepairChance)
      Read repair chance for the CassandraTable.
      Returns:
      this.
    • cassandraTableSpeculativeRetry Link icon

      public B cassandraTableSpeculativeRetry(String cassandraTableSpeculativeRetry)
      Speculative retry setting for the CassandraTable.
      Returns:
      this.
    • cassandraTableVirtual Link icon

      public B cassandraTableVirtual(Boolean cassandraTableVirtual)
      Indicates whether the CassandraTable is virtual.
      Returns:
      this.
    • cassandraViewName Link icon

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

      public B cassandraViewQualifiedName(String cassandraViewQualifiedName)
      Unique name of view for Cassandra asset
      Returns:
      this.
    • 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()
    • noSQLSchemaDefinition Link icon

      public B noSQLSchemaDefinition(String noSQLSchemaDefinition)
      Represents attributes for describing the key schema for the table and indexes.
      Returns:
      this.
    • 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()
    • self Link icon

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

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

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