StreamingJob.UpdateStages.WithOutputErrorPolicy Interface

public static interface StreamingJob.UpdateStages.WithOutputErrorPolicy

The stage of the StreamingJob update allowing to specify outputErrorPolicy.

Method Summary

Modifier and Type Method and Description
abstract Update withOutputErrorPolicy(OutputErrorPolicy outputErrorPolicy)

Specifies the outputErrorPolicy property: Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size)..

Method Details

withOutputErrorPolicy

public abstract StreamingJob.Update withOutputErrorPolicy(OutputErrorPolicy outputErrorPolicy)

Specifies the outputErrorPolicy property: Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size)..

Parameters:

outputErrorPolicy - Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).

Returns:

the next definition stage.

Applies to