Interface StreamingJob.DefinitionStages.WithOutputErrorPolicy
-
- All Known Subinterfaces:
StreamingJob.Definition
,StreamingJob.DefinitionStages.WithCreate
- Enclosing interface:
- StreamingJob.DefinitionStages
public static interface StreamingJob.DefinitionStages.WithOutputErrorPolicy
The stage of the StreamingJob definition allowing to specify outputErrorPolicy.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamingJob.DefinitionStages.WithCreate
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 Detail
-
withOutputErrorPolicy
StreamingJob.DefinitionStages.WithCreate 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.
-
-