Uses of Interface
com.hazelcast.projection.Projection
Packages that use 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
Methods in com.hazelcast.jet.core.processor with parameters of type ProjectionModifier 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
Methods in com.hazelcast.jet.pipeline with parameters of type ProjectionModifier 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 HazelcastIMapwith 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 HazelcastIMapwith 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
Methods in com.hazelcast.map with parameters of type ProjectionModifier 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
Methods in com.hazelcast.projection that return ProjectionModifier 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.