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. |
Modifier and Type | Method and 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 by
path . |
FileSourceBuilder<T> |
FileSourceBuilder.option(String key,
String value)
Specifies an arbitrary option for the underlying source.
|
FileSourceBuilder<T> |
FileSourceBuilder.sharedFileSystem(boolean sharedFileSystem)
If
sharedFileSystem is true , 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.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.