All controllers (alphabetical)¶

This topic provides a list of all openflow controllers in alphabetical order. The list includes:

Type of controller (Snowflake or not)

The name of each controller

A summary of each controller

A¶

	Controller	Description
	ADLSCredentialsControllerService	Defines credentials for ADLS processors.
	ADLSCredentialsControllerServiceLookup	Provides an ADLSCredentialsService that can be used to dynamically select another ADLSCredentialsService.
	AmazonGlueSchemaRegistry	Provides a Schema Registry that interacts with the AWS Glue Schema Registry so that those Schemas that are stored in the Glue Schema Registry can be used in NiFi.
Snowflake	AmazonMSKConnectionService	Provides and manages connections to AWS MSK Kafka Brokers for producer or consumer operations.
	ApicurioSchemaRegistry	Provides a Schema Registry that interacts with the Apicurio Schema Registry so that those Schemas that are stored in the Apicurio Schema Registry can be used in NiFi.
	AvroReader	Parses Avro data and returns each Avro record as an separate Record object.
	AvroRecordSetWriter	Writes the contents of a RecordSet in Binary Avro format.
	AvroSchemaRegistry	Provides a service for registering and accessing schemas.
	AWSCredentialsProviderControllerService	Defines credentials for Amazon Web Services processors.
	AzureBlobStorageFileResourceService	Provides an Azure Blob Storage file resource for other components.
	AzureCosmosDBClientService	Provides a controller service that configures a connection to Cosmos DB (Core SQL API) and provides access to that connection to other Cosmos DB-related components.
	AzureDataLakeStorageFileResourceService	Provides an Azure Data Lake Storage (ADLS) file resource for other components.
	AzureEventHubRecordSink	Format and send Records to Azure Event Hubs
	AzureStorageCredentialsControllerService_v12	Provides credentials for Azure Storage processors using Azure Storage client library v12.
	AzureStorageCredentialsControllerServiceLookup_v12	Provides an AzureStorageCredentialsService_v12 that can be used to dynamically select another AzureStorageCredentialsService_v12.

C¶

	Controller	Description
	CEFReader	Parses CEF (Common Event Format) events, returning each row as a record.
	ConfluentEncodedSchemaReferenceReader	Reads Schema Identifier according to Confluent encoding as a header consisting of a byte marker and an integer represented as four bytes
	ConfluentEncodedSchemaReferenceWriter	Writes Schema Identifier according to Confluent encoding as a header consisting of a byte marker and an integer represented as four bytes
	ConfluentSchemaRegistry	Provides a Schema Registry that interacts with the Confluent Schema Registry so that those Schemas that are stored in the Confluent Schema Registry can be used in NiFi.
	CSVReader	Parses CSV-formatted data, returning each row in the CSV file as a separate record.
	CSVRecordLookupService	A reloadable CSV file-based lookup service.
	CSVRecordSetWriter	Writes the contents of a RecordSet as CSV data.

D¶

	Controller	Description
Snowflake	DatabaseLookup	A Lookup Service that allows for enrichment with a database using a user-specified SQL statement.
	DatabaseRecordLookupService	A relational-database-based lookup service.
	DatabaseRecordSink	Provides a service to write records using a configured database connection.
	DBCPConnectionPool	Provides Database Connection Pooling Service.
	DBCPConnectionPoolLookup	Provides a DBCPService that can be used to dynamically select another DBCPService.
	DeveloperBoxClientService	Provides Box client objects through which Box API calls can be used.
	DistributedMapCacheLookupService	Allows to choose a distributed map cache client to retrieve the value associated to a key.

E¶

	Controller	Description
	ElasticSearchClientServiceImpl	A controller service for accessing an Elasticsearch client, using the Elasticsearch (low-level) REST Client.
	ElasticSearchLookupService	Lookup a record from Elasticsearch Server associated with the specified document ID.
	ElasticSearchStringLookupService	Lookup a string value from Elasticsearch Server associated with the specified document ID.
	EmailRecordSink	Provides a RecordSinkService that can be used to send records in email using the specified writer for formatting.
	EmbeddedHazelcastCacheManager	A service that runs embedded Hazelcast and provides cache instances backed by that.
	ExcelReader	Parses a Microsoft Excel document returning each row in each sheet as a separate record.
	ExternalHazelcastCacheManager	A service that provides cache instances backed by Hazelcast running outside of NiFi.

F¶

	Controller	Description
	FreeFormTextRecordSetWriter	Writes the contents of a RecordSet as free-form text.

