Package com.hazelcast.pc.sources

Class MapJournalSource

java.lang.Object

com.hazelcast.pc.sources.MapJournalSource

All Implemented Interfaces:

Source

public class MapJournalSource
extends Object
implements Source

Constructor Summary

Constructors

Constructor	Description
MapJournalSource()

Method Summary

Modifier and Type	Method	Description
com.hazelcast.jet.pipeline.GeneralStage	source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

MapJournalSource

public MapJournalSource()

Method Details

source

public com.hazelcast.jet.pipeline.GeneralStage source(com.hazelcast.jet.pipeline.Pipeline pipeline,
 StageConfig stageConfig)

Specified by:

source in interface Source