org.apache.flink.deployment

Class HeavyDeploymentStressTestProgram

java.lang.Object

org.apache.flink.deployment.HeavyDeploymentStressTestProgram

public class HeavyDeploymentStressTestProgram
extends Object

End-to-end test for heavy deployment descriptors. This test creates a heavy deployment by producing inflated meta data for the source's operator state. The state is registered as union state and will be multiplied in deployment.

Constructor Summary

Constructors

Constructor and Description
HeavyDeploymentStressTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HeavyDeploymentStressTestProgram

public HeavyDeploymentStressTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception