com.amazonaws.services.kinesisanalyticsv2.model

Class FlinkApplicationConfiguration

java.lang.Object

com.amazonaws.services.kinesisanalyticsv2.model.FlinkApplicationConfiguration

All Implemented Interfaces:

StructuredPojo, Serializable, Cloneable

@Generated(value="com.amazonaws:aws-java-sdk-code-generator")
public class FlinkApplicationConfiguration
extends Object
implements Serializable, Cloneable, StructuredPojo

Describes configuration parameters for a Managed Service for Apache Flink application or a Studio notebook.

See Also:

AWS API Documentation, Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlinkApplicationConfiguration()

Method Summary

Modifier and Type	Method and Description
FlinkApplicationConfiguration	clone()
boolean	equals(Object obj)
CheckpointConfiguration	getCheckpointConfiguration() Describes an application's checkpointing configuration.
MonitoringConfiguration	getMonitoringConfiguration() Describes configuration parameters for Amazon CloudWatch logging for an application.
ParallelismConfiguration	getParallelismConfiguration() Describes parameters for how an application executes multiple tasks simultaneously.
int	hashCode()
void	marshall(ProtocolMarshaller protocolMarshaller) Marshalls this structured data using the given ProtocolMarshaller.
void	setCheckpointConfiguration(CheckpointConfiguration checkpointConfiguration) Describes an application's checkpointing configuration.
void	setMonitoringConfiguration(MonitoringConfiguration monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.
void	setParallelismConfiguration(ParallelismConfiguration parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.
String	toString() Returns a string representation of this object.
FlinkApplicationConfiguration	withCheckpointConfiguration(CheckpointConfiguration checkpointConfiguration) Describes an application's checkpointing configuration.
FlinkApplicationConfiguration	withMonitoringConfiguration(MonitoringConfiguration monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.
FlinkApplicationConfiguration	withParallelismConfiguration(ParallelismConfiguration parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

FlinkApplicationConfiguration

public FlinkApplicationConfiguration()

Method Detail

setCheckpointConfiguration

public void setCheckpointConfiguration(CheckpointConfiguration checkpointConfiguration)

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

Parameters:

checkpointConfiguration - Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

getCheckpointConfiguration

public CheckpointConfiguration getCheckpointConfiguration()

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

Returns:

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

withCheckpointConfiguration

public FlinkApplicationConfiguration withCheckpointConfiguration(CheckpointConfiguration checkpointConfiguration)

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

Parameters:

checkpointConfiguration - Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

Returns:

Returns a reference to this object so that method calls can be chained together.

setMonitoringConfiguration

public void setMonitoringConfiguration(MonitoringConfiguration monitoringConfiguration)

Describes configuration parameters for Amazon CloudWatch logging for an application.

Parameters:

monitoringConfiguration - Describes configuration parameters for Amazon CloudWatch logging for an application.

getMonitoringConfiguration

public MonitoringConfiguration getMonitoringConfiguration()

Describes configuration parameters for Amazon CloudWatch logging for an application.

Returns:

Describes configuration parameters for Amazon CloudWatch logging for an application.

withMonitoringConfiguration

public FlinkApplicationConfiguration withMonitoringConfiguration(MonitoringConfiguration monitoringConfiguration)

Describes configuration parameters for Amazon CloudWatch logging for an application.

Parameters:

monitoringConfiguration - Describes configuration parameters for Amazon CloudWatch logging for an application.

Returns:

Returns a reference to this object so that method calls can be chained together.

setParallelismConfiguration

public void setParallelismConfiguration(ParallelismConfiguration parallelismConfiguration)

Describes parameters for how an application executes multiple tasks simultaneously.

Parameters:

parallelismConfiguration - Describes parameters for how an application executes multiple tasks simultaneously.

getParallelismConfiguration

public ParallelismConfiguration getParallelismConfiguration()

Describes parameters for how an application executes multiple tasks simultaneously.

Returns:

Describes parameters for how an application executes multiple tasks simultaneously.

withParallelismConfiguration

public FlinkApplicationConfiguration withParallelismConfiguration(ParallelismConfiguration parallelismConfiguration)

Describes parameters for how an application executes multiple tasks simultaneously.

Parameters:

parallelismConfiguration - Describes parameters for how an application executes multiple tasks simultaneously.

Returns:

Returns a reference to this object so that method calls can be chained together.

toString

public String toString()

Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value.

Overrides:

toString in class Object

Returns:

A string representation of this object.

See Also:

Object.toString()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

clone

public FlinkApplicationConfiguration clone()

Overrides:

clone in class Object

marshall

public void marshall(ProtocolMarshaller protocolMarshaller)

Description copied from interface: StructuredPojo

Marshalls this structured data using the given ProtocolMarshaller.

Specified by:

marshall in interface StructuredPojo

Parameters:

protocolMarshaller - Implementation of ProtocolMarshaller used to marshall this object's data.