本文整理了Java中io.airlift.bootstrap.Bootstrap.doNotInitializeLogging()
方法的一些代码示例,展示了Bootstrap.doNotInitializeLogging()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bootstrap.doNotInitializeLogging()
方法的具体详情如下:
包路径:io.airlift.bootstrap.Bootstrap
类名称:Bootstrap
方法名:doNotInitializeLogging
暂无
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
try {
Bootstrap app = new Bootstrap(
binder -> {
configBinder(binder).bindConfig(JmxConnectorConfig.class);
binder.bind(MBeanServer.class).toInstance(new RebindSafeMBeanServer(mbeanServer));
binder.bind(NodeManager.class).toInstance(context.getNodeManager());
binder.bind(JmxConnector.class).in(Scopes.SINGLETON);
binder.bind(JmxHistoricalData.class).in(Scopes.SINGLETON);
binder.bind(JmxMetadata.class).in(Scopes.SINGLETON);
binder.bind(JmxSplitManager.class).in(Scopes.SINGLETON);
binder.bind(JmxPeriodicSampler.class).in(Scopes.SINGLETON);
binder.bind(JmxRecordSetProvider.class).in(Scopes.SINGLETON);
});
Injector injector = app.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(JmxConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public PasswordAuthenticator create(Map<String, String> config)
{
try {
Bootstrap app = new Bootstrap(
binder -> {
configBinder(binder).bindConfig(LdapConfig.class);
binder.bind(LdapAuthenticator.class).in(Scopes.SINGLETON);
});
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(LdapAuthenticator.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(config, "config is null");
try {
Bootstrap app = new Bootstrap(
binder -> binder.bind(NodeManager.class).toInstance(context.getNodeManager()),
new LocalFileModule(catalogName));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(LocalFileConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(catalogName, "catalogName is null");
requireNonNull(config, "config is null");
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new ElasticsearchConnectorModule(),
binder -> {
binder.bind(TypeManager.class).toInstance(context.getTypeManager());
binder.bind(NodeManager.class).toInstance(context.getNodeManager());
binder.bind(ElasticsearchTableDescriptionProvider.class).in(Scopes.SINGLETON);
});
Injector injector = app.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(ElasticsearchConnector.class);
}
catch (Exception e) {
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public ResourceGroupConfigurationManager<VariableMap> create(Map<String, String> config, ResourceGroupConfigurationManagerContext context)
{
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new DbResourceGroupsModule(),
binder -> binder.bind(String.class).annotatedWith(ForEnvironment.class).toInstance(context.getEnvironment()),
binder -> binder.bind(ClusterMemoryPoolManager.class).toInstance(context.getMemoryPoolManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(DbResourceGroupConfigurationManager.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> requiredConfig, ConnectorContext context)
{
requireNonNull(requiredConfig, "requiredConfig is null");
try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) {
Bootstrap app = new Bootstrap(new JdbcModule(catalogName), module);
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(requiredConfig)
.initialize();
return injector.getInstance(JdbcConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(config, "config is null");
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new MongoClientModule(),
binder -> binder.bind(TypeManager.class).toInstance(context.getTypeManager()));
Injector injector = app.strictConfig().doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(MongoConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(catalogName, "catalogName is null");
requireNonNull(config, "requiredConfig is null");
requireNonNull(context, "context is null");
try {
// A plugin is not required to use Guice; it is just very convenient
// Unless you don't really know how to Guice, then it is less convenient
Bootstrap app = new Bootstrap(new JsonModule(), new AccumuloModule(catalogName, context.getTypeManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(AccumuloConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
代码示例来源:origin: prestodb/presto
@Override
public ResourceGroupConfigurationManager<VariableMap> create(Map<String, String> config, ResourceGroupConfigurationManagerContext context)
{
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new FileResourceGroupsModule(),
binder -> binder.bind(ClusterMemoryPoolManager.class).toInstance(context.getMemoryPoolManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(FileResourceGroupConfigurationManager.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> requiredConfig, ConnectorContext context)
{
requireNonNull(requiredConfig, "requiredConfig is null");
try {
// A plugin is not required to use Guice; it is just very convenient
Bootstrap app = new Bootstrap(
new JsonModule(),
new ExampleModule(catalogName, context.getTypeManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(requiredConfig)
.initialize();
return injector.getInstance(ExampleConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public SessionPropertyConfigurationManager create(Map<String, String> config, SessionPropertyConfigurationManagerContext context)
{
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new FileSessionPropertyManagerModule());
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(FileSessionPropertyManager.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> requiredConfig, ConnectorContext context)
{
requireNonNull(requiredConfig, "requiredConfig is null");
try {
// A plugin is not required to use Guice; it is just very convenient
Bootstrap app = new Bootstrap(
new JsonModule(),
new MemoryModule(catalogName, context.getTypeManager(), context.getNodeManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(requiredConfig)
.initialize();
return injector.getInstance(MemoryConnector.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(config, "config is null");
try {
Bootstrap app = new Bootstrap(new JsonModule(),
new KuduModule(catalogName, context.getTypeManager()));
Injector injector =
app.strictConfig().doNotInitializeLogging().setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(KuduConnector.class);
}
catch (RuntimeException e) {
throw e;
}
catch (Exception e) {
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
Injector injector = app.strictConfig().doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
代码示例来源:origin: prestodb/presto
@Override
public Connector create(String catalogName, Map<String, String> config, ConnectorContext context)
{
requireNonNull(catalogName, "catalogName is null");
requireNonNull(config, "config is null");
try {
Bootstrap app = new Bootstrap(
new JsonModule(),
new ElasticsearchConnectorModule(),
binder -> {
binder.bind(TypeManager.class).toInstance(context.getTypeManager());
binder.bind(NodeManager.class).toInstance(context.getNodeManager());
binder.bind(ElasticsearchTableDescriptionProvider.class).toInstance(tableDescriptionSupplier);
});
Injector injector = app.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.initialize();
return injector.getInstance(ElasticsearchConnector.class);
}
catch (Exception e) {
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public ResourceGroupConfigurationManager<VariableMap> create(Map<String, String> config, ResourceGroupConfigurationManagerContext context)
{
try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) {
Bootstrap app = new Bootstrap(
new JsonModule(),
new H2ResourceGroupsModule(),
new NodeModule(),
binder -> binder.bind(ResourceGroupConfigurationManagerContext.class).toInstance(context),
binder -> binder.bind(ClusterMemoryPoolManager.class).toInstance(context.getMemoryPoolManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.quiet()
.initialize();
return injector.getInstance(DbResourceGroupConfigurationManager.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
public ExampleHttpServer()
throws Exception
{
Bootstrap app = new Bootstrap(
new TestingNodeModule(),
new TestingHttpServerModule(),
new ExampleHttpServerModule());
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.initialize();
lifeCycleManager = injector.getInstance(LifeCycleManager.class);
baseUri = injector.getInstance(TestingHttpServer.class).getBaseUrl();
}
代码示例来源:origin: prestodb/presto
.doNotInitializeLogging()
.setRequiredConfigurationProperty("proxy.uri", server.getBaseUrl().toString())
.setRequiredConfigurationProperty("proxy.shared-secret-file", sharedSecretFile.toString())
内容来源于网络,如有侵权,请联系作者删除!