Namespace com.ibm.streamsx.objectstorage.s3
Specialized toolkits - release 4.3.1.0-prod20190605 > com.ibm.streamsx.objectstorage 1.9.2 > com.ibm.streamsx.objectstorage.s3
Operators
- S3ObjectStorageScan: Operator scans for specified key name pattern on a S3 compliant object storage.
- S3ObjectStorageSink: Operator writes objects to S3 compliant object storage.
- S3ObjectStorageSource: Operator reads objects from S3 compliant object storage.
Functions
- createBucket(T): Creates a bucket if it doesn't exist.
- createBucket(T, T): Creates a bucket if it doesn't exist.
- deleteAllObjects(T): Deletes all objects in a bucket.
- deleteBucket(T): Deletes a bucket.
- deleteObject(T, T): Deletes an object in a bucket.
- getObjectMetadata(T, T): Get object metadata.
- getObjectStorageURI(T): Converts the bucket to a URI for the objectStorageURI parameter of the ObjectStorageSource, ObjectStorageScan and ObjectStorageSink operators.
- getProtocolFromURI(T): Extracts the protocol of the URI.
- initialize(T): Initialize S3 client using JSON IAM credentials from IBM Cloud Object Storage service.
- initialize(T, T): Initialize S3 client using JSON IAM credentials from IBM Cloud Object Storage service.
- initialize(T, T, T): Initialize S3 client using basic authentication.
- initialize_cos(T, T): Initialize S3 client using JSON IAM credentials from IBM Cloud Object Storage service.
- initialize_iam(T, T, T): Initialize S3 client using IAM credentials.
- listBuckets(): Lists all bucket names.
- listObjects(T): Lists all object names in a bucket.