Package com.atlan.model.assets
Class FlowDatasetOperation.FlowDatasetOperationBuilder<C extends FlowDatasetOperation,B extends FlowDatasetOperation.FlowDatasetOperationBuilder<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.FlowDatasetOperation.FlowDatasetOperationBuilder<C,B>
- Enclosing class:
FlowDatasetOperation
public abstract static class FlowDatasetOperation.FlowDatasetOperationBuilder<C extends FlowDatasetOperation,B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C,B>>
extends Asset.AssetBuilder<C,B>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected B
$fillValuesFrom
(C instance) additionalEtlContext
(String additionalEtlContext) Additional Context of the ETL pipeline/notebook which creates the process.adfActivity
(IAdfActivity adfActivity) ADF Activity that is associated with this lineage process.aiDatasetType
(AIDatasetType aiDatasetType) Dataset type for AI Model - dataset process.airflowTask
(IAirflowTask airflowTask) airflowTasks
(Collection<? extends IAirflowTask> airflowTasks) Parsed AST of the code or SQL statements that describe the logic of this process.abstract C
build()
Code that ran within the process.columnProcess
(IColumnProcess columnProcess) columnProcesses
(Collection<? extends IColumnProcess> columnProcesses) fivetranConnector
(IFivetranConnector fivetranConnector) fivetranConnector in which this process exists.flowErrorMessage
(String flowErrorMessage) Optional error message of the flow run.flowFinishedAt
(Long flowFinishedAt) Date and time at which this point in the data processing or orchestration finished.flowFolderName
(String flowFolderName) Simple name of the folder in which this asset is contained.flowFolderQualifiedName
(String flowFolderQualifiedName) Unique name of the folder in which this asset is contained.Unique ID for this flow asset, which will remain constant throughout the lifecycle of the asset.flowOrchestratedBy
(IFlowControlOperation flowOrchestratedBy) Orchestrated control operation that ran these data flows (process).flowProjectName
(String flowProjectName) Simple name of the project in which this asset is contained.flowProjectQualifiedName
(String flowProjectQualifiedName) Unique name of the project in which this asset is contained.flowReusableUnit
(IFlowReusableUnit flowReusableUnit) Reusable unit of dataset operations that are all executed together.flowReusableUnitName
(String flowReusableUnitName) Simple name of the reusable grouping of operations in which this ephemeral data is contained.flowReusableUnitQualifiedName
(String flowReusableUnitQualifiedName) Unique name of the reusable grouping of operations in which this ephemeral data is contained.Unique ID of the flow run, which could change on subsequent runs of the same flow.flowSchedule
(String flowSchedule) Schedule for this point in the data processing or orchestration.flowStartedAt
(Long flowStartedAt) Date and time at which this point in the data processing or orchestration started.flowStatus
(String flowStatus) Overall status of this point in the data processing or orchestration.inputs
(Collection<? extends ICatalog> inputs) matillionComponent
(IMatillionComponent matillionComponent) Matillion component that contains the logic for this lineage process.outputs
(Collection<? extends ICatalog> outputs) parentConnectionProcessQualifiedName
(String parentConnectionProcessQualifiedName) parentConnectionProcessQualifiedNames
(Collection<? extends String> parentConnectionProcessQualifiedNames) powerBIDataflow
(IPowerBIDataflow powerBIDataflow) PowerBI Dataflow that is associated with this lineage process.protected abstract B
self()
sparkJobs
(Collection<? extends ISparkJob> sparkJobs) SQL query that ran to produce the outputs.toString()
Fixed typeName for FlowDatasetOperations.Methods inherited from class com.atlan.model.assets.Asset.AssetBuilder
addStarredBy, adminGroup, adminGroups, adminRole, adminRoles, adminUser, adminUsers, announcementMessage, announcementTitle, announcementType, announcementUpdatedAt, announcementUpdatedBy, anomaloCheck, anomaloChecks, appendAssignedTerm, appendAtlanTag, appendAtlanTag, appendAtlanTags, appendAtlanTags, application, applicationField, applicationFieldQualifiedName, applicationQualifiedName, 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, assetMcIsMonitored, assetMcLastSyncRunAt, assetMcMonitorName, assetMcMonitorNames, assetMcMonitorQualifiedName, assetMcMonitorQualifiedNames, assetMcMonitorScheduleType, assetMcMonitorScheduleTypes, assetMcMonitorStatus, assetMcMonitorStatuses, assetMcMonitorType, assetMcMonitorTypes, assetPoliciesCount, assetPolicyGUID, assetPolicyGUIDs, assetRedirectGUID, assetRedirectGUIDs, assetSodaCheckCount, assetSodaCheckStatuses, assetSodaDQStatus, assetSodaLastScanAt, assetSodaLastSyncRunAt, assetSodaSourceURL, assetTag, assetTags, assetThemeHex, assetUserDefinedType, 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, clearAssetRedirectGUIDs, clearAssetTags, clearAssignedTerms, clearAtlanTagNames, clearAtlanTags, clearCustomMetadataSets, clearDomainGUIDs, 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, 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
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
-
Constructor Details
-
FlowDatasetOperationBuilder
public FlowDatasetOperationBuilder()
-
-
Method Details
-
$fillValuesFrom
- Overrides:
$fillValuesFrom
in classAsset.AssetBuilder<C extends FlowDatasetOperation,
B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C, B>>
-
typeName
Fixed typeName for FlowDatasetOperations.- Overrides:
typeName
in classReference.ReferenceBuilder<C extends FlowDatasetOperation,
B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C, B>> - Returns:
this
.
-
additionalEtlContext
Additional Context of the ETL pipeline/notebook which creates the process.- Returns:
this
.
-
adfActivity
ADF Activity that is associated with this lineage process.- Returns:
this
.
-
aiDatasetType
Dataset type for AI Model - dataset process.- Returns:
this
.
-
airflowTask
-
airflowTasks
-
clearAirflowTasks
-
ast
Parsed AST of the code or SQL statements that describe the logic of this process.- Returns:
this
.
-
code
Code that ran within the process.- Returns:
this
.
-
columnProcess
-
columnProcesses
-
clearColumnProcesses
-
fivetranConnector
fivetranConnector in which this process exists.- Returns:
this
.
-
flowErrorMessage
Optional error message of the flow run.- Returns:
this
.
-
flowFinishedAt
Date and time at which this point in the data processing or orchestration finished.- Returns:
this
.
-
flowFolderName
Simple name of the folder in which this asset is contained.- Returns:
this
.
-
flowFolderQualifiedName
Unique name of the folder in which this asset is contained.- Returns:
this
.
-
flowId
Unique ID for this flow asset, which will remain constant throughout the lifecycle of the asset.- Returns:
this
.
-
flowOrchestratedBy
Orchestrated control operation that ran these data flows (process).- Returns:
this
.
-
flowProjectName
Simple name of the project in which this asset is contained.- Returns:
this
.
-
flowProjectQualifiedName
Unique name of the project in which this asset is contained.- Returns:
this
.
-
flowReusableUnit
Reusable unit of dataset operations that are all executed together.- Returns:
this
.
-
flowReusableUnitName
Simple name of the reusable grouping of operations in which this ephemeral data is contained.- Returns:
this
.
-
flowReusableUnitQualifiedName
Unique name of the reusable grouping of operations in which this ephemeral data is contained.- Returns:
this
.
-
flowRunId
Unique ID of the flow run, which could change on subsequent runs of the same flow.- Returns:
this
.
-
flowSchedule
Schedule for this point in the data processing or orchestration.- Returns:
this
.
-
flowStartedAt
Date and time at which this point in the data processing or orchestration started.- Returns:
this
.
-
flowStatus
Overall status of this point in the data processing or orchestration.- Returns:
this
.
-
input
-
inputs
-
clearInputs
-
matillionComponent
Matillion component that contains the logic for this lineage process.- Returns:
this
.
-
output
-
outputs
-
clearOutputs
-
parentConnectionProcessQualifiedName
-
parentConnectionProcessQualifiedNames
public B parentConnectionProcessQualifiedNames(Collection<? extends String> parentConnectionProcessQualifiedNames) -
clearParentConnectionProcessQualifiedNames
-
powerBIDataflow
PowerBI Dataflow that is associated with this lineage process.- Returns:
this
.
-
sparkJob
-
sparkJobs
-
clearSparkJobs
-
sql
SQL query that ran to produce the outputs.- Returns:
this
.
-
self
- Specified by:
self
in classAsset.AssetBuilder<C extends FlowDatasetOperation,
B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C, B>>
-
build
- Specified by:
build
in classAsset.AssetBuilder<C extends FlowDatasetOperation,
B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C, B>>
-
toString
- Overrides:
toString
in classAsset.AssetBuilder<C extends FlowDatasetOperation,
B extends FlowDatasetOperation.FlowDatasetOperationBuilder<C, B>>
-