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);
}