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> com.hazelcast.jet.pipeline.StreamStage<T>
    maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig)
     
    <T> com.hazelcast.jet.pipeline.GeneralStage<T>
    source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
     

  • Method Details

    • source

      <T> com.hazelcast.jet.pipeline.GeneralStage<T> source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)

    • maybeApplyTimestamps

      static <T> com.hazelcast.jet.pipeline.StreamStage<T> maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig)