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 © 2021 Hazelcast, Inc.. All rights reserved.