10 Repos
Specifications for record occurrence times to enable incremental processing and dataset comparison.
Distinct from Event Data Processing: Distinct from Event Data Processing: focuses on the definition of temporal attributes for incremental logic rather than general event stream handling.
Explore 10 awesome GitHub repositories matching data & databases · Event Timestamp Definitions. Refine with filters or upvote what's useful.
Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and traces across distributed infrastructure. It functions as a modular engine that decouples data ingestion from processing and transmission, utilizing a component-based architecture to connect diverse sources to multiple destinations. The project distinguishes itself through a focus on reliability and flow control. It implements backpressure-aware data movement to prevent data loss during traffic spikes and utilizes disk-backed event buffering to ensure durability during network
Records the precise time of occurrence for each metric event to maintain accurate temporal ordering and historical analysis.
dbt-core is a command-line framework for transforming data within a warehouse using modular SQL and version control. It functions as a data transformation engine that enables users to define data structures and business logic through declarative configuration files, which the system then compiles into executable code. By managing complex data dependencies through a directed acyclic graph, it ensures that transformation tasks execute in the correct order while maintaining a manifest-driven state to track lineage and execution history. The project distinguishes itself through an adapter-based d
Specifies occurrence times for data records to enable incremental processing and advanced dataset comparison.
Any-rule is a multi-platform regular expression tool that provides a curated catalog of over 70 ready-to-use patterns for validating and extracting common data formats. The project separates its static regex collection from editor-specific plugins, allowing the same pattern library to be accessed through VS Code, IntelliJ IDEA, Alfred Workflow, and a web interface. The tool enables keyword-based pattern retrieval, letting users search for the correct regex by typing descriptive terms rather than remembering exact syntax. It covers a broad range of validation needs including email addresses, U
Provides a regex pattern to validate timestamps in YYYYMMDD HH:mm:ss format.
ElastAlert is an alerting framework and query monitor for Elasticsearch. It functions as a real-time log monitoring tool and event notification engine that scans indices for specific patterns to trigger automated alerts when predefined rules are matched. The system distinguishes itself through specialized detection logic, including event spike detection, event frequency monitoring, field change tracking, and the identification of new terms within data fields. It handles notification noise via stateful alert suppression to prevent redundant messages and provides time-windowed aggregation to gr
Enables specifying the field and format for event timing to adjust query delays for non-real-time data.
Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to support real-time analytics and event-driven applications. It functions as a partitioned, distributed key-value store that replicates data across cluster nodes to provide low-latency access and high availability. The platform also serves as a distributed SQL query engine, allowing users to execute standard SQL statements against both in-memory datasets and external data sources. What distinguishes Hazelcast is its use of a distributed consensus subsystem to maintain strongly consis
Defines event occurrence times using source timestamps or ingestion time to manage temporal processing.
Countly is a self-hosted product analytics and engagement platform that tracks user behavior across mobile, web, and desktop applications. It collects and analyzes device properties, user actions, and session lifecycle data to understand engagement patterns, while also providing crash reporting, push notification delivery, and A/B testing capabilities. The platform is designed for privacy-first deployment, with built-in consent management and the ability to run entirely on private infrastructure. The platform distinguishes itself through its comprehensive feature set that combines analytics w
Attaches a unique millisecond timestamp, local hour, day of week, and timezone offset to each event.
Cortex is an open-source, horizontally scalable metrics platform that ingests, stores, and queries Prometheus-compatible time-series data with multi-tenant isolation. It accepts metrics via Prometheus remote write and OpenTelemetry, executes PromQL queries against both recent and historical data, and provides a Prometheus-compatible alerting and recording rule engine with an integrated Alertmanager. The system is built as a set of independently scalable microservices that use hash-ring-based sharding, gossip-based cluster membership, and tenant-aware object storage to distribute workloads acro
Cortex rejects samples with timestamps too far in the past or future based on configurable age and grace period limits.
CRI-O is an open-source container runtime that implements the Kubernetes Container Runtime Interface (CRI) to manage container images, pods, and containers on cluster nodes using OCI-compatible runtimes. It serves as a node-level container manager that handles image pulling, container lifecycle, and resource monitoring for Kubernetes clusters, running containers according to the Open Container Initiative specifications. The runtime distinguishes itself through live configuration reloading that applies changes to runtime definitions, registry mirrors, and TLS certificates without restarting th
Reports pod sandbox status timestamps in nanosecond resolution for evented PLEG compatibility.
Dieses Projekt bietet eine Observability-Datenpipeline, die darauf ausgelegt ist, Logs, Metriken und Traces aus verschiedenen Quellen zu sammeln, zu transformieren und in standardisierte Formate für die Analyse zu routen. Es arbeitet als Plugin-basierte Komponentenarchitektur, die modulare Receiver, Prozessoren und Exporter verwendet, um Telemetriedaten durch sequentielle Verarbeitungsketten zu bewegen. Das System nutzt ein schnittstellengetriebenes Komponentenmodell, das austauschbare Konnektoren und von der Community beigesteuerte Erweiterungen ermöglicht. Es zeichnet sich durch eine domänenspezifische Sprache für Telemetrie-Filterung, metadatenbasierte Ressourcenattribuierung für die Infrastrukturerkennung und dynamische Secret-Auflösung von externen Cloud-Managern aus. Der Collector deckt eine breite Palette an Funktionen ab, einschließlich Telemetrie-Ingestion von Cloud-Providern und Datenbanken, Datentransformation und Reaggregation sowie sicheren Export an Speicher-Backends von Drittanbietern. Er integriert Funktionen für das Traffic-Management wie Round-Robin-Routing und Nachrichtenpartitionierung sowie Sicherheitsprimitive für Identitäts- und Zugriffsmanagement via OAuth2 und OIDC. Das Projekt enthält ein Qualitätssicherungs-Framework für synthetische Datensimulation, End-to-End-Leistungstests und Datenintegritätsprüfung.
Sets the start timestamp of cumulative metric points based on specific reset strategies.
Cube is a time-series analytics platform and event data store designed for real-time performance monitoring. It functions as a metrics engine that ingests timestamped event streams and persists raw logs to enable the computation of statistical summaries, quantiles, and histograms. The system distinguishes itself through a reactive processing model that automatically invalidates metric caches when new events arrive, ensuring query results remain current. It supports both real-time event streaming via persistent connections and the calculation of post hoc statistics from stored event sets. The
Stores raw timestamped events to enable incremental processing and subsequent aggregate computation.