@FunctionalInterface public interface FlinkResourceFactory
FlinkResource create(FlinkResourceSetup setup) throws Exception
FlinkResourceinstance. If the instance could not be instantiated (for example, because a mandatory parameter was missing), then an exception should be thrown.
setup- setup instructions for the FlinkResource
Exception- if the instance could not be instantiated
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.