Index

C S 
All Classes and Interfaces|All Packages

C

com.hazelcast.jet.s3 - package com.hazelcast.jet.s3
AWS S3 read/write support for Hazelcast Jet.

S

s3(String, SupplierEx<? extends S3Client>) - Static method in class com.hazelcast.jet.s3.S3Sinks
Convenience for S3Sinks.s3(String, String, Charset, SupplierEx, FunctionEx) Uses Object.toString() to convert the items to lines.
s3(String, String, Charset, SupplierEx<? extends S3Client>, FunctionEx<? super T, String>) - Static method in class com.hazelcast.jet.s3.S3Sinks
Creates an AWS S3 Sink which writes items to files into the given bucket.
s3(List<String>, String, SupplierEx<? extends S3Client>) - Static method in class com.hazelcast.jet.s3.S3Sources
Convenience for s3(List, String, Charset, SupplierEx, BiFunctionEx).
s3(List<String>, String, SupplierEx<? extends S3Client>, FunctionEx<? super InputStream, ? extends Stream<I>>, BiFunctionEx<String, ? super I, ? extends T>) - Static method in class com.hazelcast.jet.s3.S3Sources
Creates an AWS S3 BatchSource which lists all the objects in the bucket-list using given prefix, reads them using provided readFileFn, transforms each read item to the desired output object using given mapFn and emits them to downstream.
s3(List<String>, String, SupplierEx<? extends S3Client>, TriFunction<? super InputStream, String, String, ? extends Stream<I>>, BiFunctionEx<String, ? super I, ? extends T>) - Static method in class com.hazelcast.jet.s3.S3Sources
Creates an AWS S3 BatchSource which lists all the objects in the bucket-list using given prefix, reads them using provided readFileFn, transforms each read item to the desired output object using given mapFn and emits them to downstream.
s3(List<String>, String, Charset, SupplierEx<? extends S3Client>, BiFunctionEx<String, String, ? extends T>) - Static method in class com.hazelcast.jet.s3.S3Sources
Creates an AWS S3 BatchSource which lists all the objects in the bucket-list using given prefix, reads them line by line, transforms each line to the desired output object using given mapFn and emits them to downstream.
S3Sinks - Class in com.hazelcast.jet.s3
Contains factory methods for creating AWS S3 sinks.
S3Sources - Class in com.hazelcast.jet.s3
Contains factory methods for creating AWS S3 sources.
C S 
All Classes and Interfaces|All Packages