Staging Files to GCS using Dataflow DirectRunner

316 Views Asked by At

So when using DataflowRunner, we are staging files to GCS using the filesToStage method, however this does not happen in DirectRunner. Is there a way to have DirectRunner stage files to GCS and use those files similar to the DataflowRunner perhaps by perhaps using ClassLoader or another method?

1

There are 1 best solutions below

0
On

No, direct runner simply runs locally, so it doesn't stage files to GCS, it just uses the local files to run the software. My best suggestion is to write a tool that looks for the files in two possible places, detecting if its running on dataflowrunner or directrunner by locating the files