Uses of Class
com.hazelcast.jet.pipeline.RemoteMapSourceBuilder
Packages that use RemoteMapSourceBuilder
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of RemoteMapSourceBuilder in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return RemoteMapSourceBuilderModifier and TypeMethodDescriptionRemoteMapSourceBuilder.clientConfig(ClientConfig clientConfig) Set the client configuration to use to connect to the remote cluster.RemoteMapSourceBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef) Set the data connection name to use to connect to the remote cluster.Set the predicate to apply at the source.<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 <K,V> RemoteMapSourceBuilder<K, V, Map.Entry<K, V>> Sources.remoteMapBuilder(String mapName) Returns a builder to build a source that fetches entries from a remote HazelcastIMapwith the specified name.