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