com.hazelcast.connector

Class Hz3Sources

java.lang.Object

com.hazelcast.connector.Hz3Sources

public final class Hz3Sources
extends Object

Sources to connect to Hazelcast 3 cluster TODO documentation how to use

Method Summary

Modifier and Type	Method and Description
static ProcessorSupplier	readRemoteMapP(String mapName, String clientXml) Returns a supplier of processors for Sources.remoteMap(String, ClientConfig).
static <K,V> BatchSource<Map.Entry<K,V>>	remoteMap(String mapName, String clientXml) Returns a source that fetches entries from the Hazelcast IMap with the specified name in a remote cluster identified by the supplied XML configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

remoteMap

@Nonnull
public static <K,V> BatchSource<Map.Entry<K,V>> remoteMap(@Nonnull
                                                                   String mapName,
                                                                   @Nonnull
                                                                   String clientXml)

Returns a source that fetches entries from the Hazelcast IMap with the specified name in a remote cluster identified by the supplied XML configuration.

Parameters:

mapName - name of the map

clientXml - client configuration for the remote cluster

readRemoteMapP

@Nonnull
public static ProcessorSupplier readRemoteMapP(@Nonnull
                                                        String mapName,
                                                        @Nonnull
                                                        String clientXml)

Returns a supplier of processors for Sources.remoteMap(String, ClientConfig).