Uses of Class
com.logicalclocks.hsfs.beam.engine.BeamProducer

Packages that use BeamProducer

Package	Description
com.logicalclocks.hsfs.beam
com.logicalclocks.hsfs.beam.engine

Uses of BeamProducer in com.logicalclocks.hsfs.beam

Methods in com.logicalclocks.hsfs.beam that return BeamProducer

Modifier and Type	Method	Description
BeamProducer	StreamFeatureGroup.insertStream()	Ingest a feature data to the online feature store using Beam Pipeline object.
BeamProducer	StreamFeatureGroup.insertStream(Map<String,String> writeOptions)

Uses of BeamProducer in com.logicalclocks.hsfs.beam.engine

Methods in com.logicalclocks.hsfs.beam.engine that return BeamProducer

Modifier and Type	Method	Description
BeamProducer	BeamEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)
BeamProducer	FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)