org.apache.beam.runners.dataflow.util

Class PackageUtil

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class PackageUtil
extends java.lang.Object
implements java.io.Closeable

Helper routines for packages.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PackageUtil.StagedFile

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.concurrent.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, java.lang.String target, java.lang.String stagingPath, CreateOptions createOptions)
static PackageUtil	withDefaultThreadPool()
static PackageUtil	withExecutorService(java.util.concurrent.ExecutorService executorService)

Methods inherited from class java.lang.Object

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

Method Detail

withDefaultThreadPool

public static PackageUtil withDefaultThreadPool()

withExecutorService

public static PackageUtil withExecutorService(java.util.concurrent.ExecutorService executorService)

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

stagePackage

public java.util.concurrent.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,
                                   java.lang.String target,
                                   java.lang.String stagingPath,
                                   CreateOptions createOptions)