org.apache.nifi.annotation.documentation.Tags类的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.7k)|赞(0)|评价(0)|浏览(154)

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

Tags介绍

暂无

代码示例

代码示例来源：origin: apache/nifi

  1. @Tags({"lookup", "cache", "enrich", "join", "xml", "reloadable", "key", "value"})
  2. @CapabilityDescription("A reloadable XML file-based lookup service." +
  3.     " This service uses Apache Commons Configuration." +
  4.     " Example XML configuration file and how to access specific configuration can be found at" +
  5.     " http://commons.apache.org/proper/commons-configuration/userguide/howto_hierarchical.html")
  6. public class XMLFileLookupService extends CommonsConfigurationLookupService<XMLConfiguration> {
  8. }

代码示例来源：origin: apache/nifi

  1. protected List<String> getTags(final ConfigurableComponent component) {
  2.   final Tags tags = component.getClass().getAnnotation(Tags.class);
  3.   if (tags == null) {
  4.     return Collections.emptyList();
  5.   }
  6.   final String[] tagValues = tags.value();
  7.   return tagValues == null ? Collections.emptyList() : Arrays.asList(tagValues);
  8. }

代码示例来源：origin: apache/nifi

  1. @Tags({"lookup", "cache", "enrich", "join", "properties", "reloadable", "key", "value"})
  2. @CapabilityDescription("A reloadable properties file-based lookup service")
  3. public class PropertiesFileLookupService extends CommonsConfigurationLookupService<PropertiesConfiguration> {
  5. }

代码示例来源：origin: apache/nifi

  1. /**
  2.  * Gets the tags from the specified class.
  3.  */
  4. private Set<String> getTags(final Class<?> cls) {
  5.   final Set<String> tags = new HashSet<>();
  6.   final Tags tagsAnnotation = cls.getAnnotation(Tags.class);
  7.   if (tagsAnnotation != null) {
  8.     for (final String tag : tagsAnnotation.value()) {
  9.       tags.add(tag);
  10.     }
  11.   }
  12.   if (cls.isAnnotationPresent(Restricted.class)) {
  13.     tags.add("restricted");
  14.   }
  15.   return tags;
  16. }

代码示例来源：origin: apache/nifi

  1. /**
  2.  * GCPCredentialsService interface to support getting Google Cloud Platform
  3.  * GoogleCredentials used for instantiating Google cloud services.
  4.  *
  5.  * @see <a href="http://google.github.io/google-auth-library-java/releases/0.5.0/apidocs/com/google/auth/oauth2/GoogleCredentials.html">GoogleCredentials</a>
  6.  */
  7. @Tags({"gcp", "security", "credentials", "auth", "session"})
  8. @CapabilityDescription("Provides GCP GoogleCredentials.")
  9. public interface GCPCredentialsService extends ControllerService {
  11.   /**
  12.    * Get Google Credentials
  13.    * @return Valid Google Credentials suitable for authorizing requests on the platform.
  14.    * @throws ProcessException process exception in case there is problem in getting credentials
  15.    */
  16.   public GoogleCredentials getGoogleCredentials() throws ProcessException;
  17. }

代码示例来源：origin: apache/nifi

  1. private void writeTags(final ConfigurableComponent configurableComponent,
  2.     final XMLStreamWriter xmlStreamWriter) throws XMLStreamException {
  3.   final Tags tags = configurableComponent.getClass().getAnnotation(Tags.class);
  4.   xmlStreamWriter.writeStartElement("h3");
  5.   xmlStreamWriter.writeCharacters("Tags: ");
  6.   xmlStreamWriter.writeEndElement();
  7.   xmlStreamWriter.writeStartElement("p");
  8.   if (tags != null) {
  9.     final String tagString = join(tags.value(), ", ");
  10.     xmlStreamWriter.writeCharacters(tagString);
  11.   } else {
  12.     xmlStreamWriter.writeCharacters("No tags provided.");
  13.   }
  14.   xmlStreamWriter.writeEndElement();
  15. }

代码示例来源：origin: apache/nifi

  1. /**
  2.  * AWSCredentialsProviderService interface to support getting AWSCredentialsProvider used for instantiating
  3.  * aws clients
  4.  *
  5.  * @see <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/AWSCredentialsProvider.html">AWSCredentialsProvider</a>
  6.  */
  7. @Tags({"aws", "security", "credentials", "provider", "session"})
  8. @CapabilityDescription("Provides AWSCredentialsProvider.")
  9. public interface AWSCredentialsProviderService extends ControllerService {
  11.   /**
  12.    * Get credentials provider
  13.    * @return credentials provider
  14.    * @throws ProcessException process exception in case there is problem in getting credentials provider
  15.    *
  16.    * @see  <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/AWSCredentialsProvider.html">AWSCredentialsProvider</a>
  17.    */
  18.   AWSCredentialsProvider getCredentialsProvider() throws ProcessException;
  19. }

