Package com.atlan.model.assets

Class ColumnProcess.ColumnProcessBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<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.ColumnProcess.ColumnProcessBuilder<C,B>

Enclosing class:

ColumnProcess

public abstract static class ColumnProcess.ColumnProcessBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>
extends Asset.AssetBuilder<C,B>

Constructor Summary

Constructors

Constructor	Description
ColumnProcessBuilder()

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.
B	process(ILineageProcess process)	Process in which this task exists.
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 ColumnProcesss.

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

ColumnProcessBuilder

public ColumnProcessBuilder()

Method Details

$fillValuesFrom

protected B $fillValuesFrom(C instance)

Overrides:

$fillValuesFrom in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

typeName

public B typeName(String typeName)

Fixed typeName for ColumnProcesss.

Overrides:

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

process

public B process(ILineageProcess process)

Process in which this task exists.

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 ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

build

public abstract C build()

Specified by:

build in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

toString

public String toString()

Overrides:

toString in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>