Class SnowflakeStage.SnowflakeStageBuilder<C extends SnowflakeStage,B extends SnowflakeStage.SnowflakeStageBuilder<C,B>>

Enclosing class:
SnowflakeStage

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

    • SnowflakeStageBuilder

      public SnowflakeStageBuilder()
  • Method Details

    • $fillValuesFrom

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

      public B typeName(String typeName)
      Fixed typeName for SnowflakeStages.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends SnowflakeStage,B extends SnowflakeStage.SnowflakeStageBuilder<C,B>>
      Returns:
      this.
    • calculationViewName

      public B calculationViewName(String calculationViewName)
      Simple name of the calculation view in which this SQL asset exists, or empty if it does not exist within a calculation view.
      Returns:
      this.
    • calculationViewQualifiedName

      public B calculationViewQualifiedName(String calculationViewQualifiedName)
      Unique name of the calculation view in which this SQL asset exists, or empty if it does not exist within a calculation view.
      Returns:
      this.
    • databaseName

      public B databaseName(String databaseName)
      Simple name of the database in which this SQL asset exists, or empty if it does not exist within a database.
      Returns:
      this.
    • databaseQualifiedName

      public B databaseQualifiedName(String databaseQualifiedName)
      Unique name of the database in which this SQL asset exists, or empty if it does not exist within a database.
      Returns:
      this.
    • dbtModel

      public B dbtModel(IDbtModel dbtModel)
    • dbtModels

      public B dbtModels(Collection<? extends IDbtModel> dbtModels)
    • clearDbtModels

      public B clearDbtModels()
    • dbtSource

      public B dbtSource(IDbtSource dbtSource)
    • dbtSources

      public B dbtSources(Collection<? extends IDbtSource> dbtSources)
    • clearDbtSources

      public B clearDbtSources()
    • dbtTest

      public B dbtTest(IDbtTest dbtTest)
    • dbtTests

      public B dbtTests(Collection<? extends IDbtTest> dbtTests)
    • clearDbtTests

      public B clearDbtTests()
    • 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()
    • isProfiled

      public B isProfiled(Boolean isProfiled)
      Whether this asset has been profiled (true) or not (false).
      Returns:
      this.
    • lastProfiledAt

      public B lastProfiledAt(Long lastProfiledAt)
      Time (epoch) at which this asset was last profiled, in milliseconds.
      Returns:
      this.
    • 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()
    • 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()
    • queryCount

      public B queryCount(Long queryCount)
      Number of times this asset has been queried.
      Returns:
      this.
    • queryCountUpdatedAt

      public B queryCountUpdatedAt(Long queryCountUpdatedAt)
      Time (epoch) at which the query count was last updated, in milliseconds.
      Returns:
      this.
    • queryUserCount

      public B queryUserCount(Long queryUserCount)
      Number of unique users who have queried this asset.
      Returns:
      this.
    • putQueryUserMap

      public B putQueryUserMap(String putQueryUserMapKey, Long putQueryUserMapValue)
    • queryUserMap

      public B queryUserMap(Map<? extends String,? extends Long> queryUserMap)
    • clearQueryUserMap

      public B clearQueryUserMap()
    • schemaName

      public B schemaName(String schemaName)
      Simple name of the schema in which this SQL asset exists, or empty if it does not exist within a schema.
      Returns:
      this.
    • schemaQualifiedName

      public B schemaQualifiedName(String schemaQualifiedName)
      Unique name of the schema in which this SQL asset exists, or empty if it does not exist within a schema.
      Returns:
      this.
    • snowflakeStageExternalLocation

      public B snowflakeStageExternalLocation(String snowflakeStageExternalLocation)
      The URL or cloud storage path specifying the external location where the stage data files are stored. This is NULL for internal stages.
      Returns:
      this.
    • snowflakeStageExternalLocationRegion

      public B snowflakeStageExternalLocationRegion(String snowflakeStageExternalLocationRegion)
      The geographic region identifier where the external stage is located in cloud storage. This is NULL for internal stages.
      Returns:
      this.
    • snowflakeStageStorageIntegration

      public B snowflakeStageStorageIntegration(String snowflakeStageStorageIntegration)
      The name of the storage integration associated with the stage; NULL for internal stages or stages that do not use a storage integration.
      Returns:
      this.
    • snowflakeStageType

      public B snowflakeStageType(String snowflakeStageType)
      Categorization of the stage type in Snowflake, which can be 'Internal Named' or 'External Named', indicating whether the stage storage is within Snowflake or in external cloud storage.
      Returns:
      this.
    • sqlDBTSource

      public B sqlDBTSource(IDbtSource sqlDBTSource)
    • sqlDBTSources

      public B sqlDBTSources(Collection<? extends IDbtSource> sqlDBTSources)
    • clearSqlDBTSources

      public B clearSqlDBTSources()
    • sqlDbtModel

      public B sqlDbtModel(IDbtModel sqlDbtModel)
    • sqlDbtModels

      public B sqlDbtModels(Collection<? extends IDbtModel> sqlDbtModels)
    • clearSqlDbtModels

      public B clearSqlDbtModels()
    • sqlStageSchema

      public B sqlStageSchema(ISchema sqlStageSchema)
      Reference to the parent schema that contains this Snowflake stage, establishing the stage's position in the database hierarchy.
      Returns:
      this.
    • tableName

      public B tableName(String tableName)
      Simple name of the table in which this SQL asset exists, or empty if it does not exist within a table.
      Returns:
      this.
    • tableQualifiedName

      public B tableQualifiedName(String tableQualifiedName)
      Unique name of the table in which this SQL asset exists, or empty if it does not exist within a table.
      Returns:
      this.
    • viewName

      public B viewName(String viewName)
      Simple name of the view in which this SQL asset exists, or empty if it does not exist within a view.
      Returns:
      this.
    • viewQualifiedName

      public B viewQualifiedName(String viewQualifiedName)
      Unique name of the view in which this SQL asset exists, or empty if it does not exist within a view.
      Returns:
      this.
    • self

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

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

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