Uses of Class
com.hazelcast.jet.pipeline.file.FileSourceBuilder
Package | Description |
---|---|
com.hazelcast.jet.pipeline.file |
This package offers the
FileSourceBuilder
which allows you to construct various kinds of Pipeline sources that read from local or distributed files. |
-
Uses of FileSourceBuilder in com.hazelcast.jet.pipeline.file
Methods in com.hazelcast.jet.pipeline.file that return FileSourceBuilder Modifier and Type Method Description static FileSourceBuilder<String>
FileSources. files(String path)
The main entry point to the Unified File Connector.<T_NEW> FileSourceBuilder<T_NEW>
FileSourceBuilder. format(FileFormat<T_NEW> fileFormat)
Set the file format for the source.FileSourceBuilder<T>
FileSourceBuilder. glob(String glob)
Sets a glob pattern to filter the files in the specified directory.FileSourceBuilder<T>
FileSourceBuilder. ignoreFileNotFound(boolean ignoreFileNotFound)
Set to true to ignore no matching files in the directory specified bypath
.FileSourceBuilder<T>
FileSourceBuilder. option(String key, String value)
Specifies an arbitrary option for the underlying source.FileSourceBuilder<T>
FileSourceBuilder. sharedFileSystem(boolean sharedFileSystem)
IfsharedFileSystem
istrue
, Jet will assume all members see the same files.FileSourceBuilder<T>
FileSourceBuilder. useHadoopForLocalFiles(boolean useHadoop)
Specifies that Jet should use Apache Hadoop for files from the local filesystem.