BinarySink Class

public final class BinarySink
extends CopySink

A copy activity Binary sink.

Constructor Summary

Constructor Description
BinarySink()

Creates an instance of BinarySink class.

Method Summary

Modifier and Type Method and Description
static BinarySink fromJson(JsonReader jsonReader)

Reads an instance of BinarySink from the JsonReader.

StoreWriteSettings storeSettings()

Get the storeSettings property: Binary store settings.

JsonWriter toJson(JsonWriter jsonWriter)
String type()

Get the type property: Copy sink type.

void validate()

Validates the instance.

BinarySink withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection.

BinarySink withMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store.

BinarySink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count.

BinarySink withSinkRetryWait(Object sinkRetryWait)

Set the sinkRetryWait property: Sink retry wait.

BinarySink withStoreSettings(StoreWriteSettings storeSettings)

Set the storeSettings property: Binary store settings.

BinarySink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size.

BinarySink withWriteBatchTimeout(Object writeBatchTimeout)

Set the writeBatchTimeout property: Write batch timeout.

Methods inherited from CopySink

Methods inherited from java.lang.Object

Constructor Details

BinarySink

public BinarySink()

Creates an instance of BinarySink class.

Method Details

fromJson

public static BinarySink fromJson(JsonReader jsonReader)

Reads an instance of BinarySink from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of BinarySink if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the BinarySink.

storeSettings

public StoreWriteSettings storeSettings()

Get the storeSettings property: Binary store settings.

Returns:

the storeSettings value.

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

BinarySink.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

type

public String type()

Get the type property: Copy sink type.

Overrides:

BinarySink.type()

Returns:

the type value.

validate

public void validate()

Validates the instance.

Overrides:

BinarySink.validate()

withDisableMetricsCollection

public BinarySink withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).

Overrides:

BinarySink.withDisableMetricsCollection(Object disableMetricsCollection)

Parameters:

disableMetricsCollection

withMaxConcurrentConnections

public BinarySink withMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store. Type: integer (or Expression with resultType integer).

Overrides:

BinarySink.withMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

withSinkRetryCount

public BinarySink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count. Type: integer (or Expression with resultType integer).

Overrides:

BinarySink.withSinkRetryCount(Object sinkRetryCount)

Parameters:

sinkRetryCount

withSinkRetryWait

public BinarySink withSinkRetryWait(Object sinkRetryWait)

Set the sinkRetryWait property: Sink retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

BinarySink.withSinkRetryWait(Object sinkRetryWait)

Parameters:

sinkRetryWait

withStoreSettings

public BinarySink withStoreSettings(StoreWriteSettings storeSettings)

Set the storeSettings property: Binary store settings.

Parameters:

storeSettings - the storeSettings value to set.

Returns:

the BinarySink object itself.

withWriteBatchSize

public BinarySink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.

Overrides:

BinarySink.withWriteBatchSize(Object writeBatchSize)

Parameters:

writeBatchSize

withWriteBatchTimeout

public BinarySink withWriteBatchTimeout(Object writeBatchTimeout)

Set the writeBatchTimeout property: Write batch timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

BinarySink.withWriteBatchTimeout(Object writeBatchTimeout)

Parameters:

writeBatchTimeout

Applies to