Uses of Class
com.hazelcast.jet.pipeline.FileSinkBuilder
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of FileSinkBuilder in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionSets the character set used to encode the files.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.rollByDate
(String datePattern) Sets a date pattern that will be included in the file name.FileSinkBuilder.rollByFileSize
(long maxFileSize) Enables rolling by file size.FileSinkBuilder.toStringFn
(FunctionEx<? super T, String> toStringFn) Sets the function which converts the item to its string representation.