G¶

	Controller	Description
	GCPCredentialsControllerService	Defines credentials for Google Cloud Platform processors.
	GCSFileResourceService	Provides a Google Compute Storage (GCS) file resource for other components.
	GrokReader	Provides a mechanism for reading unstructured text data, such as log files, and structuring the data so that it can be processed.

H¶

	Controller	Description
	HazelcastMapCacheClient	An implementation of DistributedMapCacheClient that uses Hazelcast as the backing cache.
	HikariCPConnectionPool	Provides Database Connection Pooling Service based on HikariCP.
	HttpRecordSink	Format and send Records to a configured uri using HTTP post.

I¶

	Controller	Description
	IPLookupService	A lookup service that provides several types of enrichment information for IP addresses.

J¶

	Controller	Description
	JettyWebSocketClient	Implementation of WebSocketClientService.
	JettyWebSocketServer	Implementation of WebSocketServerService.
	JMSConnectionFactoryProvider	Provides a generic service to create vendor specific javax.
	JndiJmsConnectionFactoryProvider	Provides a service to lookup an existing JMS ConnectionFactory using the Java Naming and Directory Interface (JNDI).
	JsonConfigBasedBoxClientService	Provides Box client objects through which Box API calls can be used.
	JsonPathReader	Parses JSON records and evaluates user-defined JSON Path’s against each JSON object.
	JsonRecordSetWriter	Writes the results of a RecordSet as either a JSON Array or one JSON object per line.
Snowflake	JsonTableColumnFilter	Provides a table column filter based on a JSON configuration.
	JsonTreeReader	Parses JSON into individual Record objects.

K¶

	Controller	Description
Snowflake	Kafka3ConnectionService	Provides and manages connections to Kafka Brokers for producer or consumer operations.

