Package com.hazelcast.pc

Interface Source

All Known Implementing Classes:

FileSource, ItemsSource, ItemStreamSource, JdbcSource, KafkaSource, MapJournalSource, MapSource

public interface Source

Method Summary

Modifier and Type	Method	Description
static <T> StreamStage<T>	maybeApplyTimestamps(StreamSourceStage<T> stage, StageConfig stageConfig)
<T> GeneralStage<T>	source(Pipeline pipeline, StageConfig stageConfig)

Method Details

source

<T> GeneralStage<T> source(Pipeline pipeline,
 StageConfig stageConfig)

maybeApplyTimestamps

static <T> StreamStage<T> maybeApplyTimestamps(StreamSourceStage<T> stage,
 StageConfig stageConfig)