Skip to main content
This matrix clarifies the capabilities of FlareDB. Individual capabilities are grouped by their corresponding What / Where / When / How question:
  • What results are being calculated?
  • Where in event time?
  • When in processing time?
  • How do refinements of results relate?
For more details on the What / Where / When / How breakdown, see the Streaming 102 post on O’Reilly.

How to read the tables

Each row is a property. Cells answer: does FlareDB have this property?
SignMeaning
βœ…Yes
🟑Partially
πŸ—“οΈPlanned

What is being computed?

FeatureFlareDB
ParDoβœ…
GroupByKeyβœ…
Flattenβœ…
Combineβœ…
Composite Transformsβœ…
Side InputsπŸ—“οΈ
Source API🟑
MetricsπŸ—“οΈ
Stateful Processing🟑

Bounded Splittable DoFn Support Status

FeatureFlareDB
Baseβœ…
Side InputsπŸ—“οΈ
Splittable DoFn Initiated CheckpointingπŸ—“οΈ
Dynamic SplittingπŸ—“οΈ
Bundle FinalizationπŸ—“οΈ

Unbounded Splittable DoFn Support Status

FeatureFlareDB
BaseπŸ—“οΈ
Side InputsπŸ—“οΈ
Splittable DoFn Initiated CheckpointingπŸ—“οΈ
Dynamic SplittingπŸ—“οΈ
Bundle FinalizationπŸ—“οΈ

Where in event time?

FeatureFlareDB
Global windowsβœ…
Fixed windowsβœ…
Sliding windowsβœ…
Session windowsπŸ—“οΈ
Custom windowsπŸ—“οΈ
Custom merging windowsπŸ—“οΈ
Timestamp controlβœ…

When in processing time?

FeatureFlareDB
Configurable triggering🟑
Event-time triggersβœ…
Processing-time triggers🟑
Count triggersβœ…
Composite triggersβœ…
Allowed lateness🟑
Timersβœ…

How do refinements relate?

FeatureFlareDB
Discardingβœ…
Accumulatingβœ…

Additional common features not yet part of the Beam model

FeatureFlareDB
DrainπŸ—“οΈ
Checkpoint🟑
Key-ordered deliveryπŸ—“οΈ