Sam Rohde created BEAM-9447: ------------------------------- Summary: Generalize the InteractiveRunner StreamingCache Key: BEAM-9447 URL: https://issues.apache.org/jira/browse/BEAM-9447 Project: Beam Issue Type: Bug Components: runner-py-interactive Reporter: Sam Rohde
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. -- This message was sent by Atlassian Jira (v8.3.4#803005)