Package com.atlan.model.assets

Class BIProcess.BIProcessBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>

java.lang.Object

com.atlan.model.core.AtlanObject.AtlanObjectBuilder<C,B>

com.atlan.model.relations.Reference.ReferenceBuilder<C,B>

com.atlan.model.assets.Asset.AssetBuilder<C,B>

com.atlan.model.assets.BIProcess.BIProcessBuilder<C,B>

Enclosing class:

BIProcess

public abstract static class BIProcess.BIProcessBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>
extends Asset.AssetBuilder<C,B>

Constructor Summary

Constructors

Constructor	Description
BIProcessBuilder()

Method Summary

Modifier and Type	Method	Description
protected B	$fillValuesFrom(C instance)
B	additionalEtlContext(String additionalEtlContext)	Additional Context of the ETL pipeline/notebook which creates the process.
B	adfActivity(IAdfActivity adfActivity)	ADF Activity that is associated with this lineage process.
B	airflowTask(IAirflowTask airflowTask)
B	airflowTasks(Collection<? extends IAirflowTask> airflowTasks)
B	ast(String ast)	Parsed AST of the code or SQL statements that describe the logic of this process.
abstract C	build()
B	clearAirflowTasks()
B	clearColumnProcesses()
B	clearInputs()
B	clearOutputs()
B	clearSparkJobs()
B	code(String code)	Code that ran within the process.
B	columnProcess(IColumnProcess columnProcess)
B	columnProcesses(Collection<? extends IColumnProcess> columnProcesses)
B	fivetranConnector(IFivetranConnector fivetranConnector)	fivetranConnector in which this process exists.
B	input(ICatalog input)
B	inputs(Collection<? extends ICatalog> inputs)
B	matillionComponent(IMatillionComponent matillionComponent)	Matillion component that contains the logic for this lineage process.
B	output(ICatalog output)
B	outputs(Collection<? extends ICatalog> outputs)
B	powerBIDataflow(IPowerBIDataflow powerBIDataflow)	PowerBI Dataflow that is associated with this lineage process.
protected abstract B	self()
B	sparkJob(ISparkJob sparkJob)
B	sparkJobs(Collection<? extends ISparkJob> sparkJobs)
B	sql(String sql)	SQL query that ran to produce the outputs.
String	toString()
B	typeName(String typeName)	Fixed typeName for BIProcesss.

Methods inherited from class com.atlan.model.assets.Asset.AssetBuilder

