Package | Description |
---|---|
com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.hadoop |
Apache Hadoop HDFS read/write support for Hazelcast Jet.
|
com.hazelcast.jet.kafka |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
static <D,T> ProcessorMetaSupplier |
AvroProcessors.readFilesP(String directory,
String glob,
boolean sharedFileSystem,
DistributedSupplier<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier,
DistributedBiFunction<String,? super D,T> mapOutputFn)
Returns a supplier of processors for
AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>) . |
static <D> ProcessorMetaSupplier |
AvroProcessors.writeFilesP(String directoryName,
DistributedSupplier<org.apache.avro.Schema> schemaSupplier,
DistributedSupplier<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
|
Modifier and Type | Method and Description |
---|---|
static ProcessorMetaSupplier |
ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier)
Variant of
forceTotalParallelismOne(ProcessorSupplier, String) where the node
for the supplier will be chosen randomly. |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier,
String partitionKey)
Wraps the provided
ProcessorSupplier into a meta-supplier that
will only use the given ProcessorSupplier on a single node. |
ProcessorMetaSupplier |
Vertex.getMetaSupplier()
Returns this vertex's meta-supplier of processors.
|
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(DistributedFunction<? super Address,? extends ProcessorSupplier> addressToSupplier)
Factory method that creates a
ProcessorMetaSupplier from the
supplied function that maps a cluster member address to a ProcessorSupplier . |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(DistributedFunction<? super Address,? extends ProcessorSupplier> addressToSupplier,
int preferredLocalParallelism)
Factory method that creates a
ProcessorMetaSupplier from the
supplied function that maps a cluster member address to a ProcessorSupplier . |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(DistributedSupplier<? extends Processor> procSupplier)
Factory method that wraps the given
Supplier<Processor>
and uses it as the supplier of all Processor instances. |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(DistributedSupplier<? extends Processor> procSupplier,
int preferredLocalParallelism)
Factory method that wraps the given
Supplier<Processor>
and uses it as the supplier of all Processor instances. |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(ProcessorSupplier procSupplier)
Wraps the provided
ProcessorSupplier into a meta-supplier that
will always return it. |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.of(ProcessorSupplier procSupplier,
int preferredLocalParallelism)
Factory method that wraps the given
ProcessorSupplier and
returns the same instance for each given Address . |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.preferLocalParallelismOne(DistributedSupplier<? extends Processor> procSupplier)
Variant of
preferLocalParallelismOne(ProcessorSupplier) where
the supplied DistributedSupplier<Processor> will be
wrapped into a ProcessorSupplier . |
static ProcessorMetaSupplier |
ProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier supplier)
Wraps the provided
ProcessorSupplier into a meta-supplier that
will always return it. |
Modifier and Type | Method and Description |
---|---|
Vertex |
DAG.newVertex(String name,
ProcessorMetaSupplier metaSupplier)
Creates a vertex from a
ProcessorMetaSupplier and adds it to this DAG. |
Modifier and Type | Method and Description |
---|---|
void |
Vertex.updateMetaSupplier(UnaryOperator<ProcessorMetaSupplier> updateFn)
Applies the provided operator function to the current processor
meta-supplier and replaces it with the one it returns.
|
Constructor and Description |
---|
Vertex(String name,
ProcessorMetaSupplier metaSupplier)
Creates a vertex from a
ProcessorMetaSupplier . |
Modifier and Type | Method and Description |
---|---|
static <S,T> ProcessorMetaSupplier |
SourceProcessors.convenientSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn,
DistributedBiConsumer<? super S,? super SourceBuilder.SourceBuffer<T>> fillBufferFn,
DistributedConsumer<? super S> destroyFn,
int preferredLocalParallelism)
Returns a supplier of processors for a source that the user can create
using the
SourceBuilder . |
static <S,T> ProcessorMetaSupplier |
SourceProcessors.convenientTimestampedSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn,
DistributedBiConsumer<? super S,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn,
WatermarkGenerationParams<? super com.hazelcast.jet.impl.JetEvent<T>> wmParams,
DistributedConsumer<? super S> destroyFn,
int preferredLocalParallelism)
Returns a supplier of processors for a source that the user can create
using the
SourceBuilder . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.mergeMapP(String mapName,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends V> toValueFn,
DistributedBinaryOperator<V> mergeFn)
Returns a supplier of processors for
Sinks.mapWithMerging(String, DistributedFunction, DistributedFunction,
DistributedBinaryOperator) . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.mergeRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends V> toValueFn,
DistributedBinaryOperator<V> mergeFn)
Returns a supplier of processors for
Sinks.remoteMapWithMerging(String, ClientConfig, DistributedFunction,
DistributedFunction, DistributedBinaryOperator) . |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekInputP(DistributedFunction<T,? extends CharSequence> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekInputP(ProcessorMetaSupplier wrapped)
Convenience for
peekInput(toStringFn,
shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function. |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekOutputP(DistributedFunction<? super T,? extends CharSequence> toStringFn,
DistributedPredicate<? super T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekOutputP(ProcessorMetaSupplier wrapped)
Convenience for
peekOutput(toStringFn,
shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function. |
static <K,V> ProcessorMetaSupplier |
DiagnosticProcessors.peekSnapshotP(DistributedFunction<? super Map.Entry<K,V>,? extends CharSequence> toStringFn,
DistributedPredicate<? super Map.Entry<K,V>> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekSnapshotP(ProcessorMetaSupplier wrapped)
Convenience for
peekSnapshot(toStringFn,
shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function. |
static ProcessorMetaSupplier |
SourceProcessors.readCacheP(String cacheName)
Returns a supplier of processors for
Sources.cache(String) . |
static <R> ProcessorMetaSupplier |
SourceProcessors.readFilesP(String directory,
Charset charset,
String glob,
boolean sharedFileSystem,
DistributedBiFunction<? super String,? super String,? extends R> mapOutputFn)
Returns a supplier of processors for
Sources.filesBuilder(java.lang.String) . |
static <T> ProcessorMetaSupplier |
SourceProcessors.readJdbcP(DistributedSupplier<? extends Connection> connectionSupplier,
ToResultSetFunction resultSetFn,
DistributedFunction<? super ResultSet,? extends T> mapOutputFn)
Returns a supplier of processors for
Sources.jdbc(
DistributedSupplier, ToResultSetFunction, DistributedFunction) . |
static <T> ProcessorMetaSupplier |
SourceProcessors.readJdbcP(String connectionURL,
String query,
DistributedFunction<? super ResultSet,? extends T> mapOutputFn)
Returns a supplier of processors for
Sources.jdbc(String, String, DistributedFunction) . |
static ProcessorMetaSupplier |
SourceProcessors.readListP(String listName)
Returns a supplier of processors for
Sources.list(String) . |
static ProcessorMetaSupplier |
SourceProcessors.readMapP(String mapName)
Returns a supplier of processors for
Sources.map(String) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readMapP(String mapName,
Predicate<? super K,? super V> predicate,
DistributedFunction<? super Map.Entry<K,V>,? extends T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readMapP(String mapName,
Predicate<? super K,? super V> predicate,
Projection<? super Map.Entry<K,V>,? extends T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, Projection) . |
static ProcessorMetaSupplier |
SourceProcessors.readRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteCache(String, ClientConfig) . |
static ProcessorMetaSupplier |
SourceProcessors.readRemoteListP(String listName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteList(String, ClientConfig) . |
static ProcessorMetaSupplier |
SourceProcessors.readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
Predicate<? super K,? super V> predicate,
DistributedFunction<? super Map.Entry<K,V>,? extends T> projectionFn)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
Predicate<? super K,? super V> predicate,
Projection<? super Map.Entry<K,V>,? extends T> projection)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, Projection) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.streamCacheP(String cacheName,
DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super T> wmGenParams)
Returns a supplier of processors for
Sources.cacheJournal(String,
DistributedPredicate, DistributedFunction, JournalInitialPosition) . |
static <K,V> ProcessorMetaSupplier |
SourceProcessors.streamCacheP(String cacheName,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams)
Returns a supplier of processors for
Sources.cacheJournal(String, JournalInitialPosition) . |
static ProcessorMetaSupplier |
SourceProcessors.streamFilesP(String watchedDirectory,
Charset charset,
String glob,
boolean sharedFileSystem,
DistributedBiFunction<? super String,? super String,?> mapOutputFn)
Returns a supplier of processors for
Sources.filesBuilder(java.lang.String) . |
static <T> ProcessorMetaSupplier |
SourceProcessors.streamJmsQueueP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier,
DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionFn,
DistributedFunction<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn,
DistributedConsumer<? super javax.jms.Session> flushFn,
DistributedFunction<? super javax.jms.Message,? extends T> projectionFn)
Returns a supplier of processors for
Sources.jmsQueueBuilder(com.hazelcast.jet.function.DistributedSupplier<? extends javax.jms.ConnectionFactory>) . |
static <T> ProcessorMetaSupplier |
SourceProcessors.streamJmsTopicP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier,
DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionFn,
DistributedFunction<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn,
DistributedConsumer<? super javax.jms.Session> flushFn,
DistributedFunction<? super javax.jms.Message,? extends T> projectionFn)
Returns a supplier of processors for
Sources.jmsTopicBuilder(com.hazelcast.jet.function.DistributedSupplier<? extends javax.jms.ConnectionFactory>) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.streamMapP(String mapName,
DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super T> wmGenParams)
Returns a supplier of processors for
Sources.mapJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition) . |
static <K,V> ProcessorMetaSupplier |
SourceProcessors.streamMapP(String mapName,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams)
Returns a supplier of processors for
Sources.mapJournal(String, JournalInitialPosition) )}. |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.streamRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super T> wmGenParams)
Returns a supplier of processors for
Sources.remoteCacheJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition) . |
static <K,V> ProcessorMetaSupplier |
SourceProcessors.streamRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams)
Returns a supplier of processors for
Sources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.streamRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super T> wmGenParams)
Returns a supplier of processors for
Sources.remoteMapJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition) . |
static <K,V> ProcessorMetaSupplier |
SourceProcessors.streamRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
JournalInitialPosition initialPos,
WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams)
Returns a supplier of processors for
Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition) . |
static ProcessorMetaSupplier |
SourceProcessors.streamSocketP(String host,
int port,
Charset charset)
Returns a supplier of processors for
Sources.socket(String, int, Charset) . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateMapP(String mapName,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedBiFunction<? super V,? super T,? extends V> updateFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(String, DistributedFunction, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateMapP(String mapName,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(String, DistributedFunction, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedBiFunction<? super V,? super T,? extends V> updateFn)
Returns a supplier of processors for
Sinks.remoteMapWithUpdating(String, ClientConfig, DistributedFunction
, DistributedBiFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.remoteMapWithEntryProcessor(String, ClientConfig, DistributedFunction,
DistributedFunction) . |
static ProcessorMetaSupplier |
SinkProcessors.writeCacheP(String cacheName)
Returns a supplier of processors for
Sinks.cache(String) . |
static <T> ProcessorMetaSupplier |
SinkProcessors.writeFileP(String directoryName,
DistributedFunction<? super T,? extends String> toStringFn,
Charset charset,
boolean append)
Returns a supplier of processors for
Sinks.filesBuilder(java.lang.String) . |
static <T> ProcessorMetaSupplier |
SinkProcessors.writeJdbcP(String updateQuery,
DistributedSupplier<? extends Connection> connectionSupplier,
DistributedBiConsumer<? super PreparedStatement,? super T> bindFn)
Returns a supplier of processors for
Sinks.jdbc(String, DistributedSupplier, DistributedBiConsumer) . |
static <T> ProcessorMetaSupplier |
SinkProcessors.writeJmsQueueP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier,
DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionF,
DistributedBiFunction<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn,
DistributedBiConsumer<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn,
DistributedConsumer<? super javax.jms.Session> flushFn,
String name)
Returns a supplier of processors for
Sinks.jmsQueueBuilder(com.hazelcast.jet.function.DistributedSupplier<javax.jms.ConnectionFactory>) . |
static <T> ProcessorMetaSupplier |
SinkProcessors.writeJmsTopicP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier,
DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionF,
DistributedBiFunction<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn,
DistributedBiConsumer<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn,
DistributedConsumer<? super javax.jms.Session> flushFn,
String name)
Returns a supplier of processors for
Sinks.jmsTopicBuilder(com.hazelcast.jet.function.DistributedSupplier<javax.jms.ConnectionFactory>) . |
static ProcessorMetaSupplier |
SinkProcessors.writeListP(String listName)
Returns a supplier of processors for
Sinks.list(String) . |
static ProcessorMetaSupplier |
DiagnosticProcessors.writeLoggerP()
Convenience for
DiagnosticProcessors.writeLoggerP(DistributedFunction) that uses
toString() as toStringFn . |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.writeLoggerP(DistributedFunction<T,? extends CharSequence> toStringFn)
Returns a meta-supplier of processors for a sink vertex that logs all
the data items it receives.
|
static ProcessorMetaSupplier |
SinkProcessors.writeMapP(String mapName)
Returns a supplier of processors for
Sinks.map(String) . |
static ProcessorMetaSupplier |
SinkProcessors.writeRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sinks.remoteCache(String, ClientConfig) . |
static ProcessorMetaSupplier |
SinkProcessors.writeRemoteListP(String listName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sinks.remoteList(String, ClientConfig) . |
static ProcessorMetaSupplier |
SinkProcessors.writeRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig)
Returns a supplier of processors for
Sinks.remoteMap(String, ClientConfig) . |
static <T> ProcessorMetaSupplier |
SinkProcessors.writeSocketP(String host,
int port,
DistributedFunction<? super T,? extends String> toStringFn,
Charset charset)
Returns a supplier of processors for
Sinks.socket(String, int) . |
Modifier and Type | Method and Description |
---|---|
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekInputP(DistributedFunction<T,? extends CharSequence> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekInputP(ProcessorMetaSupplier wrapped)
Convenience for
peekInput(toStringFn,
shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function. |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekOutputP(DistributedFunction<? super T,? extends CharSequence> toStringFn,
DistributedPredicate<? super T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekOutputP(ProcessorMetaSupplier wrapped)
Convenience for
peekOutput(toStringFn,
shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function. |
static <K,V> ProcessorMetaSupplier |
DiagnosticProcessors.peekSnapshotP(DistributedFunction<? super Map.Entry<K,V>,? extends CharSequence> toStringFn,
DistributedPredicate<? super Map.Entry<K,V>> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static ProcessorMetaSupplier |
DiagnosticProcessors.peekSnapshotP(ProcessorMetaSupplier wrapped)
Convenience for
peekSnapshot(toStringFn,
shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function. |
Modifier and Type | Method and Description |
---|---|
static Supplier<Processor> |
TestSupport.supplierFrom(ProcessorMetaSupplier supplier)
Wraps the provided
ProcessorMetaSupplier with a Supplier<Processor> that returns processors obtained from it. |
static TestSupport |
TestSupport.verifyProcessor(ProcessorMetaSupplier supplier) |
Modifier and Type | Method and Description |
---|---|
static <E,K,V> ProcessorMetaSupplier |
HdfsProcessors.writeHdfsP(org.apache.hadoop.mapred.JobConf jobConf,
DistributedFunction<? super E,K> extractKeyFn,
DistributedFunction<? super E,V> extractValueFn)
Returns a supplier of processors for
HdfsSinks.hdfs(JobConf, DistributedFunction, DistributedFunction) . |
Modifier and Type | Method and Description |
---|---|
static <K,V,T> ProcessorMetaSupplier |
KafkaProcessors.streamKafkaP(Properties properties,
DistributedFunction<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,? extends T> projectionFn,
WatermarkGenerationParams<? super T> wmGenParams,
String... topics)
Returns a supplier of processors for
KafkaSources.kafka(Properties, DistributedFunction, String...) . |
static <T,K,V> ProcessorMetaSupplier |
KafkaProcessors.writeKafkaP(Properties properties,
DistributedFunction<? super T,? extends org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn)
Returns a supplier of processors for
KafkaSinks.kafka(Properties, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
KafkaProcessors.writeKafkaP(Properties properties,
String topic,
DistributedFunction<? super T,? extends K> extractKeyFn,
DistributedFunction<? super T,? extends V> extractValueFn)
Returns a supplier of processors for
KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction) . |
Modifier and Type | Method and Description |
---|---|
static <T> BatchSource<T> |
Sources.batchFromProcessor(String sourceName,
ProcessorMetaSupplier metaSupplier)
Returns a bounded (batch) source constructed directly from the given
Core API processor meta-supplier.
|
static <T> Sink<T> |
Sinks.fromProcessor(String sinkName,
ProcessorMetaSupplier metaSupplier)
Returns a sink constructed directly from the given Core API processor
meta-supplier.
|
static <T> StreamSource<T> |
Sources.streamFromProcessor(String sourceName,
ProcessorMetaSupplier metaSupplier)
Returns an unbounded (event stream) source constructed directly from the given
Core API processor meta-supplier.
|
Modifier and Type | Method and Description |
---|---|
static <T> StreamSource<T> |
Sources.streamFromProcessorWithWatermarks(String sourceName,
Function<WatermarkGenerationParams<? super T>,ProcessorMetaSupplier> metaSupplierFn)
Returns an unbounded (event stream) source that will use the supplied
function to create processor meta-suppliers as required by the Core API.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.