Uses of Interface
com.hazelcast.projection.Projection
Package
Description
Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains Hazelcast map module classes.
Contains classes related to projections.
-
Uses of Projection in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T,
K, V> ProcessorMetaSupplier SourceProcessors.readMapP
(String mapName, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a supplier of processors forSources.map(String, Predicate, Projection)
. -
Uses of Projection in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <T,
K, V> BatchSource<T> Sources.map
(IMap<? extends K, ? extends V> map, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from the given HazelcastIMap
.static <T,
K, V> BatchSource<T> Sources.map
(String mapName, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from a local HazelcastIMap
with the specified name.<T_NEW> RemoteMapSourceBuilder<K,
V, T_NEW> RemoteMapSourceBuilder.projection
(Projection<? super Map.Entry<K, V>, ? extends T_NEW> projection) Set the projection to apply at the source.static <T,
K, V> BatchSource<T> Sources.remoteMap
(String mapName, ClientConfig clientConfig, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from a remote HazelcastIMap
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <T,
K, V> BatchSource<T> Sources.remoteMap
(String mapName, DataConnectionRef dataConnectionRef, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) The same as theSources.remoteMap(String, ClientConfig, Predicate, Projection)
method. -
Uses of Projection in com.hazelcast.map
Modifier and TypeMethodDescription<R> Collection<R>
IMap.project
(Projection<? super Map.Entry<K, V>, R> projection) Applies the projection logic on all map entries and returns the result<R> Collection<R>
Applies the projection logic on map entries filtered with the Predicated and returns the result -
Uses of Projection in com.hazelcast.projection
Modifier and TypeMethodDescriptionstatic <T> Projection<T,
T> Projections.identity()
Returns a projection that does no transformation.static <I> Projection<I,
Object[]> Projections.multiAttribute
(String... attributePaths) Returns a projection that extracts the value of the givenattributePaths
.static <I,
O> Projection<I, O> Projections.singleAttribute
(String attributePath) Returns a projection that extracts the value of the givenattributePath
.