public final class SourceProcessors extends Object
package-level documentation
.Modifier and Type | Method and Description |
---|---|
static ProcessorMetaSupplier |
readCacheP(String cacheName)
Returns a supplier of processors for
Sources.cache(String) . |
static ProcessorMetaSupplier |
readFilesP(String directory,
Charset charset,
String glob)
Returns a supplier of processors for
Sources.files(String, Charset, String) . |
static ProcessorMetaSupplier |
readListP(String listName)
Returns a supplier of processors for
Sources.list(String) . |
static ProcessorMetaSupplier |
readMapP(String mapName)
Returns a supplier of processors for
Sources.map(String) . |
static <K,V,T> ProcessorMetaSupplier |
readMapP(String mapName,
com.hazelcast.query.Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, DistributedFunction) }. |
static <K,V,T> ProcessorMetaSupplier |
readMapP(String mapName,
com.hazelcast.query.Predicate<K,V> predicate,
com.hazelcast.projection.Projection<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, Projection) }. |
static ProcessorMetaSupplier |
readRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteCache(String, ClientConfig) . |
static ProcessorMetaSupplier |
readRemoteListP(String listName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteList(String, ClientConfig) . |
static ProcessorMetaSupplier |
readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig) . |
static <K,V,T> ProcessorMetaSupplier |
readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
com.hazelcast.query.Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, DistributedFunction) . |
static <K,V,T> ProcessorMetaSupplier |
readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
com.hazelcast.query.Predicate<K,V> predicate,
com.hazelcast.projection.Projection<Map.Entry<K,V>,T> projection)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, Projection) . |
static ProcessorMetaSupplier |
streamCacheP(String cacheName,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.cacheJournal(String, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
streamCacheP(String cacheName,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, boolean) . |
static ProcessorMetaSupplier |
streamFilesP(String watchedDirectory,
Charset charset,
String glob)
Returns a supplier of processors for
Sources.fileWatcher(String, Charset, String) . |
static ProcessorMetaSupplier |
streamMapP(String mapName,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.mapJournal(String, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
streamMapP(String mapName,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.mapJournal(String, DistributedPredicate, DistributedFunction, boolean) . |
static ProcessorMetaSupplier |
streamRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteCacheJournal(String, ClientConfig, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
streamRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteCacheJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
) . |
static ProcessorMetaSupplier |
streamRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteMapJournal(String, ClientConfig, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
streamRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteMapJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
) . |
static ProcessorMetaSupplier |
streamSocketP(String host,
int port,
Charset charset)
Returns a supplier of processors for
Sources.socket(String, int, Charset) . |
@Nonnull public static ProcessorMetaSupplier readMapP(@Nonnull String mapName)
Sources.map(String)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier readMapP(@Nonnull String mapName, @Nonnull com.hazelcast.query.Predicate<K,V> predicate, @Nonnull com.hazelcast.projection.Projection<Map.Entry<K,V>,T> projectionFn)
Sources.map(String, Predicate, Projection)
}.@Nonnull public static <K,V,T> ProcessorMetaSupplier readMapP(@Nonnull String mapName, @Nonnull com.hazelcast.query.Predicate<K,V> predicate, @Nonnull DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Sources.map(String, Predicate, DistributedFunction)
}.@Nonnull public static ProcessorMetaSupplier streamMapP(@Nonnull String mapName, boolean startFromLatestSequence)
Sources.mapJournal(String, boolean)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier streamMapP(@Nonnull String mapName, @Nullable DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate, @Nullable DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection, boolean startFromLatestSequence)
Sources.mapJournal(String, DistributedPredicate, DistributedFunction, boolean)
.@Nonnull public static ProcessorMetaSupplier readRemoteMapP(@Nonnull String mapName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig)
Sources.remoteMap(String, ClientConfig)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier readRemoteMapP(@Nonnull String mapName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, @Nonnull com.hazelcast.query.Predicate<K,V> predicate, @Nonnull com.hazelcast.projection.Projection<Map.Entry<K,V>,T> projection)
Sources.remoteMap(String, ClientConfig, Predicate, Projection)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier readRemoteMapP(@Nonnull String mapName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, @Nonnull com.hazelcast.query.Predicate<K,V> predicate, @Nonnull DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Sources.remoteMap(String, ClientConfig, Predicate, DistributedFunction)
.@Nonnull public static ProcessorMetaSupplier streamRemoteMapP(@Nonnull String mapName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, boolean startFromLatestSequence)
Sources.remoteMapJournal(String, ClientConfig, boolean)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier streamRemoteMapP(@Nonnull String mapName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, @Nullable DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate, @Nullable DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection, boolean startFromLatestSequence)
Sources.remoteMapJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
)
.@Nonnull public static ProcessorMetaSupplier readCacheP(@Nonnull String cacheName)
Sources.cache(String)
.@Nonnull public static ProcessorMetaSupplier streamCacheP(@Nonnull String cacheName, boolean startFromLatestSequence)
Sources.cacheJournal(String, boolean)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier streamCacheP(@Nonnull String cacheName, @Nullable DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate, @Nullable DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection, boolean startFromLatestSequence)
Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, boolean)
.@Nonnull public static ProcessorMetaSupplier readRemoteCacheP(@Nonnull String cacheName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig)
Sources.remoteCache(String, ClientConfig)
.@Nonnull public static ProcessorMetaSupplier streamRemoteCacheP(@Nonnull String cacheName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, boolean startFromLatestSequence)
Sources.remoteCacheJournal(String, ClientConfig, boolean)
.@Nonnull public static <K,V,T> ProcessorMetaSupplier streamRemoteCacheP(@Nonnull String cacheName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig, @Nullable DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate, @Nullable DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection, boolean startFromLatestSequence)
Sources.remoteCacheJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
)
.@Nonnull public static ProcessorMetaSupplier readListP(@Nonnull String listName)
Sources.list(String)
.@Nonnull public static ProcessorMetaSupplier readRemoteListP(@Nonnull String listName, @Nonnull com.hazelcast.client.config.ClientConfig clientConfig)
Sources.remoteList(String, ClientConfig)
.@Nonnull public static ProcessorMetaSupplier streamSocketP(@Nonnull String host, int port, @Nonnull Charset charset)
Sources.socket(String, int, Charset)
.@Nonnull public static ProcessorMetaSupplier readFilesP(@Nonnull String directory, @Nonnull Charset charset, @Nonnull String glob)
Sources.files(String, Charset, String)
.public static ProcessorMetaSupplier streamFilesP(@Nonnull String watchedDirectory, @Nonnull Charset charset, @Nonnull String glob)
Sources.fileWatcher(String, Charset, String)
.Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.