io.druid.guice.annotations.Json类的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(120)

本文整理了Java中io.druid.guice.annotations.Json类的一些代码示例,展示了Json类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Json类的具体详情如下:
包路径:io.druid.guice.annotations.Json
类名称: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);
 }
}

相关文章

Json类方法