L¶

	Controller	Description
	LoggingRecordSink	Provides a RecordSinkService that can be used to log records to the application log (nifi-app.

M¶

	Controller	Description
	MapCacheClientService	Provides the ability to communicate with a MapCacheServer.
	MapCacheServer	Provides a map (key/value) cache that can be accessed over a socket.
Snowflake	MicrosoftClientCertificateOAuth2TokenProvider	Provides OAuth2 access tokens for the Microsoft Graph API using client_credentials with a client certificate.
Snowflake	MicrosoftGraphAuthenticationProvider	Provides authentication for the Microsoft Graph API, which can be used for interacting with Microsoft 365 services.
	MongoDBControllerService	Provides a controller service that configures a connection to MongoDB and provides access to that connection to other Mongo-related components.
	MongoDBLookupService	Provides a lookup service based around MongoDB.

P¶

	Controller	Description
Snowflake	ParquetIcebergWriter	Provides record serialization for Apache Iceberg using Apache Parquet formatting
	PEMEncodedSSLContextProvider	SSLContext Provider configurable using PEM Private Key and Certificate files.
Snowflake	PolarisIcebergCatalog	Provides Apache Iceberg integration with Apache Polaris Catalog access over REST HTTP
	PropertiesFileLookupService	A reloadable properties file-based lookup service

R¶

	Controller	Description
	ReaderLookup	Provides a RecordReaderFactory that can be used to dynamically select another RecordReaderFactory.
	RecordSetWriterLookup	Provides a RecordSetWriterFactory that can be used to dynamically select another RecordSetWriterFactory.
	RecordSinkServiceLookup	Provides a RecordSinkService that can be used to dynamically select another RecordSinkService.
	RedisConnectionPoolService	A service that provides connections to Redis.
	RedisDistributedMapCacheClientService	An implementation of DistributedMapCacheClient that uses Redis as the backing cache.
	RestLookupService	Use a REST service to look up values.

S¶

	Controller	Description
	S3FileResourceService	Provides an Amazon Web Services (AWS) S3 file resource for other components.
	ScriptedLookupService	Allows the user to provide a scripted LookupService instance in order to enrich records from an incoming flow file.
	ScriptedReader	Allows the user to provide a scripted RecordReaderFactory instance in order to read/parse/generate records from an incoming flow file.
	ScriptedRecordSetWriter	Allows the user to provide a scripted RecordSetWriterFactory instance in order to write records to an outgoing flow file.
	ScriptedRecordSink	Allows the user to provide a scripted RecordSinkService instance in order to transmit records to the desired target.
	SetCacheClientService	Provides the ability to communicate with a SetCacheServer.
	SetCacheServer	Provides a set (collection of unique values) cache that can be accessed over a socket.
	SimpleCsvFileLookupService	A reloadable CSV file-based lookup service.
	SimpleDatabaseLookupService	A relational-database-based lookup service.
	SimpleKeyValueLookupService	Allows users to add key/value pairs as User-defined Properties.
	SimpleRedisDistributedMapCacheClientService	An implementation of DistributedMapCacheClient that uses Redis as the backing cache.
	SimpleScriptedLookupService	Allows the user to provide a scripted LookupService instance in order to enrich records from an incoming flow file.
	SlackRecordSink	Format and send Records to a configured Channel using the Slack Post Message API.
	SmbjClientProviderService	Provides access to SMB Sessions with shared authentication credentials.
Snowflake	SnowflakeConnectionService	Provides pooled database connections to Snowflake services
Snowflake	SnowflakeDatabaseDialectService	Database Dialect Service supporting Snowflake.
Snowflake	StandardAnthropicLLMService	A Controller Service that provides integration with Anthropic’s Claude AI models through their Messages API.
	StandardAzureCredentialsControllerService	Provide credentials to use with an Azure client.
Snowflake	StandardDatabricksWorkspaceClientService	Databricks client.
	StandardDropboxCredentialService	Defines credentials for Dropbox processors.
	StandardFileResourceService	Provides a file resource for other components.
	StandardHashiCorpVaultClientService	A controller service for interacting with HashiCorp Vault.
	StandardHttpContextMap	Provides the ability to store and retrieve HTTP requests and responses external to a Processor, so that multiple Processors can interact with the same HTTP request.
Snowflake	StandardHubSpotClientService	HubSpot Controller Service to integrate with HubSpot HTTP api.
	StandardJsonSchemaRegistry	Provides a service for registering and accessing JSON schemas.
	StandardKustoIngestService	Sends batches of flowfile content or stream flowfile content to an Azure ADX cluster.
	StandardKustoQueryService	Standard implementation of Kusto Query Service for Azure Data Explorer
Snowflake	StandardMilvusConnectionService	Provides connection service to a Milvus instance
	StandardOauth2AccessTokenProvider	Provides OAuth 2.
Snowflake	StandardOCRService	Provides integration to Openflow OCR Service
Snowflake	StandardOpenAILLMService	A Controller Service that provides integration with OpenAI’s Chat Completion API.
	StandardPGPPrivateKeyService	PGP Private Key Service provides Private Keys loaded from files or properties
	StandardPGPPublicKeyService	PGP Public Key Service providing Public Keys loaded from files
	StandardPrivateKeyService	Private Key Service provides access to a Private Key loaded from configured sources
	StandardProxyConfigurationService	Provides a set of configurations for different NiFi components to use a proxy server.
	StandardRestrictedSSLContextService	Restricted implementation of the SSLContextService.
	StandardS3EncryptionService	Adds configurable encryption to S3 Put and S3 Fetch operations.
	StandardSSLContextService	Standard implementation of the SSLContextService.
Snowflake	StandardTableStateService	A controller Service that provides and manages table state.
Snowflake	StandardVectaraClientService	Vectara Controller Service to integrate with Vectara HTTP Api.
	StandardWebClientServiceProvider	Web Client Service Provider with support for configuring standard HTTP connection properties
Snowflake	StateManagedCdcSchemaRegistry	Uses the in-built NiFi State Management to store the hashes of table schemas.
	Syslog5424Reader	Provides a mechanism for reading RFC 5424 compliant Syslog data, such as log files, and structuring the data so that it can be processed.
	SyslogReader	Attempts to parses the contents of a Syslog message in accordance to RFC5424 and RFC3164.

U¶

	Controller	Description
	UDPEventRecordSink	Format and send Records as UDP Datagram Packets to a configurable destination

V¶

	Controller	Description
	VolatileSchemaCache	Provides a Schema Cache that evicts elements based on a Least-Recently-Used algorithm.

W¶

	Controller	Description
	WindowsEventLogReader	Reads Windows Event Log data as XML content having been generated by ConsumeWindowsEventLog, ParseEvtx, etc.

X¶

	Controller	Description
	XMLFileLookupService	A reloadable XML file-based lookup service.
	XMLReader	Reads XML content and creates Record objects.
	XMLRecordSetWriter	Writes a RecordSet to XML.

Y¶

	Controller	Description
	YamlTreeReader	Parses YAML into individual Record objects.