Class AmazonS3FileSink

Method Details

• getOutputStream

  public OutputStream getOutputStream()

  Description copied from interface: FileSink

  Opens a new stream to write the file's content; the caller must close it.

  Specified by:

  getOutputStream in interface FileSink

• setName

  public AmazonS3FileSink setName(String name)

  Overrides:

  setName in class AmazonS3File

• setPath

  public AmazonS3FileSink setPath(String path)

  Description copied from class: AmazonS3File

  Sets the key of this file's object within its bucket.

  Overrides:

  setPath in class AmazonS3File

• setBucketName

  public AmazonS3FileSink setBucketName(String bucketName)

  Overrides:

  setBucketName in class AmazonS3File

• setAmazonS3FileSystem

  public AmazonS3FileSink setAmazonS3FileSystem(AmazonS3FileSystem amazonS3FileSystem)

  Overrides:

  setAmazonS3FileSystem in class AmazonS3File

• setCredentialsProvider

  public AmazonS3FileSink setCredentialsProvider(AwsCredentialsProvider credentialsProvider)

  Description copied from class: AmazonS3File

  Sets the AWS SDK credentials provider that this file's AmazonS3FileSystem uses when no CredentialsResolver is set.

  Overrides:

  setCredentialsProvider in class AmazonS3File

• setCredentialsResolver

  public AmazonS3FileSink setCredentialsResolver(CredentialsResolver credentialsResolver)

  Description copied from class: AmazonS3File

  Sets the backend-neutral resolver supplying this file's credentials — resolved on each connection, so rotated secrets are picked up automatically. Takes precedence over AmazonS3File.setCredentialsProvider(AwsCredentialsProvider) and the default provider chain.

  Overrides:

  setCredentialsResolver in class AmazonS3File

• useProfileCredentialsProvider

  public AmazonS3FileSink useProfileCredentialsProvider(String profileName)

  Description copied from class: AmazonS3File

  Authenticates this file's AmazonS3FileSystem using the named profile from the AWS profile files, unless a CredentialsResolver is set, which takes precedence.

  Overrides:

  useProfileCredentialsProvider in class AmazonS3File

• setBasicAWSCredentials

  public AmazonS3FileSink setBasicAWSCredentials(String accessKey, String secretKey)

  Description copied from class: AmazonS3File

  Authenticates this file's AmazonS3FileSystem with the given access key and secret key, replacing its credentials provider, unless a CredentialsResolver is set, which takes precedence.

  Overrides:

  setBasicAWSCredentials in class AmazonS3File

• isAppend

  public boolean isAppend()

  Description copied from interface: FileSink

  Indicates if FileSink.getOutputStream() appends to an existing file instead of replacing it.

  Specified by:

  isAppend in interface FileSink

• toRecord

  public Record toRecord()

  Description copied from interface: RecordSerializable

  Converts this object's state to a record that RecordSerializable.fromRecord(Record) can load.

  Specified by:

  toRecord in interface RecordSerializable

  Overrides:

  toRecord in class AmazonS3File

• fromRecord

  public AmazonS3FileSink fromRecord(Record source)

  Description copied from interface: RecordSerializable

  Loads this instance's state from a record and returns this (for fluid API call chaining). For fluid API call chaining, the overridden method should change the declared return type to its class.

  Specified by:

  fromRecord in interface FileSink

  Specified by:

  fromRecord in interface RecordSerializable

  Overrides:

  fromRecord in class AmazonS3File

  Parameters:

  source -

  Returns:

  this instance.

• toXmlElement

  public Element toXmlElement(Document document)

  Description copied from interface: XmlSerializable

  Returns an element, created with document, describing this object; the default implementation throws a DataException.

  Specified by:

  toXmlElement in interface XmlSerializable

  Overrides:

  toXmlElement in class AmazonS3File

• fromXmlElement

  public AmazonS3FileSink fromXmlElement(Element localFileSinkElement)

  Specified by:

  fromXmlElement in interface XmlSerializable

  Overrides:

  fromXmlElement in class AmazonS3File