Uses of Interface
com.hazelcast.jet.pipeline.BatchSource

Packages that use BatchSource

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of BatchSource in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return BatchSource

Modifier and Type	Method and Description
static <T> BatchSource<T>	Sources.batchFromProcessor(String sourceName, ProcessorMetaSupplier metaSupplier) Returns a bounded (batch) source constructed directly from the given Core API processor meta-supplier.
static <K,V> BatchSource<Map.Entry<K,V>>	Sources.cache(String cacheName) Returns a source that fetches entries from the Hazelcast ICache with the specified name and emits them as Map.Entry.
static BatchSource<String>	Sources.files(String directory) Convenience for the full version of readFiles which uses UTF-8 encoding, matches all the files in the directory and emits lines of text in the files.
static <R> BatchSource<R>	Sources.files(String directory, Charset charset, String glob, DistributedBiFunction<String,String,? extends R> mapOutputFn) A source that emits lines from files in a directory (but not its subdirectories.
static <T> BatchSource<T>	Sources.list(String listName) Returns a source that emits items retrieved from a Hazelcast IList.
static <K,V> BatchSource<Map.Entry<K,V>>	Sources.map(String mapName) Returns a source that fetches entries from a local Hazelcast IMap with the specified name and emits them as Map.Entry.
static <T,K,V> BatchSource<T>	Sources.map(String mapName, Predicate<K,V> predicate, DistributedFunction<Map.Entry<K,V>,T> projectionFn) Convenience for Sources.map(String, Predicate, Projection) which uses a DistributedFunction as the projection function.
static <T,K,V> BatchSource<T>	Sources.map(String mapName, Predicate<K,V> predicate, Projection<Map.Entry<K,V>,T> projection) Returns a source that fetches entries from a local Hazelcast IMap with the specified name.
static <K,V> BatchSource<Map.Entry<K,V>>	Sources.remoteCache(String cacheName, ClientConfig clientConfig) Returns a source that fetches entries from the Hazelcast ICache with the specified name in a remote cluster identified by the supplied ClientConfig and emits them as Map.Entry.
static <T> BatchSource<T>	Sources.remoteList(String listName, ClientConfig clientConfig) Returns a source that emits items retrieved from a Hazelcast IList in a remote cluster identified by the supplied ClientConfig.
static <K,V> BatchSource<Map.Entry<K,V>>	Sources.remoteMap(String mapName, ClientConfig clientConfig) Returns a source that fetches entries from the Hazelcast IMap with the specified name in a remote cluster identified by the supplied ClientConfig and emits them as Map.Entry.
static <T,K,V> BatchSource<T>	Sources.remoteMap(String mapName, ClientConfig clientConfig, Predicate<K,V> predicate, DistributedFunction<Map.Entry<K,V>,T> projectionFn) Convenience for Sources.remoteMap(String, ClientConfig, Predicate, Projection) which use a DistributedFunction as the projection function.
static <T,K,V> BatchSource<T>	Sources.remoteMap(String mapName, ClientConfig clientConfig, Predicate<K,V> predicate, Projection<Map.Entry<K,V>,T> projection) Returns a source that fetches entries from a remote Hazelcast IMap with the specified name in a remote cluster identified by the supplied ClientConfig.

Methods in com.hazelcast.jet.pipeline with parameters of type BatchSource

Modifier and Type	Method and Description
<T> BatchStage<T>	Pipeline.drawFrom(BatchSource<? extends T> source) Returns a pipeline stage that represents a bounded (batch) data source.

Uses of BatchSource in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream with parameters of type BatchSource

Modifier and Type	Method and Description
static <T> DistributedStream<T>	DistributedStream.fromSource(JetInstance instance, BatchSource<T> source, boolean isOrdered) Returns a distributed Stream with the given BatchSource as the source.