org.apache.nifi.annotation.documentation.Tags.<init>()方法的使用及代码示例

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

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

Tags.<init>介绍

暂无

代码示例

代码示例来源: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

@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

/**
 * 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

/**
 * 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'.")
public class CouchbaseKeyValueLookupService extends AbstractCouchbaseLookupService implements StringLookupService {

代码示例来源: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 "
  + "corresponding to the record fields.")

代码示例来源: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'.")
public class SimpleKeyValueLookupService extends AbstractControllerService implements StringLookupService {

代码示例来源: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.")
public class DistributedSetCacheServer extends DistributedCacheServer {

代码示例来源: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 "
  + "in a Record. Each record in the RecordSet will be separated by a single newline character.")

代码示例来源: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, "
    + "but only allows a restricted set of TLS/SSL protocols to be chosen (no SSL protocols are supported). The set of protocols selectable will "

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

@CapabilityDescription("Defines credentials for Google Cloud Platform processors. " +
    "Uses Application Default credentials without configuration. " +
    "Application Default credentials support environmental variable (GOOGLE_APPLICATION_CREDENTIALS) pointing to " +
    "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")
public interface SSLContextService extends ControllerService {

代码示例来源: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"
    + " some configurable threshold of storage space")

代码示例来源: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

@CapabilityDescription("Defines credentials for Amazon Web Services processors. " +
    "Uses default credentials without configuration. " +
    "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 {

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

@Tags({"json", "tree", "record", "reader", "parser"})
@CapabilityDescription("Parses JSON into individual Record objects. While the reader expects each record "
    + "to be well-formed JSON, the content of a FlowFile may consist of many records, each as a well-formed "
    + "JSON array or JSON object with optional whitespace between them, such as the common 'JSON-per-line' format. "

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

@InputRequirement(Requirement.INPUT_FORBIDDEN)
@CapabilityDescription("Consumes messages from Email Server using POP3 protocol. "
    + "The raw-bytes of each received email message are written as contents of the FlowFile")
@Tags({ "Email", "POP3", "Get", "Ingest", "Ingress", "Message", "Consume" })
public class ConsumePOP3 extends AbstractEmailProcessor<Pop3MailReceiver> {

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

@Tags({"distributed", "cluster", "map", "cache", "server", "key/value"})
@CapabilityDescription("Provides a map (key/value) cache that can be accessed over a socket. Interaction with this service"
    + " is typically accomplished via a DistributedMapCacheClient service.")
@SeeAlso(classNames = {"org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService", "org.apache.nifi.ssl.StandardSSLContextService"})

相关文章