- KAFKA_TIMEOUT - Static variable in class org.apache.nifi.processors.kafka.GetKafka
-
- KafkaPublisherTest - Class in org.apache.nifi.processors.kafka
-
- KafkaPublisherTest() - Constructor for class org.apache.nifi.processors.kafka.KafkaPublisherTest
-
- KEEP_PATH - Static variable in class org.apache.nifi.processors.standard.MergeContent
-
- KEEP_SEQUENCE - Static variable in class org.apache.nifi.processors.standard.SplitContent
-
- KEEP_SOURCE_FILE - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS
-
- KEEP_SOURCE_FILE - Static variable in class org.apache.nifi.processors.standard.GetFile
-
- KeepCommonAttributeStrategy - Class in org.apache.nifi.processors.standard.merge
-
- KeepCommonAttributeStrategy() - Constructor for class org.apache.nifi.processors.standard.merge.KeepCommonAttributeStrategy
-
- KeepUniqueAttributeStrategy - Class in org.apache.nifi.processors.standard.merge
-
- KeepUniqueAttributeStrategy() - Constructor for class org.apache.nifi.processors.standard.merge.KeepUniqueAttributeStrategy
-
- KERBEROS - Static variable in class org.apache.nifi.hadoop.SecurityUtil
-
- KERBEROS_AUTHENTICATION_EXPIRATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KERBEROS_KRB5_FILE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KERBEROS_RELOGIN_PERIOD - Static variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
-
- KERBEROS_SERVICE_KEYTAB_LOCATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KERBEROS_SERVICE_PRINCIPAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KERBEROS_SPNEGO_KEYTAB_LOCATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KERBEROS_SPNEGO_PRINCIPAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- KerberosContext - Interface in org.apache.nifi.kerberos
-
- kerberosKeytab - Variable in class org.apache.nifi.util.hive.HiveOptions
-
- kerberosPrincipal - Variable in class org.apache.nifi.util.hive.HiveOptions
-
- KerberosProperties - Class in org.apache.nifi.hadoop
-
All processors and controller services that need properties for Kerberos
Principal and Keytab should obtain them through this class by calling:
KerberosProperties props =
KerberosProperties.create(NiFiProperties.getInstance())
The properties can be accessed from the resulting KerberosProperties
instance.
- KerberosProperties(File) - Constructor for class org.apache.nifi.hadoop.KerberosProperties
-
Instantiate a KerberosProperties object but keep in mind it is
effectively a singleton because the krb5.conf file needs to be set as a
system property which this constructor will take care of.
- kerberosProperties - Variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
-
- kerberosProperties - Variable in class org.apache.nifi.processors.hive.PutHiveStreaming
-
- KerberosProvider - Class in org.apache.nifi.kerberos
-
Kerberos-based implementation of a login identity provider.
- KerberosProvider() - Constructor for class org.apache.nifi.kerberos.KerberosProvider
-
- KerberosService - Class in org.apache.nifi.web.security.kerberos
-
- KerberosService() - Constructor for class org.apache.nifi.web.security.kerberos.KerberosService
-
- KerberosServiceFactoryBean - Class in org.apache.nifi.web.security.spring
-
- KerberosServiceFactoryBean() - Constructor for class org.apache.nifi.web.security.spring.KerberosServiceFactoryBean
-
- KerberosTicketRenewer - Class in org.apache.nifi.hadoop
-
Periodically attempts to renew the Kerberos user's ticket for the given UGI.
- KerberosTicketRenewer(UserGroupInformation, long, ComponentLog) - Constructor for class org.apache.nifi.hadoop.KerberosTicketRenewer
-
- KerberosUserDetailsService - Class in org.apache.nifi.kerberos
-
- KerberosUserDetailsService() - Constructor for class org.apache.nifi.kerberos.KerberosUserDetailsService
-
- KERNEL_32_UTIL_CANONICAL_NAME - Static variable in class org.apache.nifi.processors.windows.event.log.JNAJUnitRunner
-
- key() - Method in enum org.apache.nifi.couchbase.CouchbaseAttributes
-
- key() - Method in enum org.apache.nifi.flowfile.attributes.CoreAttributes
-
- key() - Method in interface org.apache.nifi.flowfile.attributes.FlowFileAttributeKey
-
- key() - Method in enum org.apache.nifi.flowfile.attributes.FragmentAttributes
-
- key() - Method in enum org.apache.nifi.flowfile.attributes.SiteToSiteAttributes
-
- Key - Class in org.apache.nifi.key
-
An signing key for a NiFi user.
- Key() - Constructor for class org.apache.nifi.key.Key
-
- key - Variable in class org.apache.nifi.processor.util.listen.handler.ChannelHandler
-
- KEY - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor
-
- key() - Method in enum org.apache.nifi.processors.beats.ListenBeats.beatsAttributes
-
- KEY - Static variable in class org.apache.nifi.processors.gcp.storage.DeleteGCSObject
-
- KEY - Static variable in class org.apache.nifi.processors.gcp.storage.FetchGCSObject
-
- KEY - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
-
- KEY - Static variable in class org.apache.nifi.processors.kafka.PutKafka
-
- key() - Method in enum org.apache.nifi.processors.lumberjack.ListenLumberjack.LumberjackAttributes
-
Deprecated.
- key() - Method in enum org.apache.nifi.processors.standard.ListenRELP.RELPAttributes
-
- key() - Method in enum org.apache.nifi.processors.standard.syslog.SyslogAttributes
-
- KEY - Static variable in class org.apache.nifi.processors.yandex.YandexTranslate
-
- KEY_ALGORITHM_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- KEY_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.DeleteGCSObjectTest
-
- KEY_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes
-
- KEY_DERIVATION_FUNCTION - Static variable in class org.apache.nifi.processors.standard.EncryptContent
-
- KEY_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes
-
- KEY_GROUP - Static variable in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor
-
- KEY_ID - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
-
- KEY_PASSWORD_ARG - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine
-
- KEY_PREFIX - Static variable in class org.apache.nifi.redis.state.RedisStateProvider
-
- KEY_SIZE_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- KEY_STORE_PASSWORD_ARG - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine
-
- KEY_STORE_PASSWORD_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- KEY_STORE_TYPE_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- KEY_STORE_TYPE_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- KeyDAO - Interface in org.apache.nifi.admin.dao
-
Key data access.
- KeyDataSourceFactoryBean - Class in org.apache.nifi.admin
-
- KeyDataSourceFactoryBean() - Constructor for class org.apache.nifi.admin.KeyDataSourceFactoryBean
-
- KeyDerivationFunction - Enum in org.apache.nifi.security.util
-
Enumeration capturing essential information about the various key derivation functions that might be supported.
- KeyedCipherProvider - Class in org.apache.nifi.security.util.crypto
-
- KeyedCipherProvider() - Constructor for class org.apache.nifi.security.util.crypto.KeyedCipherProvider
-
- KeyedEncryptor - Class in org.apache.nifi.security.util.crypto
-
- KeyedEncryptor(EncryptionMethod, SecretKey) - Constructor for class org.apache.nifi.security.util.crypto.KeyedEncryptor
-
- KeyedEncryptor(EncryptionMethod, SecretKey, byte[]) - Constructor for class org.apache.nifi.security.util.crypto.KeyedEncryptor
-
- KeyedEncryptor(EncryptionMethod, byte[]) - Constructor for class org.apache.nifi.security.util.crypto.KeyedEncryptor
-
- KeyedEncryptor(EncryptionMethod, byte[], byte[]) - Constructor for class org.apache.nifi.security.util.crypto.KeyedEncryptor
-
- keyExists(String) - Method in interface org.apache.nifi.security.kms.KeyProvider
-
Returns true if the key exists and is available.
- keyExists(String) - Method in class org.apache.nifi.security.kms.StaticKeyProvider
-
Returns true if the key exists and is available.
- keyId - Variable in class org.apache.nifi.provenance.EncryptionMetadata
-
- keyIsValid(String) - Static method in class org.apache.nifi.security.kms.CryptoUtils
-
Returns true if the provided key is valid hex and is the correct length for the current system's JCE policies.
- KeyProvider - Interface in org.apache.nifi.security.kms
-
- KeyProviderFactory - Class in org.apache.nifi.security.kms
-
- KeyProviderFactory() - Constructor for class org.apache.nifi.security.kms.KeyProviderFactory
-
- KeyService - Interface in org.apache.nifi.admin.service
-
Manages NiFi user keys.
- keySet() - Method in class org.apache.nifi.attribute.expression.language.AttributesAndState
-
- KEYSPACE - Static variable in class org.apache.nifi.processors.cassandra.AbstractCassandraProcessor
-
- KEYSTORE - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedControllerService
-
- KEYSTORE - Static variable in class org.apache.nifi.ssl.StandardSSLContextService
-
- KEYSTORE - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- KEYSTORE_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- KEYSTORE_PASSWORD - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedControllerService
-
- KEYSTORE_PASSWORD - Static variable in class org.apache.nifi.ssl.StandardSSLContextService
-
- KEYSTORE_TYPE - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedControllerService
-
- KEYSTORE_TYPE - Static variable in class org.apache.nifi.ssl.StandardSSLContextService
-
- KEYSTORE_TYPE_OPTION_DEFAULT - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- keystoreFilename(String) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder
-
Sets the filename to use for the Keystore in order to communicate securely
with the remote instance of NiFi
- keystorePass(String) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder
-
Sets the password to use for the Keystore in order to communicate securely
with the remote instance of NiFi
- KeystoreType - Enum in org.apache.nifi.remote.client
-
- keystoreType(KeystoreType) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder
-
Sets the type of the Keystore to use in order to communicate securely
with the remote instance of NiFi
- KeystoreType - Enum in org.apache.nifi.security.util
-
Keystore types.
- KeyStoreUtils - Class in org.apache.nifi.security.util
-
- KeyStoreUtils() - Constructor for class org.apache.nifi.security.util.KeyStoreUtils
-
- KeyStoreUtilsTest - Class in org.apache.nifi.security.util
-
- KeyStoreUtilsTest() - Constructor for class org.apache.nifi.security.util.KeyStoreUtilsTest
-
- KeyValidator() - Constructor for class org.apache.nifi.flowfile.FlowFile.KeyValidator
-
- KeyValueReader - Class in org.apache.nifi.processors.hadoop
-
This class reads a SequenceFile and generates FlowFiles, one per KeyValue pair in the SequenceFile.
- KeyValueReader(ProcessSession) - Constructor for class org.apache.nifi.processors.hadoop.KeyValueReader
-
- KINESIS_FIREHOSE_DELIVERY_STREAM_NAME - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.AbstractKinesisFirehoseProcessor
-
- KINESIS_PARTITION_KEY - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
-
- KINESIS_STREAM_NAME - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.AbstractKinesisStreamProcessor
-
- KITE_DATASET_URI - Static variable in class org.apache.nifi.processors.kite.StoreInKiteDataset
-
- KnoxAuthenticationFilter - Class in org.apache.nifi.web.security.knox
-
- KnoxAuthenticationFilter() - Constructor for class org.apache.nifi.web.security.knox.KnoxAuthenticationFilter
-
- KnoxAuthenticationFilterTest - Class in org.apache.nifi.web.security.knox
-
- KnoxAuthenticationFilterTest() - Constructor for class org.apache.nifi.web.security.knox.KnoxAuthenticationFilterTest
-
- KnoxAuthenticationProvider - Class in org.apache.nifi.web.security.knox
-
- KnoxAuthenticationProvider(KnoxService, NiFiProperties, Authorizer) - Constructor for class org.apache.nifi.web.security.knox.KnoxAuthenticationProvider
-
- KnoxAuthenticationRequestToken - Class in org.apache.nifi.web.security.knox
-
This is an authentication request with a given JWT token.
- KnoxAuthenticationRequestToken(String, String) - Constructor for class org.apache.nifi.web.security.knox.KnoxAuthenticationRequestToken
-
Creates a representation of the jwt authentication request for a user.
- knoxCallback(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.api.AccessResource
-
- KnoxConfiguration - Interface in org.apache.nifi.web.security.knox
-
- knoxFilterBean() - Method in class org.apache.nifi.web.NiFiWebApiSecurityConfiguration
-
- knoxRequest(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.api.AccessResource
-
- KnoxService - Class in org.apache.nifi.web.security.knox
-
KnoxService is a service for managing the Apache Knox SSO.
- KnoxService(KnoxConfiguration) - Constructor for class org.apache.nifi.web.security.knox.KnoxService
-
Creates a new KnoxService.
- KnoxServiceFactoryBean - Class in org.apache.nifi.web.security.knox
-
- KnoxServiceFactoryBean() - Constructor for class org.apache.nifi.web.security.knox.KnoxServiceFactoryBean
-
- KnoxServiceTest - Class in org.apache.nifi.web.security.knox
-
- KnoxServiceTest() - Constructor for class org.apache.nifi.web.security.knox.KnoxServiceTest
-
- KUDU_MASTERS - Static variable in class org.apache.nifi.processors.kudu.AbstractKudu
-
- kuduClient - Variable in class org.apache.nifi.processors.kudu.AbstractKudu
-
- kuduMasters - Variable in class org.apache.nifi.processors.kudu.AbstractKudu
-
- kuduTable - Variable in class org.apache.nifi.processors.kudu.AbstractKudu
-