addStarredBy, adminGroup, adminGroups, adminRole, adminRoles, adminUser, adminUsers, announcementMessage, announcementTitle, announcementType, announcementUpdatedAt, announcementUpdatedBy, anomaloCheck, anomaloChecks, assetAnomaloAppliedCheckType, assetAnomaloAppliedCheckTypes, assetAnomaloCheckCount, assetAnomaloCheckStatuses, assetAnomaloDQStatus, assetAnomaloFailedCheckCount, assetAnomaloFailedCheckType, assetAnomaloFailedCheckTypes, assetAnomaloLastCheckRunAt, assetAnomaloSourceUrl, assetCoverImage, assetDbtAccountName, assetDbtAlias, assetDbtEnvironmentDbtVersion, assetDbtEnvironmentName, assetDbtJobLastRun, assetDbtJobLastRunArtifactS3Path, assetDbtJobLastRunArtifactsSaved, assetDbtJobLastRunCreatedAt, assetDbtJobLastRunDequedAt, assetDbtJobLastRunExecutedByThreadId, assetDbtJobLastRunGitBranch, assetDbtJobLastRunGitSha, assetDbtJobLastRunHasDocsGenerated, assetDbtJobLastRunHasSourcesGenerated, assetDbtJobLastRunNotificationsSent, assetDbtJobLastRunOwnerThreadId, assetDbtJobLastRunQueuedDuration, assetDbtJobLastRunQueuedDurationHumanized, assetDbtJobLastRunRunDuration, assetDbtJobLastRunRunDurationHumanized, assetDbtJobLastRunStartedAt, assetDbtJobLastRunStatusMessage, assetDbtJobLastRunTotalDuration, assetDbtJobLastRunTotalDurationHumanized, assetDbtJobLastRunUpdatedAt, assetDbtJobLastRunUrl, assetDbtJobName, assetDbtJobNextRun, assetDbtJobNextRunHumanized, assetDbtJobSchedule, assetDbtJobScheduleCronHumanized, assetDbtJobStatus, assetDbtMeta, assetDbtPackageName, assetDbtProjectName, assetDbtSemanticLayerProxyUrl, assetDbtSourceFreshnessCriteria, assetDbtTag, assetDbtTags, assetDbtTestStatus, assetDbtUniqueId, assetDbtWorkflowLastUpdated, assetIcon, assetMcAlertQualifiedName, assetMcAlertQualifiedNames, assetMcIncidentName, assetMcIncidentNames, assetMcIncidentPriorities, assetMcIncidentPriority, assetMcIncidentQualifiedName, assetMcIncidentQualifiedNames, assetMcIncidentSeverities, assetMcIncidentSeverity, assetMcIncidentState, assetMcIncidentStates, assetMcIncidentSubType, assetMcIncidentSubTypes, assetMcIncidentType, assetMcIncidentTypes, assetMcLastSyncRunAt, assetMcMonitorName, assetMcMonitorNames, assetMcMonitorQualifiedName, assetMcMonitorQualifiedNames, assetMcMonitorScheduleType, assetMcMonitorScheduleTypes, assetMcMonitorStatus, assetMcMonitorStatuses, assetMcMonitorType, assetMcMonitorTypes, assetPoliciesCount, assetPolicyGUID, assetPolicyGUIDs, assetSodaCheckCount, assetSodaCheckStatuses, assetSodaDQStatus, assetSodaLastScanAt, assetSodaLastSyncRunAt, assetSodaSourceURL, assetTag, assetTags, assetThemeHex, assignedTerm, assignedTerms, atlanTag, atlanTagName, atlanTagNames, atlanTags, certificateStatus, certificateStatusMessage, certificateUpdatedAt, certificateUpdatedBy, clearAdminGroups, clearAdminRoles, clearAdminUsers, clearAnomaloChecks, clearAssetAnomaloAppliedCheckTypes, clearAssetAnomaloFailedCheckTypes, clearAssetDbtTags, clearAssetMcAlertQualifiedNames, clearAssetMcIncidentNames, clearAssetMcIncidentPriorities, clearAssetMcIncidentQualifiedNames, clearAssetMcIncidentSeverities, clearAssetMcIncidentStates, clearAssetMcIncidentSubTypes, clearAssetMcIncidentTypes, clearAssetMcMonitorNames, clearAssetMcMonitorQualifiedNames, clearAssetMcMonitorScheduleTypes, clearAssetMcMonitorStatuses, clearAssetMcMonitorTypes, clearAssetPolicyGUIDs, clearAssetTags, clearAssignedTerms, clearAtlanTagNames, clearAtlanTags, clearCustomMetadataSets, clearDomainGUIDs, clearFiles, clearInputPortDataProducts, clearLinks, clearMcIncidents, clearMcMonitors, clearMeaningNames, clearMeanings, clearMetrics, clearNonCompliantAssetPolicyGUIDs, clearNullFields, clearOutputPortDataProducts, clearOwnerGroups, clearOwnerUsers, clearPendingTasks, clearSchemaRegistrySubjects, clearSodaChecks, clearSourceQueryComputeCostRecords, clearSourceQueryComputeCosts, clearSourceReadExpensiveQueryRecords, clearSourceReadPopularQueryRecords, clearSourceReadRecentUserRecords, clearSourceReadRecentUsers, clearSourceReadSlowQueryRecords, clearSourceReadTopUserRecords, clearSourceReadTopUsers, clearStarredBy, clearStarredDetails, clearUserDefRelationshipFroms, clearUserDefRelationshipTos, clearViewerGroups, clearViewerUsers, connectionName, connectionQualifiedName, connectorType, createdBy, createTime, customMetadata, customMetadataSets, dataContractLatest, dataContractLatestCertified, dbtQualifiedName, deleteHandler, depth, description, displayName, domainGUID, domainGUIDs, file, files, hasContract, hasLineage, immediateDownstream, immediateUpstream, inputPortDataProduct, inputPortDataProducts, isAIGenerated, isDiscoverable, isEditable, isIncomplete, isPartial, lastRowChangedAt, lastSyncRun, lastSyncRunAt, lastSyncWorkflowName, lexicographicalSortOrder, link, links, mcIncident, mcIncidents, mcMonitor, mcMonitors, meaning, meaningName, meaningNames, meanings, metric, metrics, name, nonCompliantAssetPolicyGUID, nonCompliantAssetPolicyGUIDs, nullField, nullFields, outputPortDataProduct, outputPortDataProducts, ownerGroup, ownerGroups, ownerUser, ownerUsers, pendingTask, pendingTasks, popularityScore, qualifiedName, readme, removeAnnouncement, removeAssignedTerms, removeAtlanTags, removeCertificate, removeCustomMetadata, removeDescription, removeOwners, removeUserDescription, sampleDataUrl, schemaRegistrySubject, schemaRegistrySubjects, sodaCheck, sodaChecks, sourceCostUnit, sourceCreatedAt, sourceCreatedBy, sourceEmbedURL, sourceLastReadAt, sourceOwners, sourceQueryComputeCost, sourceQueryComputeCostRecord, sourceQueryComputeCostRecords, sourceQueryComputeCosts, sourceReadCount, sourceReadExpensiveQueryRecord, sourceReadExpensiveQueryRecords, sourceReadPopularQueryRecord, sourceReadPopularQueryRecords, sourceReadQueryCost, sourceReadRecentUser, sourceReadRecentUserRecord, sourceReadRecentUserRecords, sourceReadRecentUsers, sourceReadSlowQueryRecord, sourceReadSlowQueryRecords, sourceReadTopUser, sourceReadTopUserRecord, sourceReadTopUserRecords, sourceReadTopUsers, sourceReadUserCount, sourceTotalCost, sourceUpdatedAt, sourceUpdatedBy, sourceURL, starredBy, starredCount, starredDetail, starredDetails, status, subType, tenantId, updatedBy, updateTime, userDefRelationshipFrom, userDefRelationshipFroms, userDefRelationshipTo, userDefRelationshipTos, userDescription, viewerGroup, viewerGroups, viewerUser, viewerUsers, viewScore

