Package com.atlan.model.assets

Class LineageProcess.LineageProcessBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<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.LineageProcess.LineageProcessBuilder<C,B>

Enclosing class:

LineageProcess

public abstract static class LineageProcess.LineageProcessBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<C,B>>
extends Asset.AssetBuilder<C,B>

Constructor Summary

Constructors

Constructor	Description
LineageProcessBuilder()

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	aiDatasetType(AIDatasetType aiDatasetType)	Dataset type for AI Model - dataset 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.
B	bigqueryRoutine(IBigqueryRoutine bigqueryRoutine)
B	bigqueryRoutines(Collection<? extends IBigqueryRoutine> bigqueryRoutines)
abstract C	build()
B	clearAirflowTasks()
B	clearBigqueryRoutines()
B	clearColumnProcesses()
B	clearFabricActivities()
B	clearInputs()
B	clearOutputs()
B	clearParentConnectionProcessQualifiedNames()
B	clearSparkJobs()
B	clearSqlFunctions()
B	clearSqlProcedures()
B	code(String code)	Code that ran within the process.
B	columnProcess(IColumnProcess columnProcess)
B	columnProcesses(Collection<? extends IColumnProcess> columnProcesses)
B	fabricActivities(Collection<? extends IFabricActivity> fabricActivities)
B	fabricActivity(IFabricActivity fabricActivity)
B	fivetranConnector(IFivetranConnector fivetranConnector)	fivetranConnector in which this process exists.
B	flowOrchestratedBy(IFlowControlOperation flowOrchestratedBy)	Orchestrated control operation that ran these data flows (process).
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	parentConnectionProcessQualifiedName(String parentConnectionProcessQualifiedName)
B	parentConnectionProcessQualifiedNames(Collection<? extends String> parentConnectionProcessQualifiedNames)
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.
B	sqlFunction(IFunction sqlFunction)
B	sqlFunctions(Collection<? extends IFunction> sqlFunctions)
B	sqlProcedure(IProcedure sqlProcedure)
B	sqlProcedures(Collection<? extends IProcedure> sqlProcedures)
String	toString()
B	typeName(String typeName)	Fixed typeName for LineageProcesss.

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

