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

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

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

Tags介绍

暂无

代码示例

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

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

}

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

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

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

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

}

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

/**
 * Gets the tags from the specified class.
 */
private Set<String> getTags(final Class<?> cls) {
  final Set<String> tags = new HashSet<>();
  final Tags tagsAnnotation = cls.getAnnotation(Tags.class);
  if (tagsAnnotation != null) {
    for (final String tag : tagsAnnotation.value()) {
      tags.add(tag);
    }
  }
  if (cls.isAnnotationPresent(Restricted.class)) {
    tags.add("restricted");
  }
  return tags;
}

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

/**
 * GCPCredentialsService interface to support getting Google Cloud Platform
 * GoogleCredentials used for instantiating Google cloud services.
 *
 * @see <a href="http://google.github.io/google-auth-library-java/releases/0.5.0/apidocs/com/google/auth/oauth2/GoogleCredentials.html">GoogleCredentials</a>
 */
@Tags({"gcp", "security", "credentials", "auth", "session"})
@CapabilityDescription("Provides GCP GoogleCredentials.")
public interface GCPCredentialsService extends ControllerService {

  /**
   * Get Google Credentials
   * @return Valid Google Credentials suitable for authorizing requests on the platform.
   * @throws ProcessException process exception in case there is problem in getting credentials
   */
  public GoogleCredentials getGoogleCredentials() throws ProcessException;
}

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

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("No tags provided.");
  }
  xmlStreamWriter.writeEndElement();
}

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

/**
 * AWSCredentialsProviderService interface to support getting AWSCredentialsProvider used for instantiating
 * aws clients
 *
 * @see <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/AWSCredentialsProvider.html">AWSCredentialsProvider</a>
 */
@Tags({"aws", "security", "credentials", "provider", "session"})
@CapabilityDescription("Provides AWSCredentialsProvider.")
public interface AWSCredentialsProviderService extends ControllerService {

  /**
   * Get credentials provider
   * @return credentials provider
   * @throws ProcessException process exception in case there is problem in getting credentials provider
   *
   * @see  <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/AWSCredentialsProvider.html">AWSCredentialsProvider</a>
   */
  AWSCredentialsProvider getCredentialsProvider() throws ProcessException;
}

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

/**
 * Definition for Database Connection Pooling Service.
 *
 */
@Tags({"dbcp", "jdbc", "database", "connection", "pooling", "store"})
@CapabilityDescription("Provides Database Connection Pooling Service. Connections can be asked from pool and returned after usage.")
public interface DBCPService extends ControllerService {
  Connection getConnection() throws ProcessException;

  /**
   * Allows a Map of attributes to be passed to the DBCPService for use in configuration, etc.
   * An implementation will want to override getConnection() to return getConnection(Collections.emptyMap()),
   * and override this method (possibly with its existing getConnection() implementation).
   * @param attributes a Map of attributes to be passed to the DBCPService. The use of these
   *                   attributes is implementation-specific, and the source of the attributes
   *                   is processor-specific
   * @return a Connection from the specifed/configured connection pool(s)
   * @throws ProcessException if an error occurs while getting a connection
   */
  default Connection getConnection(Map<String,String> attributes) throws ProcessException {
    // default implementation (for backwards compatibility) is to call getConnection()
    // without attributes
    return getConnection();
  }
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

相关文章