Allow sources to define custom processing behavior and time-based filtering rules.
Done when:
- Sources can define processing rules through configuration
- Pipeline applies source-specific rules during execution
- Time filtering can be configured per source
- Records outside configured time ranges are filtered appropriately
- Source-specific processing integrates with source resolution
Allow sources to define custom processing behavior and time-based filtering rules.
Done when: