Class S3Object.S3ObjectBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>

Enclosing class:
S3Object

public abstract static class S3Object.S3ObjectBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>> extends Asset.AssetBuilder<C,B>
  • Constructor Details

    • S3ObjectBuilder

      public S3ObjectBuilder()
  • Method Details

    • $fillValuesFrom

      protected B $fillValuesFrom(C instance)
      Overrides:
      $fillValuesFrom in class Asset.AssetBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>
    • typeName

      public B typeName(String typeName)
      Fixed typeName for S3Objects.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>
      Returns:
      this.
    • applicationContainer

      public B applicationContainer(IApplicationContainer applicationContainer)
      ApplicationContainer asset containing this Catalog asset.
      Returns:
      this.
    • assetApplicationQualifiedName

      public B assetApplicationQualifiedName(String assetApplicationQualifiedName)
      Qualified name of the Application Container that contains this asset.
      Returns:
      this.
    • awsAccountId

      public B awsAccountId(String awsAccountId)
      12-digit number that uniquely identifies an AWS account.
      Returns:
      this.
    • awsArn

      public B awsArn(String awsArn)
      Amazon Resource Name (ARN) for this asset. This uniquely identifies the asset in AWS, and thus must be unique across all AWS asset instances.
      Returns:
      this.
    • awsOwnerId

      public B awsOwnerId(String awsOwnerId)
      Root user's ID.
      Returns:
      this.
    • awsOwnerName

      public B awsOwnerName(String awsOwnerName)
      Root user's name.
      Returns:
      this.
    • awsPartition

      public B awsPartition(String awsPartition)
      Group of AWS region and service objects.
      Returns:
      this.
    • awsRegion

      public B awsRegion(String awsRegion)
      Physical region where the data center in which the asset exists is clustered.
      Returns:
      this.
    • awsResourceId

      public B awsResourceId(String awsResourceId)
      Unique resource ID assigned when a new resource is created.
      Returns:
      this.
    • awsService

      public B awsService(String awsService)
      Type of service in which the asset exists.
      Returns:
      this.
    • awsTag

      public B awsTag(AwsTag awsTag)
    • awsTags

      public B awsTags(Collection<? extends AwsTag> awsTags)
    • clearAwsTags

      public B clearAwsTags()
    • bucket

      public B bucket(IS3Bucket bucket)
      S3 bucket in which the object exists.
      Returns:
      this.
    • inputToAirflowTask

      public B inputToAirflowTask(IAirflowTask inputToAirflowTask)
    • inputToAirflowTasks

      public B inputToAirflowTasks(Collection<? extends IAirflowTask> inputToAirflowTasks)
    • clearInputToAirflowTasks

      public B clearInputToAirflowTasks()
    • inputToProcess

      public B inputToProcess(ILineageProcess inputToProcess)
    • inputToProcesses

      public B inputToProcesses(Collection<? extends ILineageProcess> inputToProcesses)
    • clearInputToProcesses

      public B clearInputToProcesses()
    • inputToSparkJob

      public B inputToSparkJob(ISparkJob inputToSparkJob)
    • inputToSparkJobs

      public B inputToSparkJobs(Collection<? extends ISparkJob> inputToSparkJobs)
    • clearInputToSparkJobs

      public B clearInputToSparkJobs()
    • modelImplementedEntity

      public B modelImplementedEntity(IModelEntity modelImplementedEntity)
    • modelImplementedEntities

      public B modelImplementedEntities(Collection<? extends IModelEntity> modelImplementedEntities)
    • clearModelImplementedEntities

      public B clearModelImplementedEntities()
    • outputFromAirflowTask

      public B outputFromAirflowTask(IAirflowTask outputFromAirflowTask)
    • outputFromAirflowTasks

      public B outputFromAirflowTasks(Collection<? extends IAirflowTask> outputFromAirflowTasks)
    • clearOutputFromAirflowTasks

      public B clearOutputFromAirflowTasks()
    • outputFromProcess

      public B outputFromProcess(ILineageProcess outputFromProcess)
    • outputFromProcesses

      public B outputFromProcesses(Collection<? extends ILineageProcess> outputFromProcesses)
    • clearOutputFromProcesses

      public B clearOutputFromProcesses()
    • outputFromSparkJob

      public B outputFromSparkJob(ISparkJob outputFromSparkJob)
    • outputFromSparkJobs

      public B outputFromSparkJobs(Collection<? extends ISparkJob> outputFromSparkJobs)
    • clearOutputFromSparkJobs

      public B clearOutputFromSparkJobs()
    • s3BucketName

      public B s3BucketName(String s3BucketName)
      Simple name of the bucket in which this object exists.
      Returns:
      this.
    • s3BucketQualifiedName

      public B s3BucketQualifiedName(String s3BucketQualifiedName)
      Unique name of the bucket in which this object exists.
      Returns:
      this.
    • s3ETag

      public B s3ETag(String s3ETag)
      Entity tag for the asset. An entity tag is a hash of the object and represents changes to the contents of an object only, not its metadata.
      Returns:
      this.
    • s3Encryption

      public B s3Encryption(String s3Encryption)
      TBC
      Returns:
      this.
    • s3ObjectContentDisposition

      public B s3ObjectContentDisposition(String s3ObjectContentDisposition)
      Information about how this object's content should be presented.
      Returns:
      this.
    • s3ObjectContentType

      public B s3ObjectContentType(String s3ObjectContentType)
      Type of content in this object, for example: text/plain, application/json, etc.
      Returns:
      this.
    • s3ObjectKey

      public B s3ObjectKey(String s3ObjectKey)
      Unique identity of this object in an S3 bucket. This is usually the concatenation of any prefix (folder) in the S3 bucket with the name of the object (file) itself.
      Returns:
      this.
    • s3ObjectLastModifiedTime

      public B s3ObjectLastModifiedTime(Long s3ObjectLastModifiedTime)
      Time (epoch) at which this object was last updated, in milliseconds, or when it was created if it has never been modified.
      Returns:
      this.
    • s3ObjectSize

      public B s3ObjectSize(Long s3ObjectSize)
      Object size in bytes.
      Returns:
      this.
    • s3ObjectStorageClass

      public B s3ObjectStorageClass(String s3ObjectStorageClass)
      Storage class used for storing this object, for example: standard, intelligent-tiering, glacier, etc.
      Returns:
      this.
    • s3ObjectVersionId

      public B s3ObjectVersionId(String s3ObjectVersionId)
      Version of this object. This is only applicable when versioning is enabled on the bucket in which this object exists.
      Returns:
      this.
    • self

      protected abstract B self()
      Specified by:
      self in class Asset.AssetBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>
    • build

      public abstract C build()
      Specified by:
      build in class Asset.AssetBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>
    • toString

      public String toString()
      Overrides:
      toString in class Asset.AssetBuilder<C extends S3Object,B extends S3Object.S3ObjectBuilder<C,B>>