本文整理了Java中io.druid.guice.annotations.Json
类的一些代码示例,展示了Json
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Json
类的具体详情如下:
包路径:io.druid.guice.annotations.Json
类名称:Json
暂无
代码示例来源: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 SQLAuditManagerProvider(
Supplier<MetadataStorageTablesConfig> dbTables,
SQLMetadataConnector connector,
Lifecycle lifecycle,
ServiceEmitter emitter,
@Json ObjectMapper mapper,
SQLAuditManagerConfig config
)
{
this.dbTables = dbTables;
this.connector = connector;
this.lifecycle = lifecycle;
this.emitter = emitter;
this.mapper = mapper;
this.config = config;
}
代码示例来源: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: com.n3twork.druid/druid-server
@Inject
public DatabaseRuleManager(
@Json ObjectMapper jsonMapper,
Supplier<DatabaseRuleManagerConfig> config,
Supplier<DbTablesConfig> dbTables,
IDBI dbi
)
{
this.jsonMapper = jsonMapper;
this.config = config;
this.dbTables = dbTables;
this.dbi = dbi;
this.rules = new AtomicReference<ConcurrentHashMap<String, List<Rule>>>(
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-indexing-service
@JsonCreator
public GalaxyEC2UserData(
@JacksonInject @Json ObjectMapper jsonMapper,
@JsonProperty("env") String env,
@JsonProperty("version") String version,
@JsonProperty("type") String type
)
{
this.jsonMapper = jsonMapper;
this.env = env;
this.version = version;
this.type = type;
}
代码示例来源:origin: com.n3twork.druid/druid-server
public AsyncQueryForwardingServlet(
@Json ObjectMapper jsonMapper,
@Smile ObjectMapper smileMapper,
QueryHostFinder hostFinder,
RoutingDruidClient routingDruidClient,
ServiceEmitter emitter,
RequestLogger requestLogger
)
{
this.jsonMapper = jsonMapper;
this.smileMapper = smileMapper;
this.hostFinder = hostFinder;
this.routingDruidClient = routingDruidClient;
this.emitter = emitter;
this.requestLogger = requestLogger;
}
代码示例来源:origin: io.druid/druid-server
@Inject
public SQLAuditManager(
SQLMetadataConnector connector,
Supplier<MetadataStorageTablesConfig> dbTables,
ServiceEmitter emitter,
@Json ObjectMapper jsonMapper,
SQLAuditManagerConfig config
)
{
this.dbi = connector.getDBI();
this.dbTables = dbTables;
this.emitter = emitter;
this.jsonMapper = jsonMapper;
this.config = config;
}
代码示例来源: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!