Class FivetranConnector.FivetranConnectorBuilder<C extends FivetranConnector,B extends FivetranConnector.FivetranConnectorBuilder<C,B>>

Enclosing class:
FivetranConnector

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

    • FivetranConnectorBuilder

      public FivetranConnectorBuilder()
  • Method Details

    • $fillValuesFrom

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

      public B typeName(String typeName)
      Fixed typeName for FivetranConnectors.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends FivetranConnector,B extends FivetranConnector.FivetranConnectorBuilder<C,B>>
      Returns:
      this.
    • applicationContainer

      public B applicationContainer(IApplicationContainer applicationContainer)
      ApplicationContainer asset containing this Catalog asset.
      Returns:
      this.
    • assetApplicationQualifiedName

      public B assetApplicationQualifiedName(String assetApplicationQualifiedName)
      Qualified name of the Application Container that contains this asset.
      Returns:
      this.
    • fivetranConnectorCreditsUsed

      public B fivetranConnectorCreditsUsed(Double fivetranConnectorCreditsUsed)
      Total credits used by this destination
      Returns:
      this.
    • fivetranConnectorDestinationName

      public B fivetranConnectorDestinationName(String fivetranConnectorDestinationName)
      Destination name added by the user on Fivetran
      Returns:
      this.
    • fivetranConnectorDestinationType

      public B fivetranConnectorDestinationType(String fivetranConnectorDestinationType)
      Type of destination on Fivetran. Eg: redshift, bigquery etc.
      Returns:
      this.
    • fivetranConnectorDestinationURL

      public B fivetranConnectorDestinationURL(String fivetranConnectorDestinationURL)
      URL to open the destination details on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncExtractTimeSeconds

      public B fivetranConnectorLastSyncExtractTimeSeconds(Double fivetranConnectorLastSyncExtractTimeSeconds)
      Extract time in seconds in the latest sync on fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncExtractVolumeMegabytes

      public B fivetranConnectorLastSyncExtractVolumeMegabytes(Double fivetranConnectorLastSyncExtractVolumeMegabytes)
      Extracted data volume in metabytes in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncFinishedAt

      public B fivetranConnectorLastSyncFinishedAt(Long fivetranConnectorLastSyncFinishedAt)
      Timestamp (epoch) when the latest sync finished on Fivetran, in milliseconds
      Returns:
      this.
    • fivetranConnectorLastSyncId

      public B fivetranConnectorLastSyncId(String fivetranConnectorLastSyncId)
      ID of the latest sync
      Returns:
      this.
    • fivetranConnectorLastSyncLoadTimeSeconds

      public B fivetranConnectorLastSyncLoadTimeSeconds(Double fivetranConnectorLastSyncLoadTimeSeconds)
      Load time in seconds in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncLoadVolumeMegabytes

      public B fivetranConnectorLastSyncLoadVolumeMegabytes(Double fivetranConnectorLastSyncLoadVolumeMegabytes)
      Loaded data volume in metabytes in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncProcessTimeSeconds

      public B fivetranConnectorLastSyncProcessTimeSeconds(Double fivetranConnectorLastSyncProcessTimeSeconds)
      Process time in seconds in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncProcessVolumeMegabytes

      public B fivetranConnectorLastSyncProcessVolumeMegabytes(Double fivetranConnectorLastSyncProcessVolumeMegabytes)
      Process volume in metabytes in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncReason

      public B fivetranConnectorLastSyncReason(String fivetranConnectorLastSyncReason)
      Failure reason for the latest sync on Fivetran. If status is FAILURE, this is the description of the reason why the sync failed. If status is FAILURE_WITH_TASK, this is the description of the Error. If status is RESCHEDULED, this is the description of the reason why the sync is rescheduled.
      Returns:
      this.
    • fivetranConnectorLastSyncRescheduledAt

      public B fivetranConnectorLastSyncRescheduledAt(Long fivetranConnectorLastSyncRescheduledAt)
      Timestamp (epoch) at which the latest sync is rescheduled at on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncStartedAt

      public B fivetranConnectorLastSyncStartedAt(Long fivetranConnectorLastSyncStartedAt)
      Timestamp (epoch) when the latest sync started on Fivetran, in milliseconds
      Returns:
      this.
    • fivetranConnectorLastSyncTablesSynced

      public B fivetranConnectorLastSyncTablesSynced(Long fivetranConnectorLastSyncTablesSynced)
      Number of tables synced in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorLastSyncTaskType

      public B fivetranConnectorLastSyncTaskType(String fivetranConnectorLastSyncTaskType)
      Failure task type for the latest sync on Fivetran. If status is FAILURE_WITH_TASK or RESCHEDULED, this field displays the type of the Error that caused the failure or rescheduling, respectively, e.g., reconnect, update_service_account, etc.
      Returns:
      this.
    • fivetranConnectorLastSyncTotalTimeSeconds

      public B fivetranConnectorLastSyncTotalTimeSeconds(Double fivetranConnectorLastSyncTotalTimeSeconds)
      Total sync time in seconds in the latest sync on Fivetran
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsChangePercentageFree

      public B fivetranConnectorMonthlyActiveRowsChangePercentageFree(Double fivetranConnectorMonthlyActiveRowsChangePercentageFree)
      Increase in the percentage of free MAR compared to the previous month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsChangePercentagePaid

      public B fivetranConnectorMonthlyActiveRowsChangePercentagePaid(Double fivetranConnectorMonthlyActiveRowsChangePercentagePaid)
      Increase in the percentage of paid MAR compared to the previous month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsChangePercentageTotal

      public B fivetranConnectorMonthlyActiveRowsChangePercentageTotal(Double fivetranConnectorMonthlyActiveRowsChangePercentageTotal)
      Increase in the percentage of total MAR compared to the previous month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsFree

      public B fivetranConnectorMonthlyActiveRowsFree(Long fivetranConnectorMonthlyActiveRowsFree)
      Free Monthly Active Rows used by the connector in the past month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsFreePercentageOfAccount

      public B fivetranConnectorMonthlyActiveRowsFreePercentageOfAccount(Double fivetranConnectorMonthlyActiveRowsFreePercentageOfAccount)
      Percentage of the account's total free MAR used by this connector
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsPaid

      public B fivetranConnectorMonthlyActiveRowsPaid(Long fivetranConnectorMonthlyActiveRowsPaid)
      Paid Monthly Active Rows used by the connector in the past month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsPaidPercentageOfAccount

      public B fivetranConnectorMonthlyActiveRowsPaidPercentageOfAccount(Double fivetranConnectorMonthlyActiveRowsPaidPercentageOfAccount)
      Percentage of the account's total paid MAR used by this connector
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsTotal

      public B fivetranConnectorMonthlyActiveRowsTotal(Long fivetranConnectorMonthlyActiveRowsTotal)
      Total Monthly Active Rows used by the connector in the past month
      Returns:
      this.
    • fivetranConnectorMonthlyActiveRowsTotalPercentageOfAccount

      public B fivetranConnectorMonthlyActiveRowsTotalPercentageOfAccount(Double fivetranConnectorMonthlyActiveRowsTotalPercentageOfAccount)
      Percentage of the account's total MAR used by this connector
      Returns:
      this.
    • fivetranConnectorName

      public B fivetranConnectorName(String fivetranConnectorName)
      Connector name added by the user on Fivetran
      Returns:
      this.
    • fivetranConnectorSyncFrequency

      public B fivetranConnectorSyncFrequency(String fivetranConnectorSyncFrequency)
      Sync frequency for the connector in number of hours. Eg: Every 6 hours
      Returns:
      this.
    • fivetranConnectorSyncPaused

      public B fivetranConnectorSyncPaused(Boolean fivetranConnectorSyncPaused)
      Boolean to indicate whether the sync for this connector is paused or not
      Returns:
      this.
    • fivetranConnectorSyncSetupOn

      public B fivetranConnectorSyncSetupOn(Long fivetranConnectorSyncSetupOn)
      Timestamp (epoch) on which the connector was setup on Fivetran, in milliseconds
      Returns:
      this.
    • fivetranConnectorSyncSetupUserEmail

      public B fivetranConnectorSyncSetupUserEmail(String fivetranConnectorSyncSetupUserEmail)
      Email ID of the user who setpu the connector on Fivetran
      Returns:
      this.
    • fivetranConnectorSyncSetupUserFullName

      public B fivetranConnectorSyncSetupUserFullName(String fivetranConnectorSyncSetupUserFullName)
      Full name of the user who setup the connector on Fivetran
      Returns:
      this.
    • fivetranConnectorTopTablesByMAR

      public B fivetranConnectorTopTablesByMAR(String fivetranConnectorTopTablesByMAR)
      Total five tables sorted by MAR synced by this connector
      Returns:
      this.
    • fivetranConnectorTotalTablesSynced

      public B fivetranConnectorTotalTablesSynced(Long fivetranConnectorTotalTablesSynced)
      Total number of tables synced by this connector
      Returns:
      this.
    • fivetranConnectorType

      public B fivetranConnectorType(String fivetranConnectorType)
      Type of connector on Fivetran. Eg: snowflake, google_analytics, notion etc.
      Returns:
      this.
    • fivetranConnectorURL

      public B fivetranConnectorURL(String fivetranConnectorURL)
      URL to open the connector details on Fivetran
      Returns:
      this.
    • fivetranConnectorUsageCost

      public B fivetranConnectorUsageCost(Double fivetranConnectorUsageCost)
      Total usage cost by this destination
      Returns:
      this.
    • fivetranLastSyncRecordsUpdated

      public B fivetranLastSyncRecordsUpdated(Long fivetranLastSyncRecordsUpdated)
      Number of records updated in the latest sync on Fivetran
      Returns:
      this.
    • fivetranLastSyncStatus

      public B fivetranLastSyncStatus(FivetranConnectorStatus fivetranLastSyncStatus)
      Status of the latest sync on Fivetran.
      Returns:
      this.
    • fivetranWorkflowName

      public B fivetranWorkflowName(String fivetranWorkflowName)
      Name of the atlan fivetran workflow that updated this asset
      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()
    • 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()
    • process

      public B process(ILineageProcess process)
    • processes

      public B processes(Collection<? extends ILineageProcess> processes)
    • clearProcesses

      public B clearProcesses()
    • self

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

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

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