org.apache.beam.runners.dataflow.util

Class GcsStager

java.lang.Object

org.apache.beam.runners.dataflow.util.GcsStager

All Implemented Interfaces:

Stager

public class GcsStager
extends java.lang.Object
implements Stager

Utility class for staging files to GCS.

Method Summary

Modifier and Type	Method and Description
static GcsStager	fromOptions(PipelineOptions options)
java.util.List<com.google.api.services.dataflow.model.DataflowPackage>	stageFiles()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fromOptions

public static GcsStager fromOptions(PipelineOptions options)

stageFiles

public java.util.List<com.google.api.services.dataflow.model.DataflowPackage> stageFiles()

Specified by:

stageFiles in interface Stager