Package org.apache.beam.runners.dataflow.util

Class PackageUtil

java.lang.Object

org.apache.beam.runners.dataflow.util.PackageUtil

All Implemented Interfaces:

Closeable, AutoCloseable

public class PackageUtil
extends Object
implements Closeable

Helper routines for packages.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PackageUtil.StagedFile

Method Summary

Modifier and Type	Method	Description
void	close()
CompletionStage<org.apache.beam.runners.dataflow.util.PackageUtil.StagingResult>	stagePackage(org.apache.beam.runners.dataflow.util.PackageUtil.PackageAttributes attributes, com.google.api.client.util.Sleeper retrySleeper, CreateOptions createOptions)	Stages one file ("package") if necessary.
DataflowPackage	stageToFile(byte[] bytes, String target, String stagingPath, CreateOptions createOptions)
static PackageUtil	withDefaultThreadPool()
static PackageUtil	withExecutorService(ExecutorService executorService)

Methods inherited from class java.lang.Object

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

Method Details

withDefaultThreadPool

public static PackageUtil withDefaultThreadPool()

withExecutorService

public static PackageUtil withExecutorService(ExecutorService executorService)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

stagePackage

public CompletionStage<org.apache.beam.runners.dataflow.util.PackageUtil.StagingResult> stagePackage(org.apache.beam.runners.dataflow.util.PackageUtil.PackageAttributes attributes,
 com.google.api.client.util.Sleeper retrySleeper,
 CreateOptions createOptions)

Stages one file ("package") if necessary.

stageToFile

public DataflowPackage stageToFile(byte[] bytes,
 String target,
 String stagingPath,
 CreateOptions createOptions)