addAssetGCPDataplexAspect, addAssetGCPDataplexAspectField, addStarredBy, adminGroup, adminGroups, adminRole, adminRoles, adminUser, adminUsers, announcementMessage, announcementTitle, announcementType, announcementUpdatedAt, announcementUpdatedBy, anomaloCheck, anomaloChecks, appendAssignedTerm, appendAtlanTag, appendAtlanTag, appendAtlanTags, appendAtlanTags, application, applicationField, applicationFieldQualifiedName, applicationQualifiedName, assetAiGeneratedDescription, assetAiGeneratedDescriptionConfidence, assetAiGeneratedDescriptionReasoning, assetAnnouncementExpiredAt, 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, assetDQFreshnessExpectation, assetDQFreshnessValue, assetDQManualRunStatus, assetDQResult, assetDQRowScopeFilterColumnQualifiedName, assetDQRuleAttachedDimension, assetDQRuleAttachedDimensions, assetDQRuleAttachedRuleType, assetDQRuleAttachedRuleTypes, assetDQRuleFailedCount, assetDQRuleFailedDimension, assetDQRuleFailedDimensions, assetDQRuleFailedRuleType, assetDQRuleFailedRuleTypes, assetDQRuleLastRunAt, assetDQRulePassedCount, assetDQRulePassedDimension, assetDQRulePassedDimensions, assetDQRulePassedRuleType, assetDQRulePassedRuleTypes, assetDQRuleResultTag, assetDQRuleResultTags, assetDQRuleTotalCount, assetDQScheduleCrontab, assetDQScheduleSourceSyncedAt, assetDQScheduleSourceSyncErrorCode, assetDQScheduleSourceSyncErrorMessage, assetDQScheduleSourceSyncRawError, assetDQScheduleSourceSyncStatus, assetDQScheduleTimeZone, assetDQScheduleType, assetExternalDQMetadataDetail, assetExternalDQMetadataDetails, assetGCPDataplexAspectFieldList, assetGCPDataplexAspectList, assetGCPDataplexMetadataDetails, assetIcon, assetImmutaRequestType, assetImmutaRequestUrl, assetInternalPopularityScore, assetMcAlertQualifiedName, assetMcAlertQualifiedNames, assetMcIncidentName, assetMcIncidentNames, assetMcIncidentPriorities, assetMcIncidentPriority, assetMcIncidentQualifiedName, assetMcIncidentQualifiedNames, assetMcIncidentSeverities, assetMcIncidentSeverity, assetMcIncidentState, assetMcIncidentStates, assetMcIncidentSubType, assetMcIncidentSubTypes, assetMcIncidentType, assetMcIncidentTypes, assetMcIsMonitored, assetMcLastSyncRunAt, assetMcMonitorName, assetMcMonitorNames, assetMcMonitorQualifiedName, assetMcMonitorQualifiedNames, assetMcMonitorScheduleType, assetMcMonitorScheduleTypes, assetMcMonitorStatus, assetMcMonitorStatuses, assetMcMonitorType, assetMcMonitorTypes, assetPoliciesCount, assetPolicyGUID, assetPolicyGUIDs, assetRedirectGUID, assetRedirectGUIDs, assetSmusMetadataFormDetail, assetSmusMetadataFormDetails, assetSmusMetadataFormKeyValueDetail, assetSmusMetadataFormKeyValueDetails, assetSmusMetadataFormName, assetSmusMetadataFormNames, assetSodaCheckCount, assetSodaCheckStatuses, assetSodaDQStatus, assetSodaLastScanAt, assetSodaLastSyncRunAt, assetSodaSourceURL, assetSourceId, assetSourceReadme, assetSpaceName, assetSpaceQualifiedName, assetTag, assetTags, assetThemeHex, assetUserDefinedType, assignedTerm, assignedTerms, atlanTag, atlanTagName, atlanTagNames, atlanTags, certificateStatus, certificateStatusMessage, certificateUpdatedAt, certificateUpdatedBy, clearAdminGroups, clearAdminRoles, clearAdminUsers, clearAnomaloChecks, clearAssetAnomaloAppliedCheckTypes, clearAssetAnomaloFailedCheckTypes, clearAssetDbtTags, clearAssetDQRuleAttachedDimensions, clearAssetDQRuleAttachedRuleTypes, clearAssetDQRuleFailedDimensions, clearAssetDQRuleFailedRuleTypes, clearAssetDQRulePassedDimensions, clearAssetDQRulePassedRuleTypes, clearAssetDQRuleResultTags, clearAssetExternalDQMetadataDetails, clearAssetGCPDataplexAspectFieldList, clearAssetGCPDataplexAspectList, clearAssetMcAlertQualifiedNames, clearAssetMcIncidentNames, clearAssetMcIncidentPriorities, clearAssetMcIncidentQualifiedNames, clearAssetMcIncidentSeverities, clearAssetMcIncidentStates, clearAssetMcIncidentSubTypes, clearAssetMcIncidentTypes, clearAssetMcMonitorNames, clearAssetMcMonitorQualifiedNames, clearAssetMcMonitorScheduleTypes, clearAssetMcMonitorStatuses, clearAssetMcMonitorTypes, clearAssetPolicyGUIDs, clearAssetRedirectGUIDs, clearAssetSmusMetadataFormDetails, clearAssetSmusMetadataFormKeyValueDetails, clearAssetSmusMetadataFormNames, clearAssetTags, clearAssignedTerms, clearAtlanTagNames, clearAtlanTags, clearCustomMetadataSets, clearDomainGUIDs, clearDqBaseDatasetRules, clearDqReferenceDatasetRules, clearFiles, clearInputPortDataProducts, clearLinks, clearMcIncidents, clearMcMonitors, clearMeaningNames, clearMeanings, clearMetrics, clearNonCompliantAssetPolicyGUIDs, clearNullFields, clearOutputPortDataProducts, clearOutputProductGUIDs, clearOwnerGroups, clearOwnerUsers, clearPendingTasks, clearProductGUIDs, clearSchemaRegistrySubjects, clearSodaChecks, clearSourceQueryComputeCostRecords, clearSourceQueryComputeCosts, clearSourceReadExpensiveQueryRecords, clearSourceReadPopularQueryRecords, clearSourceReadRecentUserRecords, clearSourceReadRecentUsers, clearSourceReadSlowQueryRecords, clearSourceReadTopUserRecords, clearSourceReadTopUsers, clearStarredBy, clearStarredDetails, clearUserDefRelationshipFroms, clearUserDefRelationshipTos, clearViewerGroups, clearViewerUsers, connectionName, connectionQualifiedName, connectorName, connectorType, createdBy, createTime, customConnectorType, customMetadata, customMetadataSets, dataContractLatest, dataContractLatestCertified, dbtQualifiedName, deleteHandler, depth, description, displayName, domainGUID, domainGUIDs, dqBaseDatasetRule, dqBaseDatasetRules, dqReferenceDatasetRule, dqReferenceDatasetRules, file, files, hasContract, hasLineage, iconUrl, 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, outputProductGUID, outputProductGUIDs, ownerGroup, ownerGroups, ownerUser, ownerUsers, pendingTask, pendingTasks, popularityScore, productGUID, productGUIDs, qualifiedName, readme, removeAnnouncement, removeAssignedTerm, removeAssignedTerms, removeAtlanTag, removeAtlanTags, 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

