Package com.atlan.model.assets
Class FlowDataset.FlowDatasetBuilder<C extends FlowDataset,B extends FlowDataset.FlowDatasetBuilder<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.FlowDataset.FlowDatasetBuilder<C,B>
- Enclosing class:
FlowDataset
public abstract static class FlowDataset.FlowDatasetBuilder<C extends FlowDataset,B extends FlowDataset.FlowDatasetBuilder<C,B>>
extends Asset.AssetBuilder<C,B>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected B
$fillValuesFrom
(C instance) abstract C
build()
flowDetailedBy
(IFlowReusableUnit flowDetailedBy) Reusable unit that details the sub-processing to produce the ephemeral dataset.flowErrorMessage
(String flowErrorMessage) Optional error message of the flow run.flowExpression
(String flowExpression) Logic that is applied, injected or otherwise used as part of producing this ephemeral piece of data.flowField
(IFlowField flowField) flowFieldCount
(Long flowFieldCount) Count of the number of individual fields that make up this ephemeral dataset.flowFields
(Collection<? extends IFlowField> flowFields) 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.flowParentUnit
(IFlowReusableUnit flowParentUnit) Reusable unit in which the ephemeral dataset is contained.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.Query (e.g.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.Type of the ephemeral piece of data.inputToAirflowTask
(IAirflowTask inputToAirflowTask) inputToAirflowTasks
(Collection<? extends IAirflowTask> inputToAirflowTasks) inputToProcess
(ILineageProcess inputToProcess) inputToProcesses
(Collection<? extends ILineageProcess> inputToProcesses) inputToSparkJob
(ISparkJob inputToSparkJob) inputToSparkJobs
(Collection<? extends ISparkJob> inputToSparkJobs) modelImplementedAttribute
(IModelAttribute modelImplementedAttribute) modelImplementedAttributes
(Collection<? extends IModelAttribute> modelImplementedAttributes) modelImplementedEntities
(Collection<? extends IModelEntity> modelImplementedEntities) modelImplementedEntity
(IModelEntity modelImplementedEntity) outputFromAirflowTask
(IAirflowTask outputFromAirflowTask) outputFromAirflowTasks
(Collection<? extends IAirflowTask> outputFromAirflowTasks) outputFromProcess
(ILineageProcess outputFromProcess) outputFromProcesses
(Collection<? extends ILineageProcess> outputFromProcesses) outputFromSparkJob
(ISparkJob outputFromSparkJob) outputFromSparkJobs
(Collection<? extends ISparkJob> outputFromSparkJobs) protected abstract B
self()
toString()
Fixed typeName for FlowDatasets.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
-
FlowDatasetBuilder
public FlowDatasetBuilder()
-
-
Method Details
-
$fillValuesFrom
- Overrides:
$fillValuesFrom
in classAsset.AssetBuilder<C extends FlowDataset,
B extends FlowDataset.FlowDatasetBuilder<C, B>>
-
typeName
Fixed typeName for FlowDatasets.- Overrides:
typeName
in classReference.ReferenceBuilder<C extends FlowDataset,
B extends FlowDataset.FlowDatasetBuilder<C, B>> - Returns:
this
.
-
flowDetailedBy
Reusable unit that details the sub-processing to produce the ephemeral dataset.- Returns:
this
.
-
flowErrorMessage
Optional error message of the flow run.- Returns:
this
.
-
flowExpression
Logic that is applied, injected or otherwise used as part of producing this ephemeral piece of data.- Returns:
this
.
-
flowFieldCount
Count of the number of individual fields that make up this ephemeral dataset.- Returns:
this
.
-
flowField
-
flowFields
-
clearFlowFields
-
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
.
-
flowParentUnit
Reusable unit in which the ephemeral dataset is contained.- 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
.
-
flowQuery
Query (e.g. SQL) that was run to produce this ephemeral piece of data.- 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
.
-
flowType
Type of the ephemeral piece of data.- Returns:
this
.
-
inputToAirflowTask
-
inputToAirflowTasks
-
clearInputToAirflowTasks
-
inputToProcess
-
inputToProcesses
-
clearInputToProcesses
-
inputToSparkJob
-
inputToSparkJobs
-
clearInputToSparkJobs
-
modelImplementedAttribute
-
modelImplementedAttributes
public B modelImplementedAttributes(Collection<? extends IModelAttribute> modelImplementedAttributes) -
clearModelImplementedAttributes
-
modelImplementedEntity
-
modelImplementedEntities
-
clearModelImplementedEntities
-
outputFromAirflowTask
-
outputFromAirflowTasks
-
clearOutputFromAirflowTasks
-
outputFromProcess
-
outputFromProcesses
-
clearOutputFromProcesses
-
outputFromSparkJob
-
outputFromSparkJobs
-
clearOutputFromSparkJobs
-
self
- Specified by:
self
in classAsset.AssetBuilder<C extends FlowDataset,
B extends FlowDataset.FlowDatasetBuilder<C, B>>
-
build
- Specified by:
build
in classAsset.AssetBuilder<C extends FlowDataset,
B extends FlowDataset.FlowDatasetBuilder<C, B>>
-
toString
- Overrides:
toString
in classAsset.AssetBuilder<C extends FlowDataset,
B extends FlowDataset.FlowDatasetBuilder<C, B>>
-