Package com.google.cloud.hadoop.util

Class AsyncWriteChannelOptions

java.lang.Object

com.google.cloud.hadoop.util.AsyncWriteChannelOptions

public abstract class AsyncWriteChannelOptions
extends Object

Options for the AbstractGoogleAsyncWriteChannel.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncWriteChannelOptions.Builder	Mutable builder for the GoogleCloudStorageWriteChannelOptions class.
static enum	AsyncWriteChannelOptions.PartFileCleanupType	Part file cleanup strategy for parallel composite upload.
static enum	AsyncWriteChannelOptions.PipeType	Pipe used for output stream.
static enum	AsyncWriteChannelOptions.UploadType	UploadType are in parity with various upload configuration offered by google-java-storage client ref: https://cloud.google.com/java/docs/reference/google-cloud-storage/latest/com.google.cloud.storage.BlobWriteSessionConfigs

Field Summary

Fields

Modifier and Type	Field	Description
static final AsyncWriteChannelOptions	DEFAULT

Constructor Summary

Constructors

Constructor	Description
AsyncWriteChannelOptions()

Method Summary

Modifier and Type	Method	Description
static AsyncWriteChannelOptions.Builder	builder()
abstract int	getBufferSize()
abstract Duration	getGrpcWriteMessageTimeout()
abstract Duration	getGrpcWriteTimeout()
abstract int	getNumberOfBufferedRequests()
abstract AsyncWriteChannelOptions.PartFileCleanupType	getPartFileCleanupType()
abstract String	getPartFileNamePrefix()
abstract int	getPCUBufferCapacity()
abstract int	getPCUBufferCount()
abstract int	getPipeBufferSize()
abstract AsyncWriteChannelOptions.PipeType	getPipeType()
abstract com.google.common.collect.ImmutableSet<String>	getTemporaryPaths()
abstract int	getUploadCacheSize()
abstract int	getUploadChunkSize()
abstract AsyncWriteChannelOptions.UploadType	getUploadType()
abstract boolean	isDirectUploadEnabled()
abstract boolean	isGrpcChecksumsEnabled()
abstract boolean	isRollingChecksumEnabled()
abstract AsyncWriteChannelOptions.Builder	toBuilder()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT

public static final AsyncWriteChannelOptions DEFAULT

Constructor Details

AsyncWriteChannelOptions

public AsyncWriteChannelOptions()

Method Details

builder

public static AsyncWriteChannelOptions.Builder builder()

toBuilder

public abstract AsyncWriteChannelOptions.Builder toBuilder()

getBufferSize

public abstract int getBufferSize()

getPipeBufferSize

public abstract int getPipeBufferSize()

getPipeType

public abstract AsyncWriteChannelOptions.PipeType getPipeType()

getUploadChunkSize

public abstract int getUploadChunkSize()

getUploadCacheSize

public abstract int getUploadCacheSize()

isDirectUploadEnabled

public abstract boolean isDirectUploadEnabled()

isGrpcChecksumsEnabled

public abstract boolean isGrpcChecksumsEnabled()

isRollingChecksumEnabled

public abstract boolean isRollingChecksumEnabled()

getGrpcWriteTimeout

public abstract Duration getGrpcWriteTimeout()

getNumberOfBufferedRequests

public abstract int getNumberOfBufferedRequests()

getGrpcWriteMessageTimeout

public abstract Duration getGrpcWriteMessageTimeout()

getUploadType

public abstract AsyncWriteChannelOptions.UploadType getUploadType()

getPartFileCleanupType

public abstract AsyncWriteChannelOptions.PartFileCleanupType getPartFileCleanupType()

getTemporaryPaths

public abstract com.google.common.collect.ImmutableSet<String> getTemporaryPaths()

getPCUBufferCount

public abstract int getPCUBufferCount()

getPCUBufferCapacity

public abstract int getPCUBufferCapacity()

getPartFileNamePrefix

public abstract String getPartFileNamePrefix()