org.apache.beam.runners.flink

Class FlinkMiniClusterEntryPoint

java.lang.Object

org.apache.beam.runners.flink.FlinkMiniClusterEntryPoint

public class FlinkMiniClusterEntryPoint
extends java.lang.Object

Entry point for starting an embedded Flink cluster.

Constructor Summary

Constructors

Constructor and Description
FlinkMiniClusterEntryPoint()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkMiniClusterEntryPoint

public FlinkMiniClusterEntryPoint()

Method Detail

main

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

Throws:

java.lang.Exception