Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
FileSinkBuilder<T> |
FileSinkBuilder.append(boolean append)
Sets whether to append (
true ) or overwrite (false )
an existing file. |
FileSinkBuilder<T> |
FileSinkBuilder.charset(Charset charset)
Sets the character set used to encode the files.
|
static <T> FileSinkBuilder<T> |
Sinks.filesBuilder(String directoryName)
Returns a builder object that offers a step-by-step fluent API to build
a custom file sink for the Pipeline API.
|
FileSinkBuilder<T> |
FileSinkBuilder.toStringFn(FunctionEx<? super T,String> toStringFn)
Sets the function which converts the item to its string representation.
|
Copyright © 2020 Hazelcast, Inc.. All rights reserved.