## Uses of Interface
com.hazelcast.jet.core.ProcessorMetaSupplier

- Packages that use ProcessorMetaSupplier
  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.

- - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.avro

    Methods in com.hazelcast.jet.avro that return ProcessorMetaSupplier
    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)` Returns a supplier of processors for `AvroSinks.files(java.lang.String, com.hazelcast.jet.function.DistributedSupplier<org.apache.avro.Schema>, com.hazelcast.jet.function.DistributedSupplier<org.apache.avro.io.DatumWriter<R>>)`.

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.core

    Methods in com.hazelcast.jet.core that return ProcessorMetaSupplier
    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.

    Methods in com.hazelcast.jet.core with parameters of type ProcessorMetaSupplier
    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.

    Method parameters in com.hazelcast.jet.core with type arguments of type ProcessorMetaSupplier
    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.

    Constructors in com.hazelcast.jet.core with parameters of type ProcessorMetaSupplier
    Constructor and Description
    `Vertex(String name, ProcessorMetaSupplier metaSupplier)` Creates a vertex from a `ProcessorMetaSupplier`.

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor that return 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, 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, ClientConfig clientConfig)` Returns a supplier of processors for `Sources.remoteCache(String, ClientConfig)`.
    `static ProcessorMetaSupplier` | SourceProcessors.`readRemoteListP(String listName, ClientConfig clientConfig)` Returns a supplier of processors for `Sources.remoteList(String, ClientConfig)`.
    `static ProcessorMetaSupplier` | SourceProcessors.`readRemoteMapP(String mapName, ClientConfig clientConfig)` Returns a supplier of processors for `Sources.remoteMap(String, ClientConfig)`.
    `static <T,K,V> ProcessorMetaSupplier` | SourceProcessors.`readRemoteMapP(String mapName, 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, 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, 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, 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, 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, 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, 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, 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, ClientConfig clientConfig)` Returns a supplier of processors for `Sinks.remoteCache(String, ClientConfig)`.
    `static ProcessorMetaSupplier` | SinkProcessors.`writeRemoteListP(String listName, ClientConfig clientConfig)` Returns a supplier of processors for `Sinks.remoteList(String, ClientConfig)`.
    `static ProcessorMetaSupplier` | SinkProcessors.`writeRemoteMapP(String mapName, 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)`.

    Methods in com.hazelcast.jet.core.processor with parameters of type ProcessorMetaSupplier
    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.

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.core.test

    Methods in com.hazelcast.jet.core.test with parameters of type ProcessorMetaSupplier
    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)`

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.hadoop

    Methods in com.hazelcast.jet.hadoop that return ProcessorMetaSupplier
    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)`.

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.kafka

    Methods in com.hazelcast.jet.kafka that return ProcessorMetaSupplier
    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)`.

  - ### Uses of ProcessorMetaSupplier in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline with parameters of type ProcessorMetaSupplier
    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.

    Method parameters in com.hazelcast.jet.pipeline with type arguments of type ProcessorMetaSupplier
    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. All rights reserved.