| 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.charset(Charset charset)
Sets the character set used to encode the files. 
 | 
FileSinkBuilder<T> | 
FileSinkBuilder.exactlyOnce(boolean enable)
Enables or disables the exactly-once behavior of the sink using
 two-phase commit of state snapshots. 
 | 
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.rollByDate(String datePattern)
Sets a date pattern that will be included in the file name. 
 | 
FileSinkBuilder<T> | 
FileSinkBuilder.rollByFileSize(long maxFileSize)
Enables rolling by file size. 
 | 
FileSinkBuilder<T> | 
FileSinkBuilder.toStringFn(FunctionEx<? super T,String> toStringFn)
Sets the function which converts the item to its string representation. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.