addedRelationshipAttributes, clearCustomAttributes, clearLabels, completeObject, customAttribute, customAttributes, displayText, docId, entityStatus, guid, label, labels, relationshipAttributes, relationshipGuid, relationshipStatus, relationshipType, removedRelationshipAttributes, 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

LineageProcessBuilder

public LineageProcessBuilder()

Method Details

$fillValuesFrom

protected B $fillValuesFrom(C instance)

Overrides:

$fillValuesFrom in class Asset.AssetBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<C,B>>

typeName

public B typeName(String typeName)

Fixed typeName for LineageProcesss.

Overrides:

typeName in class Reference.ReferenceBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<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.

aiDatasetType

public B aiDatasetType(AIDatasetType aiDatasetType)

Dataset type for AI Model - dataset 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.

bigqueryRoutine

public B bigqueryRoutine(IBigqueryRoutine bigqueryRoutine)

bigqueryRoutines

public B bigqueryRoutines(Collection<? extends IBigqueryRoutine> bigqueryRoutines)

clearBigqueryRoutines

public B clearBigqueryRoutines()

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()

fabricActivity

public B fabricActivity(IFabricActivity fabricActivity)

fabricActivities

public B fabricActivities(Collection<? extends IFabricActivity> fabricActivities)

clearFabricActivities

public B clearFabricActivities()

fivetranConnector

public B fivetranConnector(IFivetranConnector fivetranConnector)

fivetranConnector in which this process exists.

Returns:

this.

flowOrchestratedBy

public B flowOrchestratedBy(IFlowControlOperation flowOrchestratedBy)

Orchestrated control operation that ran these data flows (process).

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()

parentConnectionProcessQualifiedName

public B parentConnectionProcessQualifiedName(String parentConnectionProcessQualifiedName)

parentConnectionProcessQualifiedNames

public B parentConnectionProcessQualifiedNames(Collection<? extends String> parentConnectionProcessQualifiedNames)

clearParentConnectionProcessQualifiedNames

public B clearParentConnectionProcessQualifiedNames()

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.

sqlFunction

public B sqlFunction(IFunction sqlFunction)

sqlFunctions

public B sqlFunctions(Collection<? extends IFunction> sqlFunctions)

clearSqlFunctions

public B clearSqlFunctions()

sqlProcedure

public B sqlProcedure(IProcedure sqlProcedure)

sqlProcedures

public B sqlProcedures(Collection<? extends IProcedure> sqlProcedures)

clearSqlProcedures

public B clearSqlProcedures()

self

protected abstract B self()

Specified by:

self in class Asset.AssetBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<C,B>>

build

public abstract C build()

Specified by:

build in class Asset.AssetBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<C,B>>

toString

public String toString()

Overrides:

toString in class Asset.AssetBuilder<C extends LineageProcess,B extends LineageProcess.LineageProcessBuilder<C,B>>