Hazelcast Jet Sources.remoteMap

Giriş

İmzası şöyle

public static <K, V> BatchSource<Entry<K, V>> remoteMap(
  String mapName,
  ClientConfig clientConfig
)

public static <T, K, V> BatchSource<T> remoteMap(
  String mapName,
  ClientConfig clientConfig,
  Predicate<K, V> predicate,
  Projection<? super Entry<K, V>, ? extends T> projection
)

public static <K, V> BatchSource<Entry<K, V>> remoteMap(
  String mapName,
  DataConnectionRef dataConnectionRef
)

public static <T, K, V> BatchSource<T> remoteMap(
  String mapName,
  DataConnectionRef dataConnectionRef,
  Predicate<K, V> predicate,
  Projection<? super Entry<K, V>, ? extends T> projection
)

Altta şöyle yapar

1. RemoteMapQueryReaderFunction : ReadMapOrCacheP : com.hazelcast.jet.impl.connector.Reader ile okuma yapar

2. RemoteMapReaderFunction : RemoteMapReader : Entry<Data, Data> olarak okur