org.apache.flink.statefun.flink.launcher

Class StatefulFunctionsClusterEntryPoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

org.apache.flink.statefun.flink.launcher.StatefulFunctionsClusterEntryPoint

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.flink.runtime.rpc.FatalErrorHandler, org.apache.flink.util.AutoCloseableAsync

public final class StatefulFunctionsClusterEntryPoint
extends org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

JobClusterEntrypoint which is started with a job in a predefined location.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.ClusterEntrypoint.ExecutionMode, org.apache.flink.runtime.entrypoint.ClusterEntrypoint.ShutdownBehaviour

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.flink.api.common.JobID	ZERO_JOB_ID

Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

INTERNAL_CLUSTER_EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory	createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration)
static void	main(java.lang.String[] args)

Methods inherited from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

createSerializableExecutionGraphStore

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

cleanupDirectories, closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRestPort, getRpcPort, getRPCPortRange, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Field Detail

ZERO_JOB_ID

public static final org.apache.flink.api.common.JobID ZERO_JOB_ID

Method Detail

main

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

createDispatcherResourceManagerComponentFactory

protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration)

Specified by:

createDispatcherResourceManagerComponentFactory in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint