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 |
---|---|
FileSourceBuilder |
FileSourceBuilder.charset(Charset charset)
Sets the character set used to encode the files.
|
static FileSourceBuilder |
Sources.filesBuilder(String directory)
Returns a builder object that offers a step-by-step fluent API to build
a custom source to read files for the Pipeline API.
|
FileSourceBuilder |
FileSourceBuilder.glob(String glob)
Sets the globbing mask, see
getPathMatcher() . |
FileSourceBuilder |
FileSourceBuilder.sharedFileSystem(boolean sharedFileSystem)
Sets if files are in a shared storage visible to all members.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.