Methods inherited from class com.atlan.model.relations.Reference.ReferenceBuilder

clearCustomAttributes, clearLabels, completeObject, customAttribute, customAttributes, displayText, entityStatus, guid, label, labels, relationshipAttributes, relationshipGuid, relationshipStatus, relationshipType, semantic, uniqueAttributes

Methods inherited from class com.atlan.model.core.AtlanObject.AtlanObjectBuilder

rawJsonObject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

BIProcessBuilder

public BIProcessBuilder()

Method Details

$fillValuesFrom

protected B $fillValuesFrom(C instance)

Overrides:

$fillValuesFrom in class Asset.AssetBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>

typeName

public B typeName(String typeName)

Fixed typeName for BIProcesss.

Overrides:

typeName in class Reference.ReferenceBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>

Returns:

this.

additionalEtlContext

public B additionalEtlContext(String additionalEtlContext)

Additional Context of the ETL pipeline/notebook which creates the process.

Returns:

this.

adfActivity

public B adfActivity(IAdfActivity adfActivity)

ADF Activity that is associated with this lineage process.

Returns:

this.

airflowTask

public B airflowTask(IAirflowTask airflowTask)

airflowTasks

public B airflowTasks(Collection<? extends IAirflowTask> airflowTasks)

clearAirflowTasks

public B clearAirflowTasks()

ast

public B ast(String ast)

Parsed AST of the code or SQL statements that describe the logic of this process.

Returns:

this.

code

public B code(String code)

Code that ran within the process.

Returns:

this.

columnProcess

public B columnProcess(IColumnProcess columnProcess)

columnProcesses

public B columnProcesses(Collection<? extends IColumnProcess> columnProcesses)

clearColumnProcesses

public B clearColumnProcesses()

fivetranConnector

public B fivetranConnector(IFivetranConnector fivetranConnector)

fivetranConnector in which this process exists.

Returns:

this.

input

public B input(ICatalog input)

inputs

public B inputs(Collection<? extends ICatalog> inputs)

clearInputs

public B clearInputs()

matillionComponent

public B matillionComponent(IMatillionComponent matillionComponent)

Matillion component that contains the logic for this lineage process.

Returns:

this.

output

public B output(ICatalog output)

outputs

public B outputs(Collection<? extends ICatalog> outputs)

clearOutputs

public B clearOutputs()

powerBIDataflow

public B powerBIDataflow(IPowerBIDataflow powerBIDataflow)

PowerBI Dataflow that is associated with this lineage process.

Returns:

this.

sparkJob

public B sparkJob(ISparkJob sparkJob)

sparkJobs

public B sparkJobs(Collection<? extends ISparkJob> sparkJobs)

clearSparkJobs

public B clearSparkJobs()

sql

public B sql(String sql)

SQL query that ran to produce the outputs.

Returns:

this.

self

protected abstract B self()

Specified by:

self in class Asset.AssetBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>

build

public abstract C build()

Specified by:

build in class Asset.AssetBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>

toString

public String toString()

Overrides:

toString in class Asset.AssetBuilder<C extends BIProcess,B extends BIProcess.BIProcessBuilder<C,B>>