Uses of Class
com.hazelcast.pc.config.StageConfig
Packages that use StageConfig
Package
Description
Contains Jet pipeline declarative configuration support.
Contains Jet pipeline declarative configuration parser configuration objects.
Contains the supported Jet sink types by declarative configuration.
Contains the supported Jet source types by declarative configuration.
Contains the supported transform step types by declarative configuration.
-
Uses of StageConfig in com.hazelcast.pc
Methods in com.hazelcast.pc with parameters of type StageConfigModifier and TypeMethodDescriptionstatic <T> com.hazelcast.jet.pipeline.StreamStage<T>Source.maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageSink.sink(Object stage, StageConfig stageConfig) <T> com.hazelcast.jet.pipeline.GeneralStage<T>Source.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStage<R>Transform.transform(com.hazelcast.jet.pipeline.GeneralStage<T> stage, StageConfig stageConfig) -
Uses of StageConfig in com.hazelcast.pc.config
Methods in com.hazelcast.pc.config that return StageConfig -
Uses of StageConfig in com.hazelcast.pc.sinks
Methods in com.hazelcast.pc.sinks with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.SinkStageJdbcSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageKafkaSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageLoggerSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageMapSink.sink(Object stage, StageConfig stageConfig) -
Uses of StageConfig in com.hazelcast.pc.sources
Methods in com.hazelcast.pc.sources with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.GeneralStageFileSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageItemsSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageItemStreamSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageJdbcSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageKafkaSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageMapJournalSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageMapSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) -
Uses of StageConfig in com.hazelcast.pc.transforms
Methods in com.hazelcast.pc.transforms with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.GeneralStage<R>PythonTransform.transform(com.hazelcast.jet.pipeline.GeneralStage<T> stage, StageConfig stageConfig)