本文整理了Java中io.druid.guice.annotations.Json.<init>()
方法的一些代码示例,展示了Json.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Json.<init>()
方法的具体详情如下:
包路径:io.druid.guice.annotations.Json
类名称:Json
方法名:<init>
暂无
代码示例来源:origin: io.druid/druid-server
@Inject
public CuratorDruidNodeDiscoveryProvider(
CuratorFramework curatorFramework,
ZkPathsConfig config,
@Json ObjectMapper jsonMapper
)
{
this.curatorFramework = curatorFramework;
this.config = config;
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid/druid-server
@Inject
public CuratorDruidNodeAnnouncer(
Announcer announcer,
ZkPathsConfig config,
@Json ObjectMapper jsonMapper
)
{
this.announcer = announcer;
this.config = config;
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid/druid-processing
@Inject
public DefaultGenericQueryMetricsFactory(@Json ObjectMapper jsonMapper)
{
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid/druid-processing
@Inject
public DefaultTimeseriesQueryMetricsFactory(@Json ObjectMapper jsonMapper)
{
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid.extensions/druid-s3-extensions
@Inject
public S3DataSegmentArchiver(
@Json ObjectMapper mapper,
RestS3Service s3Client,
S3DataSegmentArchiverConfig archiveConfig,
S3DataSegmentPusherConfig restoreConfig
)
{
super(s3Client, restoreConfig);
this.mapper = mapper;
this.archiveConfig = archiveConfig;
this.restoreConfig = restoreConfig;
}
代码示例来源:origin: com.n3twork.druid/druid-indexing-service
@Inject
public EC2AutoScalingStrategy(
@Json ObjectMapper jsonMapper,
AmazonEC2 amazonEC2Client,
SimpleResourceManagementConfig config,
Supplier<WorkerSetupData> workerSetupDataRef
)
{
this.jsonMapper = jsonMapper;
this.amazonEC2Client = amazonEC2Client;
this.config = config;
this.workerSetupDataRef = workerSetupDataRef;
}
代码示例来源:origin: io.druid/druid-processing
@Inject
public DefaultTopNQueryMetricsFactory(@Json ObjectMapper jsonMapper)
{
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid/druid-processing
@Inject
public DefaultGroupByQueryMetricsFactory(@Json ObjectMapper jsonMapper)
{
this.jsonMapper = jsonMapper;
}
代码示例来源:origin: io.druid/druid-server
@Inject
public CoordinatorRuleManager(
@Json ObjectMapper jsonMapper,
Supplier<TieredBrokerConfig> config,
DruidLeaderClient druidLeaderClient
)
{
this.jsonMapper = jsonMapper;
this.config = config;
this.druidLeaderClient = druidLeaderClient;
this.rules = new AtomicReference<>(
new ConcurrentHashMap<String, List<Rule>>()
);
}
代码示例来源:origin: io.druid/druid-server
public ListenerResource(
final @Json ObjectMapper jsonMapper,
final @Smile ObjectMapper smileMapper,
final ListenerHandler handler
)
{
this.jsonMapper = Preconditions.checkNotNull(jsonMapper, "jsonMapper");
this.smileMapper = Preconditions.checkNotNull(smileMapper, "smileMapper");
this.handler = Preconditions.checkNotNull(handler, "listener handler");
}
代码示例来源:origin: io.druid/druid-server
@Inject
public SQLMetadataSupervisorManager(
@Json ObjectMapper jsonMapper,
SQLMetadataConnector connector,
Supplier<MetadataStorageTablesConfig> dbTables
)
{
this.jsonMapper = jsonMapper;
this.connector = connector;
this.dbTables = dbTables;
this.dbi = connector.getDBI();
}
代码示例来源:origin: io.druid/druid-server
@Inject
public LookupCoordinatorResource(
final LookupCoordinatorManager lookupCoordinatorManager,
final @Smile ObjectMapper smileMapper,
final @Json ObjectMapper jsonMapper
)
{
this.smileMapper = smileMapper;
this.jsonMapper = jsonMapper;
this.lookupCoordinatorManager = lookupCoordinatorManager;
}
代码示例来源:origin: io.druid.extensions/druid-kafka-indexing-service
@Inject
public KafkaIndexTaskClientFactory(
@EscalatedGlobal HttpClient httpClient,
@Json ObjectMapper mapper
)
{
this.httpClient = httpClient;
this.mapper = mapper;
}
代码示例来源:origin: io.druid/druid-server
@Inject
public SegmentListerResource(
@Json ObjectMapper jsonMapper,
@Smile ObjectMapper smileMapper,
@Nullable BatchDataSegmentAnnouncer announcer,
@Nullable SegmentLoadDropHandler loadDropRequestHandler
)
{
this.jsonMapper = jsonMapper;
this.smileMapper = smileMapper;
this.announcer = announcer;
this.loadDropRequestHandler = loadDropRequestHandler;
}
代码示例来源:origin: io.druid/druid-services
@Provides
@LazySingleton
public Task readTask(@Json ObjectMapper mapper, ExecutorLifecycleConfig config)
{
try {
return mapper.readValue(config.getTaskFile(), Task.class);
}
catch (IOException e) {
throw Throwables.propagate(e);
}
}
代码示例来源:origin: com.n3twork.druid/druid-server
@Provides
@Singleton
public JacksonJsonProvider getJacksonJsonProvider(@Json ObjectMapper objectMapper)
{
final JacksonJsonProvider provider = new JacksonJsonProvider();
provider.setMapper(objectMapper);
return provider;
}
代码示例来源:origin: io.druid/druid-server
@Provides
@Singleton
public JacksonJsonProvider getJacksonJsonProvider(@Json ObjectMapper objectMapper)
{
final JacksonJsonProvider provider = new JacksonJsonProvider();
provider.setMapper(objectMapper);
return provider;
}
代码示例来源:origin: io.druid/druid-processing
@Provides @LazySingleton @Json
public ObjectMapper jsonMapper()
{
return new DefaultObjectMapper();
}
代码示例来源:origin: com.n3twork.druid/druid-processing
@Provides @LazySingleton @Json
public ObjectMapper jsonMapper()
{
return new DefaultObjectMapper();
}
代码示例来源:origin: com.n3twork.druid/druid-common
@Provides @LazySingleton @Json
public ObjectMapper getJsonMapper(final Injector injector)
{
setupJackson(injector, jsonMapper);
return jsonMapper;
}
内容来源于网络,如有侵权,请联系作者删除!