org.apache.flink.tests.util.flink

Class LocalStandaloneFlinkResourceFactory

java.lang.Object

org.apache.flink.tests.util.flink.LocalStandaloneFlinkResourceFactory

All Implemented Interfaces:

FlinkResourceFactory

public final class LocalStandaloneFlinkResourceFactory
extends Object
implements FlinkResourceFactory

A FlinkResourceFactory for the LocalStandaloneFlinkResource.

Constructor Summary

Constructors

Constructor and Description
LocalStandaloneFlinkResourceFactory()

Method Summary

Modifier and Type	Method and Description
FlinkResource	create(FlinkResourceSetup setup) Returns a FlinkResource instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStandaloneFlinkResourceFactory

public LocalStandaloneFlinkResourceFactory()

Method Detail

create

public FlinkResource create(FlinkResourceSetup setup)

Description copied from interface: FlinkResourceFactory

Returns a FlinkResource instance. If the instance could not be instantiated (for example, because a mandatory parameter was missing), then an exception should be thrown.

Specified by:

create in interface FlinkResourceFactory

Parameters:

setup - setup instructions for the FlinkResource

Returns:

FlinkResource instance,