代码示例来源：origin: apache/nifi

  1. /**
  2.  * Definition for Database Connection Pooling Service.
  3.  *
  4.  */
  5. @Tags({"dbcp", "jdbc", "database", "connection", "pooling", "store"})
  6. @CapabilityDescription("Provides Database Connection Pooling Service. Connections can be asked from pool and returned after usage.")
  7. public interface DBCPService extends ControllerService {
  8.   Connection getConnection() throws ProcessException;
  10.   /**
  11.    * Allows a Map of attributes to be passed to the DBCPService for use in configuration, etc.
  12.    * An implementation will want to override getConnection() to return getConnection(Collections.emptyMap()),
  13.    * and override this method (possibly with its existing getConnection() implementation).
  14.    * @param attributes a Map of attributes to be passed to the DBCPService. The use of these
  15.    *                   attributes is implementation-specific, and the source of the attributes
  16.    *                   is processor-specific
  17.    * @return a Connection from the specifed/configured connection pool(s)
  18.    * @throws ProcessException if an error occurs while getting a connection
  19.    */
  20.   default Connection getConnection(Map<String,String> attributes) throws ProcessException {
  21.     // default implementation (for backwards compatibility) is to call getConnection()
  22.     // without attributes
  23.     return getConnection();
  24.   }
  25. }

代码示例来源：origin: apache/nifi

  1. @Tags({"lookup", "enrich", "key", "value", "couchbase"})
  2. @CapabilityDescription("Lookup a string value from Couchbase Server associated with the specified key."
  3.     + " The coordinates that are passed to the lookup must contain the key 'key'.")

代码示例来源：origin: apache/nifi

  1. @Tags({"csv", "result", "set", "recordset", "record", "writer", "serializer", "row", "tsv", "tab", "separated", "delimited"})
  2. @CapabilityDescription("Writes the contents of a RecordSet as CSV data. The first line written "
  3.   + "will be the column names (unless the 'Include Header Line' property is false). All subsequent lines will be the values "

代码示例来源：origin: apache/nifi

  1. @Tags({"lookup", "enrich", "key", "value"})
  2. @CapabilityDescription("Allows users to add key/value pairs as User-defined Properties. Each property that is added can be looked up by Property Name. "
  3.   + "The coordinates that are passed to the lookup must contain the key 'key'.")

代码示例来源：origin: apache/nifi

  1. @Tags({"distributed", "set", "distinct", "cache", "server"})
  2. @CapabilityDescription("Provides a set (collection of unique values) cache that can be accessed over a socket. "
  3.     + "Interaction with this service is typically accomplished via a DistributedSetCacheClient service.")

代码示例来源：origin: apache/nifi

  1. @Tags({"text", "freeform", "expression", "language", "el", "record", "recordset", "resultset", "writer", "serialize"})
  2. @CapabilityDescription("Writes the contents of a RecordSet as free-form text. The configured "
  3.   + "text is able to make use of the Expression Language to reference each of the fields that are available "

代码示例来源：origin: apache/nifi

  1. @Tags({"redis", "cache"})
  2. @CapabilityDescription("A service that provides connections to Redis.")
  3. public class RedisConnectionPoolService extends AbstractControllerService implements RedisConnectionPool {

代码示例来源：origin: apache/nifi

  1. @Tags({"tls", "ssl", "secure", "certificate", "keystore", "truststore", "jks", "p12", "pkcs12", "pkcs"})
  2. @CapabilityDescription("Restricted implementation of the SSLContextService. Provides the ability to configure "
  3.     + "keystore and/or truststore properties once and reuse that configuration throughout the application, "

代码示例来源：origin: apache/nifi

  1. "a credential file, the config generated by `gcloud auth application-default login`, AppEngine/Compute Engine" +
  2.     " service accounts, etc.")
  3. @Tags({ "gcp", "credentials","provider" })
  4. public class GCPCredentialsControllerService extends AbstractControllerService implements GCPCredentialsService {

代码示例来源：origin: apache/nifi

  1. @Tags({"ssl", "secure", "certificate", "keystore", "truststore", "jks", "p12", "pkcs12", "pkcs"})
  2. @CapabilityDescription("Provides the ability to configure keystore and/or truststore properties once and reuse "
  3.     + "that configuration throughout the application")

代码示例来源：origin: apache/nifi

  1. @Tags({"disk", "storage", "warning", "monitoring", "repo"})
  2. @CapabilityDescription("Checks the amount of storage space available for the specified directory"
  3.     + " and warns (via a log message and a System-Level Bulletin) if the partition on which it lives exceeds"

代码示例来源：origin: apache/nifi

  1. @Tags({ "example", "resources" })
  2. @CapabilityDescription("This example processor loads a resource from the nar and writes it to the FlowFile content")
  3. public class WriteResourceToStream extends AbstractProcessor {

代码示例来源：origin: apache/nifi

  1. "Default credentials support EC2 instance profile/role, default user profile, environment variables, etc. " +
  2.     "Additional options include access key / secret key pairs, credentials file, named profile, and assume role credentials.")
  3. @Tags({ "aws", "credentials","provider" })
  4. public class AWSCredentialsProviderControllerService extends AbstractControllerService implements AWSCredentialsProviderService {

内容来源于网络，如有侵权，请联系作者删除！

tags

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com