JsonSink Class

public final class JsonSink
extends CopySink

A copy activity Json sink.

Constructor Summary

Constructor Description
JsonSink()

Creates an instance of JsonSink class.

Method Summary

Modifier and Type Method and Description
JsonWriteSettings formatSettings()

Get the formatSettings property: Json format settings.

StoreWriteSettings storeSettings()

Get the storeSettings property: Json store settings.

void validate()

Validates the instance.

JsonSink withDisableMetricsCollection(Object disableMetricsCollection)

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

JsonSink withFormatSettings(JsonWriteSettings formatSettings)

Set the formatSettings property: Json format settings.

JsonSink withMaxConcurrentConnections(Object maxConcurrentConnections)

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

JsonSink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count.

JsonSink withSinkRetryWait(Object sinkRetryWait)

Set the sinkRetryWait property: Sink retry wait.

JsonSink withStoreSettings(StoreWriteSettings storeSettings)

Set the storeSettings property: Json store settings.

JsonSink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size.

JsonSink withWriteBatchTimeout(Object writeBatchTimeout)

Set the writeBatchTimeout property: Write batch timeout.

Methods inherited from CopySink

Methods inherited from java.lang.Object

Constructor Details

JsonSink

public JsonSink()

Creates an instance of JsonSink class.

Method Details

formatSettings

public JsonWriteSettings formatSettings()

Get the formatSettings property: Json format settings.

Returns:

the formatSettings value.

storeSettings

public StoreWriteSettings storeSettings()

Get the storeSettings property: Json store settings.

Returns:

the storeSettings value.

validate

public void validate()

Validates the instance.

Overrides:

JsonSink.validate()

withDisableMetricsCollection

public JsonSink 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:

JsonSink.withDisableMetricsCollection(Object disableMetricsCollection)

Parameters:

disableMetricsCollection

withFormatSettings

public JsonSink withFormatSettings(JsonWriteSettings formatSettings)

Set the formatSettings property: Json format settings.

Parameters:

formatSettings - the formatSettings value to set.

Returns:

the JsonSink object itself.

withMaxConcurrentConnections

public JsonSink 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:

JsonSink.withMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

withSinkRetryCount

public JsonSink withSinkRetryCount(Object sinkRetryCount)

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

Overrides:

JsonSink.withSinkRetryCount(Object sinkRetryCount)

Parameters:

sinkRetryCount

withSinkRetryWait

public JsonSink 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:

JsonSink.withSinkRetryWait(Object sinkRetryWait)

Parameters:

sinkRetryWait

withStoreSettings

public JsonSink withStoreSettings(StoreWriteSettings storeSettings)

Set the storeSettings property: Json store settings.

Parameters:

storeSettings - the storeSettings value to set.

Returns:

the JsonSink object itself.

withWriteBatchSize

public JsonSink withWriteBatchSize(Object writeBatchSize)

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

Overrides:

JsonSink.withWriteBatchSize(Object writeBatchSize)

Parameters:

writeBatchSize

withWriteBatchTimeout

public JsonSink 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:

JsonSink.withWriteBatchTimeout(Object writeBatchTimeout)

Parameters:

writeBatchTimeout

Applies to