Uses of Class
com.hazelcast.jet.pipeline.FileSinkBuilder
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of FileSinkBuilder in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return FileSinkBuilder Modifier and Type Method 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.