public class S3WordCount extends Object
For more details about the word count pipeline itself, please see the JavaDoc
WordCount class in
S3Sources.s3(List, String, Charset, SupplierEx, BiFunctionEx)
is a source that can be used for reading from an S3 bucket with the given
credentials. The files in the input bucket will be split among Jet
S3Sinks.s3(String, String, Charset, SupplierEx, FunctionEx)
writes the output to the given output bucket, with each
processor writing to a file within the bucket. The files are
identified by a prefix (if provided) and followed by the global processor index.
|Constructor and Description|
Copyright © 2020 Hazelcast, Inc.. All rights reserved.