com.hurence.logisland.annotation.documentation.Tags类的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(139)

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

Tags介绍

暂无

代码示例

代码示例来源:origin: com.hurence.logisland/logisland-ml-client-service-api

@Tags({"ml", "client"})
@CapabilityDescription("A controller service for accessing an ML client.")
public interface MLClientService extends  ControllerService {

  PropertyDescriptor ML_MODEL_FILE_PATH = new PropertyDescriptor.Builder()
      .name("ml.model.file.path")
      .description("path to the pre-trained MNIST Deep Learning model file.")
      .addValidator(StandardValidators.FILE_EXISTS_VALIDATOR)
      .build();

  /**
   * Restore the previously computed Neural Network model.
   *
   */
  Model restoreModel() ;

}

代码示例来源:origin: com.hurence.logisland/logisland-documentation

private void writeTags(final ConfigurableComponent configurableComponent,
            final JsonGenerator generator) throws XMLStreamException, IOException {
  final Tags tags = configurableComponent.getClass().getAnnotation(Tags.class);
  if (tags != null) {
    generator.writeArrayFieldStart("tags");
    for (String tag:tags.value()       ) {
      generator.writeString(tag);
    }
    generator.writeEndArray();
  }
}

代码示例来源:origin: com.hurence.logisland/logisland-solr_5_5_5-client-service

@Tags({ "solr", "client"})
@CapabilityDescription("Implementation of ElasticsearchClientService for Solr 5.5.5.")
public class Solr_5_5_5_ClientService extends SolrClientService {
  private static org.slf4j.Logger logger = LoggerFactory.getLogger(Solr_5_5_5_ClientService.class);

  protected SolrClient createCloudClient(String connectionString, String collection) {
    CloudSolrClient cloudSolrClient = new CloudSolrClient(connectionString);
    cloudSolrClient.setDefaultCollection(collection);
    cloudSolrClient.setZkClientTimeout(30000);
    cloudSolrClient.setZkConnectTimeout(30000);

    return cloudSolrClient;
  }

  protected SolrClient createHttpClient(String connectionString, String collection) {
    return new HttpSolrClient(connectionString + "/" + collection);
  }
}

代码示例来源:origin: com.hurence.logisland/logisland-documentation

private void writeTags(final ConfigurableComponent configurableComponent,
            final XMLStreamWriter xmlStreamWriter) throws XMLStreamException {
  final Tags tags = configurableComponent.getClass().getAnnotation(Tags.class);
  xmlStreamWriter.writeStartElement("h3");
  xmlStreamWriter.writeCharacters("Tags: ");
  xmlStreamWriter.writeEndElement();
  xmlStreamWriter.writeStartElement("p");
  if (tags != null) {
    final String tagString = join(tags.value(), ", ");
    xmlStreamWriter.writeCharacters(tagString);
  } else {
    xmlStreamWriter.writeCharacters("None.");
  }
  xmlStreamWriter.writeEndElement();
}

代码示例来源:origin: com.hurence.logisland/logisland-api

@Tags({"stream", "mock", "test"})
@CapabilityDescription("This is a stream for test purpose")
public class MockRecordStream extends AbstractRecordStream {

  public static final PropertyDescriptor FAKE_MESSAGE = new PropertyDescriptor.Builder()
      .name("fake.message")
      .description("a fake message")
      .required(true)
      .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
      .defaultValue("yoyo")
      .build();


  @Override
  public final List<PropertyDescriptor> getSupportedPropertyDescriptors() {
    final List<PropertyDescriptor> descriptors = new ArrayList<>();
    descriptors.add(FAKE_MESSAGE);

    return Collections.unmodifiableList(descriptors);
  }

}

代码示例来源:origin: com.hurence.logisland/logisland-documentation

private void writeTags(final ConfigurableComponent configurableComponent,
            final RstPrintWriter rstWriter) throws XMLStreamException {
  final Tags tags = configurableComponent.getClass().getAnnotation(Tags.class);
  rstWriter.writeSectionTitle(3, "Tags");
  if (tags != null) {
    final String tagString = join(tags.value(), ", ");
    rstWriter.println(tagString);
  } else {
    rstWriter.println("None.");
  }
}

代码示例来源:origin: com.hurence.logisland/logisland-cache-service-api

@Tags({"cache", "service", "key", "value", "pair"})
@CapabilityDescription("A controller service for caching data")
public interface CacheService<K,V> extends ControllerService {

代码示例来源:origin: com.hurence.logisland/logisland-api

@Tags({"cache", "service", "key", "value", "pair"})
@CapabilityDescription("A controller service for caching data")
public interface CacheService<K,V> extends ControllerService {

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

@Tags({"record", "fields", "remove", "delete"})
@CapabilityDescription("Removes a list of fields defined by a comma separated list of field names")
public class RemoveFields extends AbstractProcessor {

代码示例来源:origin: com.hurence.logisland/logisland-solr_6_6

@Tags({ "solr", "client"})
@CapabilityDescription("Implementation of ElasticsearchClientService for Solr 5.5.5.")
public class Solr_6_6_2_ClientService extends SolrClientService {

代码示例来源:origin: com.hurence.logisland/logisland-ml-client-service

@Tags({"ml", "client"})
@CapabilityDescription("A controller service for accessing an Machine Learning  client.")
public class MLClientServiceImpl extends AbstractControllerService implements MLClientService {

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

@Tags({"record", "fields", "remove", "delete"})
@CapabilityDescription("Keep only distinct records based on a given field")
public class SelectDistinctRecords extends AbstractProcessor {

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

@Tags({"record", "fields", "remove", "delete"})
@CapabilityDescription("Keep only records based on a given field value")
public class FilterRecords extends AbstractProcessor {

代码示例来源:origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Tags({"cache", "service", "key", "value", "pair", "LRU"})
@CapabilityDescription("A controller service for caching data by key value pair with LRU (last recently used) strategy. using LinkedHashMap")
public class LRUKeyValueCacheService<K,V>  extends AbstractControllerService implements CacheService<K,V> {

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

@Tags({"record", "properties", "parser"})
@CapabilityDescription("Parse a field made of key=value fields separated by spaces\n" +
    "a string like \"a=1 b=2 c=3\" will add a,b & c fields, respectively with values 1,2 & 3 to the current Record")

代码示例来源:origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Tags({"cache", "service", "key", "value", "pair", "LRU"})
@CapabilityDescription("A controller service for caching data by key value pair with LRU (last recently used) strategy. using LinkedHashMap")
public class LRUCache<K, V> implements Cache<K,V> {

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

@Tags({"record", "debug"})
@CapabilityDescription("This is a processor that logs incoming records")
public class DebugStream extends AbstractProcessor {

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

@Tags({"hadoop", "hbase"})
@CapabilityDescription("Adds the Contents of a Record to HBase as the value of a single cell")
public class PutHBaseCell extends AbstractPutHBase {

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

@Tags({"analytic", "sampler", "record", "iot", "timeseries"})
@CapabilityDescription("Query matching based on `Luwak <http://www.confluent.io/blog/real-time-full-text-search-with-luwak-and-samza/>`_\n\n" +
    "you can use this processor to handle custom events defined by lucene queries\n" +

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

@Tags({"elasticsearch"})
@CapabilityDescription("Indexes the content of a Record in Elasticsearch using elasticsearch's bulk processor")
public class BulkAddElasticsearch extends AbstractElasticsearchProcessor

相关文章

Tags类方法