Generalize the InteractiveRunner StreamingCache
- Lingua principale
- Java
- Stelle
- 8.7k
- Fork
- 4.7k
- Merge medio
- 2g 9h
- PR unite (30g)
- 202
Descrizione
The InteractiveRunner's StreamingCache is only file based for now. This should be generalized to work across more different source and sink types and ported to other runners.
Imported from Jira [BEAM-9447](https://issues.apache.org/jira/browse/BEAM-9447). Original Jira may contain additional context.
Reported by: rohdesam.
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Inizia individuando lo StreamingCache basato su file di InteractiveRunner e analizza il contesto aggiuntivo in Jira BEAM-9447. Determina quali tipi di source e sink e quali altri runner rientrano nell'ambito; il lavoro è completato quando la cache funziona con questi tipi ed è stata portata sui runner selezionati.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- java
- Ambito
- data-engineering
- Tipo di issue
- Funzionalità
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Stato di attività
- Ferma
- Chiarezza
- Da chiarire
- Idoneità per principianti
- 25/100