本文整理了Java中com.hurence.logisland.component.PropertyValue.asControllerService()方法的一些代码示例，展示了PropertyValue.asControllerService()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。PropertyValue.asControllerService()方法的具体详情如下：
包路径：com.hurence.logisland.component.PropertyValue
类名称：PropertyValue
方法名：asControllerService

PropertyValue.asControllerService介绍

暂无

代码示例

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
public void init(final ProcessContext context) {
  datastoreClientService = context.getPropertyValue(DATASTORE_CLIENT_SERVICE).asControllerService(DatastoreClientService.class);
  if (datastoreClientService == null) {
    logger.error("Datastore client service is not initialized!");
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-elasticsearch-plugin

@Override
public void init(final ProcessContext context) {
  elasticsearchClientService = context.getPropertyValue(ELASTICSEARCH_CLIENT_SERVICE).asControllerService(ElasticsearchClientService.class);
  if(elasticsearchClientService == null) {
    logger.error("Elasticsearch client service is not initialized!");
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-enrichment-plugin

@Override
public void init(final ProcessContext context) {
  cacheService = context.getPropertyValue(CONFIG_CACHE_SERVICE).asControllerService(CacheService.class);
  if(cacheService == null) {
    logger.error("Cache service is not initialized!");
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-web-analytics-plugin

@Override
public void init(final ProcessContext context) {
  debug = context.getPropertyValue(CONFIG_DEBUG).asBoolean();
  /**
   * Get source of traffic service (aka Elasticsearch service) and the cache
   */
  super.init(context);
  cacheService = context.getPropertyValue(CONFIG_CACHE_SERVICE).asControllerService(CacheService.class);
  if(cacheService == null) {
    logger.error("Cache service is not initialized!");
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-enrichment-plugin

ipToGeoService = context.getPropertyValue(IP_TO_GEO_SERVICE).asControllerService(IpToGeoService.class);
if(ipToGeoService == null) {
  logger.error("IpToGeoService service is not initialized!");
cacheService = context.getPropertyValue(CONFIG_CACHE_SERVICE).asControllerService(CacheService.class);
if(cacheService == null) {
  logger.error("Cache service is not initialized!");

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
public void init(ProcessContext context) {
  this.clientService = context.getPropertyValue(HBASE_CLIENT_SERVICE).asControllerService(HBaseClientService.class);
  if (context.getPropertyValue(RECORD_SCHEMA).isSet()) {
    serializer = SerializerProvider.getSerializer(
        context.getPropertyValue(RECORD_SERIALIZER).asString(),
        context.getPropertyValue(RECORD_SCHEMA).asString());
  } else {
    serializer = SerializerProvider.getSerializer(context.getPropertyValue(RECORD_SERIALIZER).asString(), null);
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

sandbox = NashornSandboxes.create();
CacheService<String, String> cacheService = context.getPropertyValue(JS_CACHE_SERVICE).asControllerService(CacheService.class);
datastoreClientService = context.getPropertyValue(DATASTORE_CLIENT_SERVICE).asControllerService(DatastoreClientService.class);
if (datastoreClientService == null) {
  logger.error("Datastore client service is not initialized!");

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
public void init(final ProcessContext context) {
  clientService = context.getPropertyValue(HBASE_CLIENT_SERVICE).asControllerService(HBaseClientService.class);
  if(clientService == null)
    logger.error("HBase client service is not initialized!");
  if (context.getPropertyValue(RECORD_SCHEMA).isSet()) {
    serializer = SerializerProvider.getSerializer(
        context.getPropertyValue(RECORD_SERIALIZER).asString(),
        context.getPropertyValue(RECORD_SCHEMA).asString());
  } else {
    serializer = SerializerProvider.getSerializer(context.getPropertyValue(RECORD_SERIALIZER).asString(), null);
  }
}