Java源码示例:org.apache.flink.runtime.resourcemanager.ResourceManagerFactory
示例1
public AbstractDispatcherResourceManagerComponentFactory(
@Nonnull DispatcherFactory<T> dispatcherFactory,
@Nonnull ResourceManagerFactory<?> resourceManagerFactory,
@Nonnull RestEndpointFactory<U> restEndpointFactory) {
this.dispatcherFactory = dispatcherFactory;
this.resourceManagerFactory = resourceManagerFactory;
this.restEndpointFactory = restEndpointFactory;
}
示例2
public AbstractDispatcherResourceManagerComponentFactory(
@Nonnull DispatcherFactory<T> dispatcherFactory,
@Nonnull ResourceManagerFactory<?> resourceManagerFactory,
@Nonnull RestEndpointFactory<U> restEndpointFactory) {
this.dispatcherFactory = dispatcherFactory;
this.resourceManagerFactory = resourceManagerFactory;
this.restEndpointFactory = restEndpointFactory;
}
示例3
public DefaultDispatcherResourceManagerComponentFactory(
@Nonnull DispatcherRunnerFactory dispatcherRunnerFactory,
@Nonnull ResourceManagerFactory<?> resourceManagerFactory,
@Nonnull RestEndpointFactory<?> restEndpointFactory) {
this.dispatcherRunnerFactory = dispatcherRunnerFactory;
this.resourceManagerFactory = resourceManagerFactory;
this.restEndpointFactory = restEndpointFactory;
}
示例4
public static DefaultDispatcherResourceManagerComponentFactory createSessionComponentFactory(
ResourceManagerFactory<?> resourceManagerFactory) {
return new DefaultDispatcherResourceManagerComponentFactory(
DefaultDispatcherRunnerFactory.createSessionRunner(SessionDispatcherFactory.INSTANCE),
resourceManagerFactory,
SessionRestEndpointFactory.INSTANCE);
}
示例5
public static DefaultDispatcherResourceManagerComponentFactory createJobComponentFactory(
ResourceManagerFactory<?> resourceManagerFactory,
JobGraphRetriever jobGraphRetriever) {
return new DefaultDispatcherResourceManagerComponentFactory(
DefaultDispatcherRunnerFactory.createJobRunner(jobGraphRetriever),
resourceManagerFactory,
JobRestEndpointFactory.INSTANCE);
}
示例6
protected ApplicationClusterEntryPoint(
final Configuration configuration,
final PackagedProgram program,
final ResourceManagerFactory<?> resourceManagerFactory) {
super(configuration);
this.program = checkNotNull(program);
this.resourceManagerFactory = checkNotNull(resourceManagerFactory);
}
示例7
public SessionDispatcherResourceManagerComponentFactory(@Nonnull ResourceManagerFactory<?> resourceManagerFactory) {
this(SessionDispatcherFactory.INSTANCE, resourceManagerFactory);
}
示例8
@VisibleForTesting
public SessionDispatcherResourceManagerComponentFactory(
@Nonnull DispatcherFactory<Dispatcher> dispatcherFactory,
@Nonnull ResourceManagerFactory<?> resourceManagerFactory) {
super(dispatcherFactory, resourceManagerFactory, SessionRestEndpointFactory.INSTANCE);
}
示例9
public JobDispatcherResourceManagerComponentFactory(@Nonnull ResourceManagerFactory<?> resourceManagerFactory, @Nonnull JobGraphRetriever jobGraphRetriever) {
super(new JobDispatcherFactory(jobGraphRetriever), resourceManagerFactory, JobRestEndpointFactory.INSTANCE);
}
示例10
public SessionDispatcherResourceManagerComponentFactory(@Nonnull ResourceManagerFactory<?> resourceManagerFactory) {
this(SessionDispatcherFactory.INSTANCE, resourceManagerFactory);
}
示例11
@VisibleForTesting
public SessionDispatcherResourceManagerComponentFactory(
@Nonnull DispatcherFactory<Dispatcher> dispatcherFactory,
@Nonnull ResourceManagerFactory<?> resourceManagerFactory) {
super(dispatcherFactory, resourceManagerFactory, SessionRestEndpointFactory.INSTANCE);
}
示例12
public JobDispatcherResourceManagerComponentFactory(@Nonnull ResourceManagerFactory<?> resourceManagerFactory, @Nonnull JobGraphRetriever jobGraphRetriever) {
super(new JobDispatcherFactory(jobGraphRetriever), resourceManagerFactory, JobRestEndpointFactory.INSTANCE);
}