本文整理了Java中com.hurence.logisland.annotation.documentation.Tags
类的一些代码示例,展示了Tags
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tags
类的具体详情如下:
包路径:com.hurence.logisland.annotation.documentation.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
内容来源于网络,如有侵权,请联系作者删除!