Hazelcast Jet StreamSource Arayüzü - An Infinite Source of Data

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.pipeline.StreamSource;

Açıklaması şöyle.

A StreamSource emits data events into the pipeline. The events can be any Java object that represents a data record, such as a Map, a POJO (Plain Old Java Object), or a custom object. The data events can be emitted as a single object or as a collection of objects.

In addition to the data events, StreamSource can also emit watermark events. A watermark event is a signal that denotes the current progress of the stream processing. It represents a timestamp that indicates that all events with a timestamp smaller than the watermark have been processed. Watermarks help ensure that the pipeline processes events in the correct order, and that no events are missed or processed too early.

Açıklaması şöyle

Kafka Connect has a similar concept called Source Connector. A Source Connector is a Kafka Connect plugin that is responsible for reading data from an external system and writing it to Kafka. Like StreamSource, a Source Connector emits data events into the pipeline.