public class S3WordCount extends Object
For more details about the word count pipeline itself, please see the JavaDoc
for the WordCount
class in wordcount
sample.
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
processors.
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 |
---|
S3WordCount() |
public static void main(String[] args) throws IOException
IOException
Copyright © 2019 Hazelcast, Inc.. All rights reserved.