- D() - Constructor for class org.apache.nifi.util.ReflectionUtilsTest.D
-
- DAOFactory - Interface in org.apache.nifi.admin.dao
-
- DAOFactoryImpl - Class in org.apache.nifi.admin.dao.impl
-
- DAOFactoryImpl(Connection) - Constructor for class org.apache.nifi.admin.dao.impl.DAOFactoryImpl
-
- data(InputStream) - Method in class org.apache.nifi.processors.email.smtp.SmtpConsumer
-
- data(byte[]) - Method in class org.apache.nifi.processors.standard.relp.frame.RELPFrame.Builder
-
- DATA_FORMAT - Static variable in class org.apache.nifi.processors.standard.GenerateFlowFile
-
- DATA_FORMAT_BINARY - Static variable in class org.apache.nifi.processors.standard.GenerateFlowFile
-
- DATA_FORMAT_TEXT - Static variable in class org.apache.nifi.processors.standard.GenerateFlowFile
-
- DATA_PACKET_DTO_TYPE_REFERENCE - Static variable in class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DATA_RATE - Static variable in class org.apache.nifi.processors.standard.ControlRate
-
- DATA_RATE_VALUE - Static variable in class org.apache.nifi.processors.standard.ControlRate
-
- DATA_SIZE_PATTERN - Static variable in class org.apache.nifi.controller.MonitorMemory
-
- DATA_SIZE_PATTERN - Static variable in enum org.apache.nifi.processor.DataUnit
-
- DATA_SIZE_REGEX - Static variable in enum org.apache.nifi.processor.DataUnit
-
- DATA_SIZE_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
-
- DATA_STREAMER_ALLOW_OVERRIDE - Static variable in class org.apache.nifi.processors.ignite.cache.PutIgniteCache
-
Data streamers override values property
- DATA_STREAMER_AUTO_FLUSH_FREQUENCY - Static variable in class org.apache.nifi.processors.ignite.cache.PutIgniteCache
-
Data streamers auto flush frequency
- DATA_STREAMER_PER_NODE_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.ignite.cache.PutIgniteCache
-
Data streamers per node buffer size
- DATA_STREAMER_PER_NODE_PARALLEL_OPERATIONS - Static variable in class org.apache.nifi.processors.ignite.cache.PutIgniteCache
-
Data streamer's per node parallelism
- DATA_TAGS - Static variable in class org.apache.nifi.processors.evtx.ParseEvtxTest
-
- DATA_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.GetHTTP
-
- DATA_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.PostHTTP
-
- DATA_TIMEOUT - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
-
- DataAccessException - Exception in org.apache.nifi.admin.dao
-
Represents any error that might occur while administering NiFi accounts.
- DataAccessException(Throwable) - Constructor for exception org.apache.nifi.admin.dao.DataAccessException
-
- DataAccessException(String, Throwable) - Constructor for exception org.apache.nifi.admin.dao.DataAccessException
-
- DataAccessException(String) - Constructor for exception org.apache.nifi.admin.dao.DataAccessException
-
- DataAccessException() - Constructor for exception org.apache.nifi.admin.dao.DataAccessException
-
- DataAuthorizable - Class in org.apache.nifi.authorization.resource
-
Authorizable for authorizing access to data.
- DataAuthorizable(Authorizable) - Constructor for class org.apache.nifi.authorization.resource.DataAuthorizable
-
- DataAuthorizableTest - Class in org.apache.nifi.authorization.resource
-
- DataAuthorizableTest() - Constructor for class org.apache.nifi.authorization.resource.DataAuthorizableTest
-
- dataAvailable - Variable in class org.apache.nifi.remote.AbstractTransaction
-
- DATABASE - Static variable in class org.apache.nifi.redis.util.RedisUtils
-
- DATABASE_NAME - Static variable in class org.apache.nifi.mongodb.AbstractMongoDBControllerService
-
- DATABASE_NAME - Static variable in class org.apache.nifi.processors.mongodb.AbstractMongoProcessor
-
- DATABASE_NAME_PATTERN - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
-
- DATABASE_URL - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DATABASE_URL - Static variable in class org.apache.nifi.dbcp.hive.HiveConnectionPool
-
- DatabaseAdapter - Interface in org.apache.nifi.processors.standard.db
-
Interface for RDBMS/JDBC-specific code.
- databaseName - Variable in class org.apache.nifi.util.hive.HiveOptions
-
- DatabaseReader - Class in org.apache.nifi.lookup.maxmind
-
This class was copied from https://raw.githubusercontent.com/maxmind/GeoIP2-java/master/src/main/java/com/maxmind/geoip2/DatabaseReader.java It is written by Maxmind and it is available under
Apache Software License V2
The modification we're making to the code below is to stop using exceptions for mainline flow control.
- DatabaseReader - Class in org.apache.nifi.processors.maxmind
-
This class was copied from https://raw.githubusercontent.com/maxmind/GeoIP2-java/master/src/main/java/com/maxmind/geoip2/DatabaseReader.java It is written by Maxmind and it is available under
Apache Software License V2
The modification we're making to the code below is to stop using exceptions for mainline flow control.
- DatabaseReader.Builder - Class in org.apache.nifi.lookup.maxmind
-
Constructs a Builder for the DatabaseReader.
- DatabaseReader.Builder - Class in org.apache.nifi.processors.maxmind
-
Constructs a Builder for the DatabaseReader.
- DataDogReportingTask - Class in org.apache.nifi.reporting.datadog
-
- DataDogReportingTask() - Constructor for class org.apache.nifi.reporting.datadog.DataDogReportingTask
-
- DATAFILE_OUTPUT - Static variable in class org.apache.nifi.processors.avro.SplitAvro
-
- DATAFILE_OUTPUT_VALUE - Static variable in class org.apache.nifi.processors.avro.SplitAvro
-
- DataFlow - Interface in org.apache.nifi.cluster.protocol
-
- DataFlowAdapter - Class in org.apache.nifi.cluster.protocol.jaxb.message
-
- DataFlowAdapter() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.DataFlowAdapter
-
- DataGeneratorTestProcessor - Class in org.apache.nifi.test.processors
-
- DataGeneratorTestProcessor() - Constructor for class org.apache.nifi.test.processors.DataGeneratorTestProcessor
-
- DatagramChannelDispatcher<E extends Event<java.nio.channels.DatagramChannel>> - Class in org.apache.nifi.processor.util.listen.dispatcher
-
Reads from the Datagram channel into an available buffer.
- DatagramChannelDispatcher(EventFactory<E>, BlockingQueue<ByteBuffer>, BlockingQueue<E>, ComponentLog) - Constructor for class org.apache.nifi.processor.util.listen.dispatcher.DatagramChannelDispatcher
-
- DatagramChannelDispatcher(EventFactory<E>, BlockingQueue<ByteBuffer>, BlockingQueue<E>, ComponentLog, String, Integer) - Constructor for class org.apache.nifi.processor.util.listen.dispatcher.DatagramChannelDispatcher
-
- DatagramChannelReader - Class in org.apache.nifi.io.nio
-
- DatagramChannelReader(String, SelectionKey, BufferPool, StreamConsumerFactory, boolean) - Constructor for class org.apache.nifi.io.nio.DatagramChannelReader
-
- DatagramChannelSender - Class in org.apache.nifi.processor.util.put.sender
-
Sends messages over a DatagramChannel.
- DatagramChannelSender(String, int, int, ComponentLog) - Constructor for class org.apache.nifi.processor.util.put.sender.DatagramChannelSender
-
- DatagramSender(int, int, long, String) - Constructor for class org.apache.nifi.processors.standard.TestListenSyslog.DatagramSender
-
- dataLength(int) - Method in class org.apache.nifi.processors.standard.relp.frame.RELPFrame.Builder
-
- DataOutputStream - Class in org.apache.nifi.stream.io
-
- DataOutputStream(OutputStream) - Constructor for class org.apache.nifi.stream.io.DataOutputStream
-
Deprecated.
- DataPacket - Interface in org.apache.nifi.remote.protocol
-
Represents a piece of data that is to be sent to or that was received from a
NiFi instance.
- DataPacketDto - Class in org.apache.nifi.toolkit.s2s
-
DTO object for serializing and deserializing DataPackets via JSON
- DataPacketDto() - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DataPacketDto(byte[]) - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DataPacketDto(Map<String, String>, byte[]) - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DataPacketDto(Map<String, String>, String) - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DataPacketDto(Map<String, String>, byte[], String) - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDto
-
- DataPacketDtoTest - Class in org.apache.nifi.toolkit.s2s
-
- DataPacketDtoTest() - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketDtoTest
-
- DataPacketImpl - Class in org.apache.nifi.toolkit.s2s
-
Implements DataPacket either taking the data passed in or reading from a file on disk
- DataPacketImpl(Map<String, String>, byte[], String) - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketImpl
-
- DataPacketImplTest - Class in org.apache.nifi.toolkit.s2s
-
- DataPacketImplTest() - Constructor for class org.apache.nifi.toolkit.s2s.DataPacketImplTest
-
- dataSize(long) - Method in class org.apache.nifi.processors.beats.frame.BeatsFrame.Builder
-
- dataSize(long) - Method in class org.apache.nifi.processors.lumberjack.frame.LumberjackFrame.Builder
-
Deprecated.
- DataTransferAuthorizable - Class in org.apache.nifi.authorization.resource
-
Authorizable for authorizing data transfers.
- DataTransferAuthorizable(Authorizable) - Constructor for class org.apache.nifi.authorization.resource.DataTransferAuthorizable
-
- DataTransferResource - Class in org.apache.nifi.web.api
-
RESTful endpoint for managing a SiteToSite connection.
- DataTransferResource(NiFiProperties) - Constructor for class org.apache.nifi.web.api.DataTransferResource
-
- DataType - Class in org.apache.nifi.serialization.record
-
- DataType(RecordFieldType, String) - Constructor for class org.apache.nifi.serialization.record.DataType
-
- DataTypeUtils - Class in org.apache.nifi.serialization.record.util
-
- DataTypeUtils() - Constructor for class org.apache.nifi.serialization.record.util.DataTypeUtils
-
- DataUnit - Enum in org.apache.nifi.processor
-
- DATE_FIELD - Static variable in class org.apache.nifi.processors.solr.GetSolr
-
- DATE_FORMAT - Static variable in class org.apache.nifi.serialization.DateTimeUtils
-
- DATE_TIME_FORMAT - Static variable in class org.apache.nifi.logging.LogMessage
-
- DATE_TIME_FORMAT - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
-
- DATE_TO_STRING_FORMAT - Static variable in class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
-
- DATE_TO_STRING_PATTERN - Static variable in class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
-
- DateCastEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.cast
-
- DateCastEvaluator(Evaluator<?>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
-
- DateEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- DateEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.DateEvaluator
-
- DateHandler() - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.DateHandler
-
- DATEMODE_COOKIE_DEFAULT - Static variable in class org.apache.nifi.processors.standard.CookieTestingServlet
-
- DATEMODE_COOKIE_NOT_TYPICAL - Static variable in class org.apache.nifi.processors.standard.CookieTestingServlet
-
- DateQueryResult - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- DateQueryResult(Date) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.DateQueryResult
-
- DATETIME_REPRESENTATION - Static variable in class org.apache.nifi.processors.standard.ParseCEF
-
- DateTimeAdapter - Class in org.apache.nifi.web.api.dto.util
-
XmlAdapter for (un)marshalling a date/time.
- DateTimeAdapter() - Constructor for class org.apache.nifi.web.api.dto.util.DateTimeAdapter
-
- DateTimeParameter - Class in org.apache.nifi.web.api.request
-
Class for parsing integer parameters and providing a user friendly error message.
- DateTimeParameter(String) - Constructor for class org.apache.nifi.web.api.request.DateTimeParameter
-
- DateTimeTextRecordSetWriter - Class in org.apache.nifi.serialization
-
- DateTimeTextRecordSetWriter() - Constructor for class org.apache.nifi.serialization.DateTimeTextRecordSetWriter
-
- DateTimeUtils - Class in org.apache.nifi.serialization
-
- DateTimeUtils() - Constructor for class org.apache.nifi.serialization.DateTimeUtils
-
- DAYS_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- DB_DRIVER_LOCATION - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DB_DRIVERNAME - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DB_NAME - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
-
- DB_PASSWORD - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DB_PASSWORD - Static variable in class org.apache.nifi.dbcp.hive.HiveConnectionPool
-
- DB_TABLE_CATALOG - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_COUNT - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_FULLNAME - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_NAME - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_REMARKS - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_SCHEMA - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TABLE_TYPE - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DB_TYPE - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
-
- DB_USER - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DB_USER - Static variable in class org.apache.nifi.dbcp.hive.HiveConnectionPool
-
- dbAdapters - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
-
- DBCP_SERVICE - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
-
- DBCP_SERVICE - Static variable in class org.apache.nifi.processors.standard.ExecuteSQL
-
- DBCP_SERVICE - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
-
- DBCPConnectionPool - Class in org.apache.nifi.dbcp
-
Implementation of for Database Connection Pooling Service.
- DBCPConnectionPool() - Constructor for class org.apache.nifi.dbcp.DBCPConnectionPool
-
- DBCPService - Interface in org.apache.nifi.dbcp
-
Definition for Database Connection Pooling Service.
- DBCPServiceSimpleImpl - Class in org.apache.nifi.processors.standard
-
Simple implementation only for GenerateTableFetch processor testing.
- DBCPServiceSimpleImpl(String) - Constructor for class org.apache.nifi.processors.standard.DBCPServiceSimpleImpl
-
- DBCPServiceTest - Class in org.apache.nifi.dbcp
-
- DBCPServiceTest() - Constructor for class org.apache.nifi.dbcp.DBCPServiceTest
-
- dbHost - Variable in class org.apache.nifi.processors.rethinkdb.ITAbstractRethinkDBTest
-
- dbName - Variable in class org.apache.nifi.processors.rethinkdb.ITAbstractRethinkDBTest
-
- dbPort - Variable in class org.apache.nifi.processors.rethinkdb.ITAbstractRethinkDBTest
-
- DDL_EVENT - Static variable in interface org.apache.nifi.cdc.event.EventInfo
-
- DDLEventInfo - Class in org.apache.nifi.cdc.mysql.event
-
An event class corresponding to Data Definition Language (DDL) events, such as schema changes (add/drop column, add/drop table, etc.) and others (truncate table, e.g.)
- DDLEventInfo(TableInfo, Long, String, long, String) - Constructor for class org.apache.nifi.cdc.mysql.event.DDLEventInfo
-
- DDLEventWriter - Class in org.apache.nifi.cdc.mysql.event.io
-
A writer class to output MySQL binlog Data Definition Language (DDL) events to flow file(s).
- DDLEventWriter() - Constructor for class org.apache.nifi.cdc.mysql.event.io.DDLEventWriter
-
- DDMetricRegistryBuilder - Class in org.apache.nifi.reporting.datadog
-
Class configures MetricRegistry (passed outside or created from scratch) with Datadog support
- DDMetricRegistryBuilder() - Constructor for class org.apache.nifi.reporting.datadog.DDMetricRegistryBuilder
-
- debug(String, Throwable) - Method in interface org.apache.nifi.logging.ComponentLog
-
- debug(String, Object[]) - Method in interface org.apache.nifi.logging.ComponentLog
-
- debug(String, Object[], Throwable) - Method in interface org.apache.nifi.logging.ComponentLog
-
- debug(String) - Method in interface org.apache.nifi.logging.ComponentLog
-
- debug(Marker, String, Throwable) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(Marker, String, Object[]) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(Marker, String, Object, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(Marker, String, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(Marker, String) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String, Throwable) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String, Object[]) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String, Object, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String) - Method in class org.apache.nifi.logging.NiFiLog
-
- debug(String, Throwable) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- debug(String, Object[]) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- debug(String, Object[], Throwable) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- debug(String) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- debug(String, Throwable) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- debug(String, Object[]) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- debug(String, Object[], Throwable) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- debug(String) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- debug(String) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(String, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(String, Object, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(String, Object...) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(String, Throwable) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(Marker, String) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(Marker, String, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(Marker, String, Object, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(Marker, String, Object...) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(Marker, String, Throwable) - Method in class org.apache.nifi.util.CapturingLogger
-
- debug(String, Throwable) - Method in class org.apache.nifi.util.MockComponentLog
-
- debug(String, Object[]) - Method in class org.apache.nifi.util.MockComponentLog
-
- debug(String, Object[], Throwable) - Method in class org.apache.nifi.util.MockComponentLog
-
- debug(String) - Method in class org.apache.nifi.util.MockComponentLog
-
- DebugDisabledTimedLock - Class in org.apache.nifi.util.concurrency
-
- DebugDisabledTimedLock(Lock) - Constructor for class org.apache.nifi.util.concurrency.DebugDisabledTimedLock
-
- DebugEnabledTimedLock - Class in org.apache.nifi.util.concurrency
-
- DebugEnabledTimedLock(Lock, String, int) - Constructor for class org.apache.nifi.util.concurrency.DebugEnabledTimedLock
-
- DebugFlow - Class in org.apache.nifi.processors.standard
-
- DebugFlow() - Constructor for class org.apache.nifi.processors.standard.DebugFlow
-
- DebuggableTimedLock - Interface in org.apache.nifi.util.concurrency
-
- DecimalCastEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.cast
-
- DecimalCastEvaluator(Evaluator<?>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.cast.DecimalCastEvaluator
-
- DecimalEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- DecimalEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.DecimalEvaluator
-
- DecimalLiteralEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.literals
-
- DecimalLiteralEvaluator(String) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.literals.DecimalLiteralEvaluator
-
- DecimalQueryResult - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- DecimalQueryResult(Double) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.DecimalQueryResult
-
- Declaration - Interface in org.apache.nifi.hl7.query
-
- DeclaredReferenceEvaluator - Class in org.apache.nifi.hl7.query.evaluator.message
-
- DeclaredReferenceEvaluator(StringEvaluator) - Constructor for class org.apache.nifi.hl7.query.evaluator.message.DeclaredReferenceEvaluator
-
- declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.nifi.storm.NiFiBolt
-
- declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.nifi.storm.NiFiSpout
-
- decode(InputStream) - Method in interface org.apache.nifi.remote.codec.FlowFileCodec
-
Decodes the contents of the InputStream, interpreting the data to
determine the next DataPacket's attributes and content.
- decode(InputStream) - Method in class org.apache.nifi.remote.codec.StandardFlowFileCodec
-
- DECODE_MODE - Static variable in class org.apache.nifi.processors.standard.Base64EncodeContent
-
- DECODE_MODE - Static variable in class org.apache.nifi.processors.standard.EncodeContent
-
- decorate(String) - Method in interface org.apache.nifi.expression.AttributeValueDecorator
-
Decorates the given value
- decrementActiveThreadCount() - Method in class org.apache.nifi.controller.scheduling.ScheduleState
-
- decrementClaimantCount(ResourceClaim) - Method in interface org.apache.nifi.controller.repository.claim.ResourceClaimManager
-
Decreases by 1 the count of how many FlowFiles hold a claim to a
particular piece of FlowFile content and returns the new count
- decrementClaimantCount(ResourceClaim) - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager
-
- decrementClaimantCount(ContentClaim) - Method in interface org.apache.nifi.controller.repository.ContentRepository
-
Reduces the number of claimants for the given claim.
- decrementClaimantCount(ContentClaim) - Method in class org.apache.nifi.controller.repository.FileSystemRepository
-
- decrementClaimantCount(ContentClaim) - Method in class org.apache.nifi.controller.repository.VolatileContentRepository
-
- decrementClaimantCount(ResourceClaim) - Method in class org.apache.nifi.controller.TestFileSystemSwapManager.NopResourceClaimManager
-
- decrementEventCount() - Method in interface org.apache.nifi.controller.EventBasedWorker
-
- decrementEventCount() - Method in class org.apache.nifi.controller.EventDrivenWorkerQueue.Worker
-
- decrementUsageCounter() - Method in class org.apache.nifi.provenance.lucene.LuceneEventIndexSearcher
-
- decrypt(String) - Method in class org.apache.nifi.controller.scheduling.ConnectableProcessContext
-
- decrypt(String) - Method in class org.apache.nifi.encrypt.StringEncryptor
-
Decrypts the given cipher text.
- decrypt(String) - Method in class org.apache.nifi.mock.MockProcessContext
-
- decrypt(String) - Method in interface org.apache.nifi.processor.ProcessContext
-
Decrypts the given value using the password provided in the NiFi
Properties
- decrypt(String) - Method in class org.apache.nifi.processor.StandardProcessContext
-
- decrypt(String) - Method in class org.apache.nifi.processor.StandardSchedulingContext
-
- decrypt(byte[], String) - Method in class org.apache.nifi.provenance.AESProvenanceEventEncryptor
-
Decrypts the provided byte[] (an encrypted record with accompanying metadata).
- decrypt(byte[], String) - Method in interface org.apache.nifi.provenance.ProvenanceEventEncryptor
-
Decrypts the provided byte[] (an encrypted record with accompanying metadata).
- decrypt(String) - Method in class org.apache.nifi.util.MockProcessContext
-
- DECRYPT_MODE - Static variable in class org.apache.nifi.processors.standard.EncryptContent
-
- decryptPassword(Properties, ProcessContext) - Method in class org.apache.nifi.processors.standard.GetJMSTopic
-
Deprecated.
Attempts to locate the password in the specified properties.
- DEFAULT_ADMINISTRATIVE_YIELD_DURATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_AUTHORIZER_CONFIGURATION_FILE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_AUTO_RESUME_STATE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_BACKPRESSURE_COUNT - Static variable in class org.apache.nifi.controller.StandardFlowFileQueue
-
- DEFAULT_BACKPRESSURE_SIZE - Static variable in class org.apache.nifi.controller.StandardFlowFileQueue
-
- DEFAULT_BATCH_NANOS - Static variable in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
-
- DEFAULT_BLOCK_SIZE_KB - Static variable in class org.apache.nifi.controller.repository.VolatileContentRepository
-
- DEFAULT_BORED_YIELD_DURATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_BUFFER_SIZE - Static variable in class org.apache.nifi.provenance.VolatileProvenanceRepository
-
- DEFAULT_BUFFER_SIZE - Static variable in class org.apache.nifi.remote.io.CompressionOutputStream
-
- DEFAULT_CASSANDRA_PORT - Static variable in class org.apache.nifi.processors.cassandra.AbstractCassandraProcessor
-
- DEFAULT_CERTIFICATE_DIRECTORY - Static variable in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateAuthorityClientCommandLine
-
- DEFAULT_CHANNEL - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
-
- DEFAULT_CHANNEL_READER_PERIOD_MILLISECONDS - Static variable in class org.apache.nifi.io.nio.ChannelDispatcher
-
- DEFAULT_CLUSTER_NODE_CONNECTION_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_NODE_MAX_CONCURRENT_REQUESTS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_NODE_PROTOCOL_MAX_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_NODE_PROTOCOL_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_NODE_READ_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_PROTOCOL_HEARTBEAT_INTERVAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_PROTOCOL_MULTICAST_SERVICE_BROADCAST_DELAY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_PROTOCOL_MULTICAST_SERVICE_LOCATOR_ATTEMPTS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_CLUSTER_PROTOCOL_MULTICAST_SERVICE_LOCATOR_ATTEMPTS_DELAY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_COLUMN_FAMILY - Static variable in class org.apache.nifi.hbase.TestPutHBaseJSON
-
- DEFAULT_COLUMN_FAMILY - Static variable in class org.apache.nifi.hbase.TestPutHBaseRecord
-
- DEFAULT_COMPONENT_DOCS_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_COMPONENT_STATUS_REPO_IMPLEMENTATION - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_COMPONENT_STATUS_SNAPSHOT_FREQUENCY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_COMPRESSION_LEVEL - Static variable in class org.apache.nifi.remote.io.CompressionOutputStream
-
- DEFAULT_COMPRESSION_LEVEL - Static variable in class org.apache.nifi.stream.io.GZIPOutputStream
-
- DEFAULT_COMPRESSION_LEVEL - Static variable in class org.apache.nifi.stream.io.ZipOutputStream
-
- DEFAULT_COMPRESSION_TYPE - Static variable in class org.apache.nifi.processors.hadoop.CreateHadoopSequenceFile
-
- DEFAULT_CONFIG_FILE - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DEFAULT_CONFIG_JSON - Static variable in class org.apache.nifi.toolkit.tls.service.BaseCertificateAuthorityCommandLine
-
- DEFAULT_CONTENT_REPO_IMPLEMENTATION - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_CONTENT_TYPE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
-
- DEFAULT_CONTENT_TYPE - Static variable in class org.apache.nifi.processors.standard.PostHTTP
-
- DEFAULT_COOKIE_POLICY - Static variable in class org.apache.nifi.processors.standard.GetHTTP
-
- DEFAULT_COOKIE_POLICY_STR - Static variable in class org.apache.nifi.processors.standard.GetHTTP
-
- DEFAULT_COUNT_NAME - Static variable in class org.apache.nifi.processors.standard.WaitNotifyProtocol
-
- DEFAULT_DATA_DIR - Static variable in class org.apache.nifi.processors.solr.EmbeddedSolrServerFactory
-
- DEFAULT_DATE_TIME_FORMAT - Static variable in class org.apache.nifi.web.api.dto.util.DateTimeAdapter
-
- DEFAULT_DATE_TIME_FORMAT - Static variable in class org.apache.nifi.web.api.dto.util.TimestampAdapter
-
- DEFAULT_DATE_TIME_FORMAT - Static variable in class org.apache.nifi.web.api.dto.util.TimezoneAdapter
-
- DEFAULT_DAYS - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_DN_PREFIX - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_DN_SUFFIX - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_ENCODING - Static variable in class org.apache.nifi.redis.state.RedisStateMap
-
- DEFAULT_EXPLANATION - Static variable in class org.apache.nifi.authorization.AuthorizationRequest
-
- DEFAULT_FLOW_CONFIGURATION_ARCHIVE_ENABLED - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FLOW_CONFIGURATION_ARCHIVE_MAX_STORAGE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FLOW_CONFIGURATION_ARCHIVE_MAX_TIME - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FLOW_ELECTION_MAX_WAIT_TIME - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FLOWFILE_CHECKPOINT_INTERVAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FLOWFILE_PATH - Static variable in class org.apache.nifi.controller.repository.StandardProcessSession
-
- DEFAULT_FLOWFILE_PATH - Static variable in class org.apache.nifi.remote.codec.StandardFlowFileCodec
-
- DEFAULT_FLOWFILE_PATH - Static variable in class org.apache.nifi.remote.SocketRemoteSiteListener
-
- DEFAULT_FLOWFILE_REPO_IMPLEMENTATION - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_FLOWFILE_REPO_PARTITIONS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_FOUND_SUBJECT - Static variable in class org.apache.nifi.processors.grpc.FlowFileIngestServiceInterceptor
-
- DEFAULT_FOUND_SUBJECT - Static variable in class org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet
-
- DEFAULT_FOUND_SUBJECT - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
-
- DEFAULT_GRACEFUL_SHUTDOWN_SECONDS - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_GRACEFUL_SHUTDOWN_VALUE - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DEFAULT_GROUP - Static variable in class org.apache.nifi.bundle.BundleCoordinate
-
- DEFAULT_HOSTNAME - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_IS_TRANSACTED - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
-
- DEFAULT_JAVA_CMD - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DEFAULT_KERBEROS_AUTHENTICATION_EXPIRATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_KEY_PAIR_ALGORITHM - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_KEY_SIZE - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_KEY_STORE_TYPE - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_LOCALE_VALUE - Static variable in class org.apache.nifi.processors.kite.ConvertAvroSchema
-
- DEFAULT_LOG_DIR - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DEFAULT_LOGIN_IDENTITY_PROVIDER_CONFIGURATION_FILE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_MASTERS - Static variable in class org.apache.nifi.processors.kudu.TestPutKudu
-
- DEFAULT_MAX_APPENDABLE_CLAIM_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_MAX_BUFFER - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
-
- DEFAULT_MAX_CAPACITY_PER_LEVEL - Static variable in class org.apache.nifi.logging.repository.StandardLogRepository
-
- DEFAULT_MAX_EVENTS_PER_COMMIT - Static variable in class org.apache.nifi.provenance.index.lucene.EventIndexTask
-
- DEFAULT_MAX_FLOWFILES_PER_CLAIM - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_MAX_QUEUE_SIZE - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
-
- DEFAULT_MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processors.standard.util.TCPTestServer
-
- DEFAULT_MESSAGE_PRIORITY - Static variable in class org.apache.nifi.processors.standard.PutJMS
-
Deprecated.
- DEFAULT_MULTICAST_TTL - Static variable in class org.apache.nifi.io.socket.multicast.MulticastConfiguration
-
- DEFAULT_NAR_LIBRARY_DIR - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_NAR_WORKING_DIR - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_NUM_DATA_POINTS - Static variable in class org.apache.nifi.controller.status.history.VolatileComponentStatusRepository
-
- DEFAULT_OFFER_WAIT_MS - Static variable in class org.apache.nifi.processor.util.listen.event.EventQueue
-
The default number of milliseconds to wait when offering new events to the queue.
- DEFAULT_OUTPUT_DIRECTORY - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine
-
- DEFAULT_PENALIZATION_PERIOD - Static variable in class org.apache.nifi.controller.StandardProcessorNode
-
- DEFAULT_PERSISTENT_STATE_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_PID_DIR - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DEFAULT_PORT - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_POSITION_SCALE_FACTOR_X - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_POSITION_SCALE_FACTOR_Y - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_PRECISION - Static variable in class org.apache.nifi.processors.standard.util.JdbcCommon
-
- DEFAULT_PROTOCOL - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor
-
Deprecated.
- DEFAULT_PROVENANCE_REPO_IMPLEMENTATION - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_QUEUE_SWAP_THRESHOLD - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_REMOTE_INPUT_PORT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_REORDER_DN - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_REQUEST_REPLICATION_CLAIM_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ROLLOVER_MILLIS - Static variable in class org.apache.nifi.provenance.TestPersistentProvenanceRepository
-
- DEFAULT_ROOT_GROUP_NAME - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_ROW - Static variable in class org.apache.nifi.hbase.TestPutHBaseJSON
-
- DEFAULT_SCALE - Static variable in class org.apache.nifi.processors.standard.util.JdbcCommon
-
- DEFAULT_SECURITY_USER_OIDC_CONNECT_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SECURITY_USER_OIDC_READ_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SIGNING_ALGORITHM - Static variable in class org.apache.nifi.toolkit.tls.configuration.TlsConfig
-
- DEFAULT_SITE_TO_SITE_HTTP_TRANSACTION_TTL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SOLR_HOME - Static variable in class org.apache.nifi.processors.solr.EmbeddedSolrServerFactory
-
- DEFAULT_STATE_MANAGEMENT_CONFIG_FILE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SWAP_IN_PERIOD - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SWAP_IN_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SWAP_MANAGER_IMPLEMENTATION - Static variable in class org.apache.nifi.controller.FlowController
-
- DEFAULT_SWAP_OUT_PERIOD - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SWAP_OUT_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_SWAP_STORAGE_LOCATION - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_TABLE_NAME - Static variable in class org.apache.nifi.hbase.TestPutHBaseJSON
-
- DEFAULT_TABLE_NAME - Static variable in class org.apache.nifi.hbase.TestPutHBaseRecord
-
- DEFAULT_TABLE_NAME - Static variable in class org.apache.nifi.processors.kudu.TestPutKudu
-
- DEFAULT_TAR_PERMISSIONS - Static variable in class org.apache.nifi.util.FlowFilePackagerV1
-
- DEFAULT_TEMPLATE_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_TIME_FORMAT - Static variable in class org.apache.nifi.web.api.dto.util.TimeAdapter
-
- DEFAULT_TIME_UNIT - Static variable in class org.apache.nifi.controller.AbstractPort
-
- DEFAULT_TIME_UNIT - Static variable in class org.apache.nifi.controller.StandardFunnel
-
- DEFAULT_TIME_UNIT - Static variable in class org.apache.nifi.controller.StandardProcessorNode
-
- DEFAULT_TIMESTAMP - Static variable in class org.apache.nifi.hbase.TestPutHBaseJSON
-
- DEFAULT_USER_AGENT - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor
-
Deprecated.
- DEFAULT_VERSION - Static variable in class org.apache.nifi.bundle.BundleCoordinate
-
- DEFAULT_VERSION - Static variable in class org.apache.nifi.redis.state.RedisStateMap
-
- DEFAULT_WEB_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_WEB_WORKING_DIR - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_XPATH - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
-
- DEFAULT_YIELD_PERIOD - Static variable in class org.apache.nifi.controller.AbstractPort
-
- DEFAULT_YIELD_PERIOD - Static variable in class org.apache.nifi.controller.StandardFunnel
-
- DEFAULT_YIELD_PERIOD - Static variable in class org.apache.nifi.controller.StandardProcessorNode
-
- DEFAULT_YIELD_TIME_UNIT - Static variable in class org.apache.nifi.controller.AbstractPort
-
- DEFAULT_YIELD_TIME_UNIT - Static variable in class org.apache.nifi.controller.StandardFunnel
-
- DEFAULT_ZOOKEEPER_AUTH_TYPE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ZOOKEEPER_CONNECT_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ZOOKEEPER_KERBEROS_REMOVE_HOST_FROM_PRINCIPAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ZOOKEEPER_KERBEROS_REMOVE_REALM_FROM_PRINCIPAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ZOOKEEPER_ROOT_NODE - Static variable in class org.apache.nifi.util.NiFiProperties
-
- DEFAULT_ZOOKEEPER_SESSION_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- defaultPrecision(int) - Method in class org.apache.nifi.processors.standard.util.JdbcCommon.AvroConversionOptions.Builder
-
- DEFAULTR - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON
-
- defaultScale(int) - Method in class org.apache.nifi.processors.standard.util.JdbcCommon.AvroConversionOptions.Builder
-
- DefaultSchedule - Annotation Type in org.apache.nifi.annotation.configuration
-
Marker interface that a Processor can use to configure default settings for the schedule strategy, the period and the number of concurrent tasks.
- DefaultSettings - Annotation Type in org.apache.nifi.annotation.configuration
-
Marker interface that a Processor can use to configure the yield duration, the penalty duration and the bulletin log level.
- defaultTextDevice() - Static method in class org.apache.nifi.util.console.TextDevices
-
The default system text I/O device.
- defaultValue(String) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
-
Specifies the initial value and the default value that will be used
if the user does not specify a value.
- defaultValue(String) - Method in class org.apache.nifi.web.ComponentDescriptor.Builder
-
- DELAY - Static variable in class org.apache.nifi.processors.aws.sqs.PutSQS
-
- DelayedProtocolHandler - Class in org.apache.nifi.cluster.protocol.impl.testutils
-
- DelayedProtocolHandler(int) - Constructor for class org.apache.nifi.cluster.protocol.impl.testutils.DelayedProtocolHandler
-
- delete(String, byte[]) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientService
-
- delete(String, byte[]) - Method in interface org.apache.nifi.hbase.HBaseClientService
-
Deletes the given row on HBase.
- delete(Document) - Method in interface org.apache.nifi.mongodb.MongoDBClientService
-
- delete(Document) - Method in class org.apache.nifi.mongodb.MongoDBControllerService
-
- delete(File) - Method in class org.apache.nifi.processors.standard.FetchFile
-
- DELETE_ACTION - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
-
- DELETE_ATTRIBUTES - Static variable in class org.apache.nifi.processors.attributes.UpdateAttribute
-
- DELETE_ATTRIBUTES_EXPRESSION_NAME - Static variable in class org.apache.nifi.processors.attributes.UpdateAttribute
-
- DELETE_EVENT - Static variable in interface org.apache.nifi.cdc.event.EventInfo
-
- DELETE_ORIGINAL - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
-
- DELETE_SCHEMA_V1 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
-
- DELETE_SCHEMA_V2 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
-
- DELETE_TIME_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes
-
- DELETE_TIME_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes
-
- deleteAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Deletes the given policy.
- deleteAccessPolicy(AccessPolicy) - Method in interface org.apache.nifi.authorization.ConfigurableAccessPolicyProvider
-
Deletes the given policy.
- deleteAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.FileAccessPolicyProvider
-
- deleteAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- deleteAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- deleteAccessPolicy(String) - Method in interface org.apache.nifi.web.dao.AccessPolicyDAO
-
Deletes the specified access policy.
- deleteAccessPolicy(String) - Method in class org.apache.nifi.web.dao.impl.StandardPolicyBasedAuthorizerDAO
-
- deleteAccessPolicy(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified access policy.
- deleteAccessPolicy(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteActions(Date) - Method in interface org.apache.nifi.admin.dao.ActionDAO
-
Deletes all actions up to the specified end date.
- deleteActions(Date) - Method in class org.apache.nifi.admin.dao.impl.StandardActionDAO
-
- deleteActions(Date) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Purges all actions up to the specified end date.
- deleteActions(Date) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteConnection(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.ConnectionResource
-
Removes the specified connection.
- deleteConnection(String) - Method in interface org.apache.nifi.web.dao.ConnectionDAO
-
Deletes the specified Connection.
- deleteConnection(String) - Method in class org.apache.nifi.web.dao.impl.StandardConnectionDAO
-
- deleteConnection(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified relationship target.
- deleteConnection(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteControllerService(String) - Method in interface org.apache.nifi.web.dao.ControllerServiceDAO
-
Deletes the specified controller service.
- deleteControllerService(String) - Method in class org.apache.nifi.web.dao.impl.StandardControllerServiceDAO
-
- deleteControllerService(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified label.
- deleteControllerService(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteDataset() - Method in class org.apache.nifi.processors.kite.TestKiteStorageProcessor
-
- deleteDirectory(FlowFile, String) - Method in interface org.apache.nifi.processors.standard.util.FileTransfer
-
- deleteDirectory(FlowFile, String) - Method in class org.apache.nifi.processors.standard.util.FTPTransfer
-
- deleteDirectory(FlowFile, String) - Method in class org.apache.nifi.processors.standard.util.SFTPTransfer
-
- deleteDirectory(File) - Method in class org.apache.nifi.provenance.index.lucene.IndexDirectoryManager
-
- deleteDocument(String, String, Boolean) - Method in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
-
- DeleteDynamoDB - Class in org.apache.nifi.processors.aws.dynamodb
-
- DeleteDynamoDB() - Constructor for class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB
-
- deleteDynamoDB - Variable in class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDBTest
-
- DeleteDynamoDBTest - Class in org.apache.nifi.processors.aws.dynamodb
-
- DeleteDynamoDBTest() - Constructor for class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDBTest
-
- DeleteElasticsearch5 - Class in org.apache.nifi.processors.elasticsearch
-
- DeleteElasticsearch5() - Constructor for class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
-
- deleteFile(FlowFile, String, String) - Method in interface org.apache.nifi.processors.standard.util.FileTransfer
-
- deleteFile(FlowFile, String, String) - Method in class org.apache.nifi.processors.standard.util.FTPTransfer
-
- deleteFile(FlowFile, String, String) - Method in class org.apache.nifi.processors.standard.util.SFTPTransfer
-
- deleteFile(File, Logger) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes the given file.
- deleteFile(File, Logger, int) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes the given file.
- deleteFile(List<File>, Logger) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes all of the given files.
- deleteFile(List<File>, Logger, int) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes all of the given files.
- deleteFile(File, boolean) - Static method in class org.apache.nifi.util.file.FileUtils
-
- deleteFile(File, Logger) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes the given file.
- deleteFile(File, Logger, int) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes the given file.
- deleteFile(File, boolean) - Static method in class org.apache.nifi.util.FileUtils
-
- deleteFiles(Collection<File>, boolean) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes given files.
- deleteFiles(Collection<File>, boolean) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes given files.
- deleteFilesInDir(File, FilenameFilter, Logger) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes all files (not directories..) in the given directory (non recursive) that match the given filename filter.
- deleteFilesInDir(File, FilenameFilter, Logger, boolean) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes all files (not directories) in the given directory (recursive) that match the given filename filter.
- deleteFilesInDir(File, FilenameFilter, Logger, boolean, boolean) - Static method in class org.apache.nifi.util.file.FileUtils
-
Deletes all files (not directories) in the given directory (recursive) that match the given filename filter.
- deleteFilesInDirectory(File, FilenameFilter, Logger) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes all files (not directories..) in the given directory (non
recursive) that match the given filename filter.
- deleteFilesInDirectory(File, FilenameFilter, Logger, boolean) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes all files (not directories) in the given directory (recursive)
that match the given filename filter.
- deleteFilesInDirectory(File, FilenameFilter, Logger, boolean, boolean) - Static method in class org.apache.nifi.util.FileUtils
-
Deletes all files (not directories) in the given directory (recursive)
that match the given filename filter.
- deleteFlowFileDropRequest(String, String) - Method in interface org.apache.nifi.web.dao.ConnectionDAO
-
Deletes the specified flow file drop request.
- deleteFlowFileDropRequest(String, String) - Method in class org.apache.nifi.web.dao.impl.StandardConnectionDAO
-
- deleteFlowFileDropRequest(String, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Cancels/removes the specified flow file drop request.
- deleteFlowFileDropRequest(String, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteFlowFileListingRequest(String, String) - Method in interface org.apache.nifi.web.dao.ConnectionDAO
-
Deletes the specified flow file listing request.
- deleteFlowFileListingRequest(String, String) - Method in class org.apache.nifi.web.dao.impl.StandardConnectionDAO
-
- deleteFlowFileListingRequest(String, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes a new flow file listing request.
- deleteFlowFileListingRequest(String, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteFunnel(String) - Method in interface org.apache.nifi.web.dao.FunnelDAO
-
Deletes the specified Funnel.
- deleteFunnel(String) - Method in class org.apache.nifi.web.dao.impl.StandardFunnelDAO
-
- deleteFunnel(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified funnel.
- deleteFunnel(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- DeleteGCSObject - Class in org.apache.nifi.processors.gcp.storage
-
- DeleteGCSObject() - Constructor for class org.apache.nifi.processors.gcp.storage.DeleteGCSObject
-
- DeleteGCSObjectIT - Class in org.apache.nifi.processors.gcp.storage
-
Integration tests for
DeleteGCSObject
which actually use Google Cloud resources.
- DeleteGCSObjectIT() - Constructor for class org.apache.nifi.processors.gcp.storage.DeleteGCSObjectIT
-
- DeleteGCSObjectTest - Class in org.apache.nifi.processors.gcp.storage
-
- DeleteGCSObjectTest() - Constructor for class org.apache.nifi.processors.gcp.storage.DeleteGCSObjectTest
-
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Deletes the given group.
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider
-
- deleteGroup(Group) - Method in interface org.apache.nifi.authorization.ConfigurableUserGroupProvider
-
Deletes the given group.
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.FileUserGroupProvider
-
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- deleteGroup(Group) - Method in class org.apache.nifi.authorization.SimpleConfigurableUserGroupProvider
-
- DeleteHandler() - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.DeleteHandler
-
- DeleteHDFS - Class in org.apache.nifi.processors.hadoop
-
- DeleteHDFS() - Constructor for class org.apache.nifi.processors.hadoop.DeleteHDFS
-
- deleteHistory(HttpServletRequest, DateTimeParameter) - Method in class org.apache.nifi.web.api.ControllerResource
-
Deletes flow history from the specified end date.
- DeleteIndexAction - Class in org.apache.nifi.provenance.lucene
-
- DeleteIndexAction(PersistentProvenanceRepository, IndexConfiguration, IndexManager) - Constructor for class org.apache.nifi.provenance.lucene.DeleteIndexAction
-
- deleteInputPort(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified input port.
- deleteInputPort(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteKey(String) - Method in class org.apache.nifi.admin.service.impl.StandardKeyService
-
- deleteKey(String) - Method in interface org.apache.nifi.admin.service.KeyService
-
Deletes keys for the specified identity.
- deleteKeys(String) - Method in class org.apache.nifi.admin.dao.impl.StandardKeyDAO
-
- deleteKeys(String) - Method in interface org.apache.nifi.admin.dao.KeyDAO
-
Deletes all keys for the specified user identity.
- DeleteKeysAction - Class in org.apache.nifi.admin.service.action
-
- DeleteKeysAction(String) - Constructor for class org.apache.nifi.admin.service.action.DeleteKeysAction
-
Creates a new transactions for deleting keys for specified user.
- deleteLabel(String) - Method in class org.apache.nifi.web.dao.impl.StandardLabelDAO
-
- deleteLabel(String) - Method in interface org.apache.nifi.web.dao.LabelDAO
-
Deletes the specified label in the specified group.
- deleteLabel(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified label.
- deleteLabel(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteLineage(HttpServletRequest, String, String) - Method in class org.apache.nifi.web.api.ProvenanceResource
-
Deletes the lineage with the specified id.
- deleteLineage(String) - Method in class org.apache.nifi.web.controller.ControllerFacade
-
Deletes the lineage with the specified id.
- deleteLineage(String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the lineage with the specified id.
- deleteLineage(String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteListingRequest(HttpServletRequest, String, String) - Method in class org.apache.nifi.web.api.FlowFileQueueResource
-
Deletes the specified listing request.
- deleteLock(ProceedingJoinPoint) - Method in class org.apache.nifi.web.NiFiServiceFacadeLock
-
- deleteNode(String) - Method in class org.apache.nifi.web.api.ControllerResource
-
Removes the specified from this NiFi cluster.
- deleteNode(String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the node.
- deleteNode(String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteOutputPort(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Determines if the output port could be deleted.
- deleteOutputPort(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deletePort(String) - Method in class org.apache.nifi.web.dao.impl.StandardInputPortDAO
-
- deletePort(String) - Method in class org.apache.nifi.web.dao.impl.StandardOutputPortDAO
-
- deletePort(String) - Method in interface org.apache.nifi.web.dao.PortDAO
-
Deletes the specified label in the specified group.
- deleteProcessGroup(String) - Method in class org.apache.nifi.web.dao.impl.StandardProcessGroupDAO
-
- deleteProcessGroup(String) - Method in interface org.apache.nifi.web.dao.ProcessGroupDAO
-
Deletes the specified process group.
- deleteProcessGroup(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified process group.
- deleteProcessGroup(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteProcessor(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.ProcessorResource
-
Removes the specified processor.
- deleteProcessor(String) - Method in class org.apache.nifi.web.dao.impl.StandardProcessorDAO
-
- deleteProcessor(String) - Method in interface org.apache.nifi.web.dao.ProcessorDAO
-
Deletes the specified processor.
- deleteProcessor(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified processor.
- deleteProcessor(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteProvenance(HttpServletRequest, String, String) - Method in class org.apache.nifi.web.api.ProvenanceResource
-
Deletes the provenance with the specified id.
- deleteProvenance(String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes provenance.
- deleteProvenance(String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteProvenanceQuery(String) - Method in class org.apache.nifi.web.controller.ControllerFacade
-
Deletes the query with the specified id.
- deleteQuietly(FileSystem, Path) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
-
Deletes the given file from the given filesystem.
- deleteRecursively(File, int) - Static method in class org.apache.nifi.controller.repository.util.DiskUtils
-
- deleteRecursively(File) - Static method in class org.apache.nifi.controller.repository.util.DiskUtils
-
- deleteRemoteProcessGroup(String) - Method in class org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO
-
- deleteRemoteProcessGroup(String) - Method in interface org.apache.nifi.web.dao.RemoteProcessGroupDAO
-
Deletes the specified remote process group.
- deleteRemoteProcessGroup(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified remote process group.
- deleteRemoteProcessGroup(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteReportingTask(String) - Method in class org.apache.nifi.web.dao.impl.StandardReportingTaskDAO
-
- deleteReportingTask(String) - Method in interface org.apache.nifi.web.dao.ReportingTaskDAO
-
Deletes the specified reporting task.
- deleteReportingTask(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified reporting task.
- deleteReportingTask(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteResponse - Variable in class org.apache.nifi.processors.elasticsearch.ITDeleteElasticsearch5Test
-
- deleteResponse - Variable in class org.apache.nifi.processors.elasticsearch.TestDeleteElasticsearch5
-
- DeleteRethinkDB - Class in org.apache.nifi.processors.rethinkdb
-
- DeleteRethinkDB() - Constructor for class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
-
- deleteRevision(RevisionClaim, NiFiUser, DeleteRevisionTask<T>) - Method in class org.apache.nifi.web.revision.NaiveRevisionManager
-
- deleteRevision(RevisionClaim, NiFiUser, DeleteRevisionTask<T>) - Method in interface org.apache.nifi.web.revision.RevisionManager
-
Performs the given task that is expected to remove a component from the flow.
- DeleteRevisionTask<T> - Interface in org.apache.nifi.web.revision
-
- DeleteRowsEventInfo - Class in org.apache.nifi.cdc.mysql.event
-
This class represents information about rows deleted from a MySQL table
- DeleteRowsEventInfo(TableInfo, Long, String, Long, DeleteRowsEventData) - Constructor for class org.apache.nifi.cdc.mysql.event.DeleteRowsEventInfo
-
- DeleteRowsWriter - Class in org.apache.nifi.cdc.mysql.event.io
-
A writer class to output MySQL binlog "delete rows" events to flow file(s).
- DeleteRowsWriter() - Constructor for class org.apache.nifi.cdc.mysql.event.io.DeleteRowsWriter
-
- deleteRule(String, String, String, Long) - Method in class org.apache.nifi.update.attributes.api.RuleResource
-
- deleteRule(Rule) - Method in class org.apache.nifi.update.attributes.Criteria
-
Deletes the specified rule from the rule collection.
- DeleteS3Object - Class in org.apache.nifi.processors.aws.s3
-
- DeleteS3Object() - Constructor for class org.apache.nifi.processors.aws.s3.DeleteS3Object
-
- deleteSnippet(HttpServletRequest, String) - Method in class org.apache.nifi.web.api.SnippetResource
-
Removes the specified snippet.
- deleteSnippet(Set<Revision>, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Removes the specified snippet.
- deleteSnippet(Set<Revision>, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteSnippetComponents(String) - Method in class org.apache.nifi.web.dao.impl.StandardSnippetDAO
-
- deleteSnippetComponents(String) - Method in interface org.apache.nifi.web.dao.SnippetDAO
-
Deletes the components in the specified snippet.
- DeleteSQS - Class in org.apache.nifi.processors.aws.sqs
-
- DeleteSQS() - Constructor for class org.apache.nifi.processors.aws.sqs.DeleteSQS
-
- deleteTemplate(String) - Method in class org.apache.nifi.web.dao.impl.StandardTemplateDAO
-
- deleteTemplate(String) - Method in interface org.apache.nifi.web.dao.TemplateDAO
-
Deletes the specified template.
- deleteTemplate(String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified template.
- deleteTemplate(String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteUser(User) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Deletes the given user.
- deleteUser(User) - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider
-
- deleteUser(User) - Method in interface org.apache.nifi.authorization.ConfigurableUserGroupProvider
-
Deletes the given user.
- deleteUser(User) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- deleteUser(User) - Method in class org.apache.nifi.authorization.FileUserGroupProvider
-
- deleteUser(User) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- deleteUser(User) - Method in class org.apache.nifi.authorization.SimpleConfigurableUserGroupProvider
-
- deleteUser(String) - Method in class org.apache.nifi.web.dao.impl.StandardPolicyBasedAuthorizerDAO
-
- deleteUser(String) - Method in interface org.apache.nifi.web.dao.UserDAO
-
Deletes the specified user.
- deleteUser(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified user.
- deleteUser(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteUserGroup(String) - Method in class org.apache.nifi.web.dao.impl.StandardPolicyBasedAuthorizerDAO
-
- deleteUserGroup(String) - Method in interface org.apache.nifi.web.dao.UserGroupDAO
-
Deletes the specified user group.
- deleteUserGroup(Revision, String) - Method in interface org.apache.nifi.web.NiFiServiceFacade
-
Deletes the specified user group.
- deleteUserGroup(Revision, String) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
-
- deleteVariableRegistryUpdateRequest(String, String) - Method in class org.apache.nifi.web.api.ProcessGroupResource
-
- DELIMITER - Static variable in class org.apache.nifi.processors.aws.s3.ListS3
-
- DELIMITER - Static variable in class org.apache.nifi.processors.beats.frame.BeatsFrame
-
- DELIMITER - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
-
- DELIMITER - Static variable in class org.apache.nifi.processors.lumberjack.frame.LumberjackFrame
-
Deprecated.
- DELIMITER - Static variable in class org.apache.nifi.processors.standard.relp.frame.RELPFrame
-
- DELIMITER_CHARACTER - Static variable in class org.apache.nifi.processors.standard.ValidateCsv
-
- DELIMITER_STRATEGY - Static variable in class org.apache.nifi.processors.standard.MergeContent
-
- DELIMITER_STRATEGY_FILENAME - Static variable in class org.apache.nifi.processors.standard.MergeContent
-
- DELIMITER_STRATEGY_TEXT - Static variable in class org.apache.nifi.processors.standard.MergeContent
-
- DelineatedAttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection
-
- DelineatedAttributeEvaluator(Evaluator<String>, Evaluator<String>, int) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.DelineatedAttributeEvaluator
-
- DELIVER - Static variable in interface org.apache.nifi.processors.windows.event.log.jna.WEvtApi.EvtSubscribeNotifyAction
-
- DELIVERY_BEST_EFFORT - Static variable in class org.apache.nifi.processors.kafka.PutKafka
-
- DELIVERY_GUARANTEE - Static variable in class org.apache.nifi.processors.kafka.PutKafka
-
- DELIVERY_ONE_NODE - Static variable in class org.apache.nifi.processors.kafka.PutKafka
-
- DELIVERY_REPLICATED - Static variable in class org.apache.nifi.processors.kafka.PutKafka
-
- DEMARCATOR - Static variable in class org.apache.nifi.processors.standard.MergeContent
-
- denied() - Static method in class org.apache.nifi.authorization.AuthorizationResult
-
Creates a new denied AuthorizationResult with a message indicating 'Access is denied'.
- denied(String) - Static method in class org.apache.nifi.authorization.AuthorizationResult
-
Creates a new denied AuthorizationResult with the specified explanation.
- DENY_ALL - Static variable in interface org.apache.nifi.provenance.authorization.EventAuthorizer
-
- dependencyCoordinate(BundleCoordinate) - Method in class org.apache.nifi.bundle.BundleDetails.Builder
-
- DeprecatedProcessor - Class in org.apache.nifi.documentation.example
-
- DeprecatedProcessor() - Constructor for class org.apache.nifi.documentation.example.DeprecatedProcessor
-
- DeprecationNotice - Annotation Type in org.apache.nifi.annotation.documentation
-
- DerbyDatabaseAdapter - Class in org.apache.nifi.processors.standard.db.impl
-
An implementation of DatabaseAdapter for Derby (used for testing).
- DerbyDatabaseAdapter() - Constructor for class org.apache.nifi.processors.standard.db.impl.DerbyDatabaseAdapter
-
- deregisterProcessor(String, Processor) - Method in class org.apache.nifi.websocket.AbstractWebSocketService
-
- deregisterProcessor(Processor) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter
-
- deregisterProcessor(String, Processor) - Method in class org.apache.nifi.websocket.WebSocketMessageRouters
-
- deregisterProcessor(String, Processor) - Method in interface org.apache.nifi.websocket.WebSocketService
-
- deriveRowType() - Method in class org.apache.nifi.queryrecord.FlowFileTableScan
-
- deriveScryptKey(byte[], byte[], int, int, int, int) - Static method in class org.apache.nifi.security.util.crypto.scrypt.Scrypt
-
- DescendantFieldPath - Class in org.apache.nifi.record.path.paths
-
- description(String) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
-
- description(String) - Method in class org.apache.nifi.processor.Relationship.Builder
-
- description(String) - Method in class org.apache.nifi.registry.VariableDescriptor.Builder
-
- DESCRIPTION - Static variable in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateAuthorityClientCommandLine
-
- DESCRIPTION - Static variable in class org.apache.nifi.toolkit.tls.service.server.TlsCertificateAuthorityServiceCommandLine
-
- DESCRIPTION - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine
-
- DESCRIPTION - Static variable in class org.apache.nifi.toolkit.tls.TlsToolkitMain
-
- description(String) - Method in class org.apache.nifi.web.ComponentDescriptor.Builder
-
- descriptor - Static variable in class org.apache.nifi.processors.kite.TestKiteProcessorsCluster
-
- descriptors - Variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
-
- DESCRIPTORS - Variable in class org.apache.nifi.processors.email.ConsumeEWS
-
- descriptors - Static variable in class org.apache.nifi.processors.ignite.cache.GetIgniteCache
-
Property descriptors
- descriptors - Static variable in class org.apache.nifi.processors.ignite.cache.PutIgniteCache
-
Property descriptors
- descriptors - Static variable in class org.apache.nifi.processors.slack.PutSlack
-
- descriptors(Map<String, ComponentDescriptor>) - Method in class org.apache.nifi.web.ComponentDetails.Builder
-
- DeserializationException - Exception in org.apache.nifi.distributed.cache.client.exception
-
- DeserializationException(Throwable) - Constructor for exception org.apache.nifi.distributed.cache.client.exception.DeserializationException
-
- DeserializationException(String) - Constructor for exception org.apache.nifi.distributed.cache.client.exception.DeserializationException
-
- DeserializationException(String, Throwable) - Constructor for exception org.apache.nifi.distributed.cache.client.exception.DeserializationException
-
- deserialize(byte[]) - Method in class org.apache.nifi.cdc.event.TableInfo.Deserializer
-
- deserialize(byte[]) - Method in interface org.apache.nifi.distributed.cache.client.Deserializer
-
Deserializes the given byte array input an Object and returns that value.
- deserialize(byte[]) - Method in class org.apache.nifi.hbase.util.ObjectSerDe
-
- deserialize(byte[]) - Method in class org.apache.nifi.hbase.util.StringSerDe
-
- deserialize(InputStream) - Static method in class org.apache.nifi.persistence.StandardSnippetDeserializer
-
- deserialize(InputStream) - Static method in class org.apache.nifi.persistence.TemplateDeserializer
-
- deserialize(StreamSource) - Static method in class org.apache.nifi.persistence.TemplateDeserializer
-
- deserialize(byte[]) - Method in class org.apache.nifi.processors.hadoop.util.LongSerDe
-
- deserialize(byte[]) - Method in class org.apache.nifi.processors.hadoop.util.StringSerDe
-
- deserialize(byte[]) - Method in class org.apache.nifi.processors.standard.FetchDistributedMapCache.CacheValueDeserializer
-
- deserialize(byte[]) - Method in class org.apache.nifi.processors.standard.PutDistributedMapCache.CacheValueDeserializer
-
- deserialize(byte[]) - Method in class org.apache.nifi.processors.standard.util.FlowFileAttributesSerializer
-
- deserialize(byte[]) - Method in class org.apache.nifi.redis.state.RedisStateMapJsonSerDe
-
- deserialize(byte[]) - Method in interface org.apache.nifi.redis.state.RedisStateMapSerDe
-
Deserializes the given bytes to a RedisStateMap.
- deserialize(String) - Static method in class org.apache.nifi.update.attributes.serde.CriteriaSerDe
-
Deserializes the specified criteria.
- deserializeEdit(DataInputStream, Map<Object, RepositoryRecord>, int) - Method in class org.apache.nifi.controller.repository.SchemaRepositoryRecordSerde
-
- deserializeEdit(DataInputStream, Map<Object, RepositoryRecord>, int) - Method in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
-
- deserializeEdit(DataInputStream, Map<Object, StateMapUpdate>, int) - Method in class org.apache.nifi.controller.state.StateMapSerDe
-
- deserializeEdit(DataInputStream, Map<Object, DummyRecord>, int) - Method in class org.wali.DummyRecordSerde
-
- deserializeEdit(DataInputStream, Map<Object, T>, int) - Method in interface org.wali.SerDe
-
Reads an Edit Record from the given DataInputStream
and merges
that edit with the current version of the record, returning the new,
merged version.
- deserializeFlowFiles(DataInputStream, String, FlowFileQueue, ResourceClaimManager) - Method in class org.apache.nifi.controller.swap.SchemaSwapDeserializer
-
- deserializeFlowFiles(DataInputStream, String, FlowFileQueue, ResourceClaimManager) - Method in class org.apache.nifi.controller.swap.SimpleSwapDeserializer
-
- deserializeFlowFiles(DataInputStream, String, FlowFileQueue, ResourceClaimManager) - Method in interface org.apache.nifi.controller.swap.SwapDeserializer
-
- Deserializer() - Constructor for class org.apache.nifi.cdc.event.TableInfo.Deserializer
-
- Deserializer<T> - Interface in org.apache.nifi.distributed.cache.client
-
Provides an interface for deserializing an array of bytes into an Object
- deserializeRecord(DataInputStream, int) - Method in class org.apache.nifi.controller.repository.SchemaRepositoryRecordSerde
-
- deserializeRecord(DataInputStream, int) - Method in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
-
- deserializeRecord(DataInputStream, int) - Method in class org.apache.nifi.controller.state.StateMapSerDe
-
- deserializeRecord(DataInputStream, int) - Method in class org.wali.DummyRecordSerde
-
- deserializeRecord(DataInputStream, int) - Method in interface org.wali.SerDe
-
Reads a Record from the given DataInputStream
and returns this
record.
- DESIRED_SHEETS - Static variable in class org.apache.nifi.processors.poi.ConvertExcelToCSVProcessor
-
- destination(Connectable) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
-
- DESTINATION - Static variable in class org.apache.nifi.GetHTMLElement
-
- destination() - Method in enum org.apache.nifi.processor.util.pattern.ErrorTypes
-
- destination() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
-
- DESTINATION - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
-
- DESTINATION - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
-
- DESTINATION - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
-
- DESTINATION - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
-
- DESTINATION - Static variable in class org.apache.nifi.processors.standard.ExtractGrok
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.GetHTMLElement
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
-
- DESTINATION_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
-
- DESTINATION_ATTRIBUTES - Static variable in class org.apache.nifi.processors.standard.ParseCEF
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.GetHTMLElement
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
-
- DESTINATION_CONTENT - Static variable in class org.apache.nifi.processors.standard.ParseCEF
-
- DESTINATION_NAME - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
-
- DESTINATION_TYPE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
-
- DESTINATION_TYPE_QUEUE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
-
- DESTINATION_TYPE_TOPIC - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
-
- DESTINATION_URL_PATH - Static variable in class org.apache.nifi.reporting.AbstractSiteToSiteReportingTask
-
- destinationId - Variable in class org.apache.nifi.remote.AbstractTransaction
-
- destroy() - Method in class org.apache.nifi.authorization.AuthorizerFactoryBean
-
- destroy() - Method in class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
-
- destroy() - Method in class org.apache.nifi.web.filter.CatchAllFilter
-
- destroy() - Method in class org.apache.nifi.web.filter.LoginFilter
-
- destroy() - Method in class org.apache.nifi.web.filter.RequestLogger
-
- destroy() - Method in class org.apache.nifi.web.filter.TimerFilter
-
- destroy() - Method in class org.apache.nifi.web.security.NiFiAuthenticationFilter
-
- destroy() - Method in class org.apache.nifi.web.security.spring.LoginIdentityProviderFactoryBean
-
- destroyClient() - Method in class org.apache.nifi.processors.yandex.YandexTranslate
-
- destroyCluster() - Method in class org.apache.nifi.cluster.integration.ClusterConnectionIT
-
- Details - Static variable in class org.apache.nifi.provenance.SearchableFields
-
- DetectDuplicate - Class in org.apache.nifi.processors.standard
-
- DetectDuplicate() - Constructor for class org.apache.nifi.processors.standard.DetectDuplicate
-
- determineDataType(Schema) - Static method in class org.apache.nifi.avro.AvroTypeUtil
-
Returns a DataType for the given Avro Schema
- determineDataType(Schema, Map<String, DataType>) - Static method in class org.apache.nifi.avro.AvroTypeUtil
-
- determinePrePostSendProperties(ProcessContext) - Method in class org.apache.nifi.processors.standard.PutFTP
-
- DiagnosticUtils - Class in org.apache.nifi.diagnostics
-
- DiagnosticUtils() - Constructor for class org.apache.nifi.diagnostics.DiagnosticUtils
-
- DICTIONARY - Static variable in class org.apache.nifi.processors.standard.ScanContent
-
- DICTIONARY_ENCODING - Static variable in class org.apache.nifi.processors.standard.ScanContent
-
- DICTIONARY_FILE - Static variable in class org.apache.nifi.processors.standard.ScanAttribute
-
- DICTIONARY_FILTER - Static variable in class org.apache.nifi.processors.standard.ScanAttribute
-
- DICTIONARY_PAGE_SIZE - Static variable in class org.apache.nifi.processors.parquet.PutParquet
-
- DIFFERENT_KEY_AND_KEYSTORE_PASSWORDS_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- DIFFERENT_RESOURCE_VERSION - Static variable in class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake
-
- DIFFERENT_RESOURCE_VERSION - Static variable in class org.apache.nifi.remote.RemoteResourceInitiator
-
- differentPasswordForKeyAndKeystore() - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
Returns true if different passwords should be used for KeyStore and individual Key entries
- DimensionsDTO - Class in org.apache.nifi.web.api.dto
-
A position on the canvas.
- DimensionsDTO() - Constructor for class org.apache.nifi.web.api.dto.DimensionsDTO
-
- DIR_DISPLAY_NAME - Static variable in class org.apache.nifi.controller.MonitorDiskUsage
-
- DIR_LOCATION - Static variable in class org.apache.nifi.controller.MonitorDiskUsage
-
- DIR_THRESHOLD - Static variable in class org.apache.nifi.controller.MonitorDiskUsage
-
- direction - Variable in class org.apache.nifi.remote.AbstractTransaction
-
- DIRECTION_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- DIRECTION_OPTION_DEFAULT - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
-
- DIRECTORY - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor
-
- DIRECTORY - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor
-
- DIRECTORY - Static variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
-
- DIRECTORY - Static variable in class org.apache.nifi.processors.standard.GetFile
-
- DIRECTORY - Static variable in class org.apache.nifi.processors.standard.ListFile
-
- DIRECTORY - Static variable in class org.apache.nifi.processors.standard.PutFile
-
- directory(boolean) - Method in class org.apache.nifi.processors.standard.util.FileInfo.Builder
-
- DIRECTORY_LOCATION - Static variable in class org.apache.nifi.processors.standard.ListFile
-
- DirectoryExistsValidator(boolean, boolean) - Constructor for class org.apache.nifi.processor.util.StandardValidators.DirectoryExistsValidator
-
- DirectoryUtils - Class in org.apache.nifi.provenance.util
-
- DirectoryUtils() - Constructor for class org.apache.nifi.provenance.util.DirectoryUtils
-
- disable() - Method in class org.apache.nifi.cluster.integration.NopStateProvider
-
- disable() - Method in interface org.apache.nifi.components.state.StateProvider
-
Notifies the state provider that it should stop servicing requests to store and retrieve state and instead throw a ProviderDisabledException if any request is made to do so
- disable() - Method in class org.apache.nifi.controller.AbstractPort
-
- disable() - Method in class org.apache.nifi.controller.ProcessorNode
-
Will set the state of the processor to DISABLED which essentially implies
that this processor can NOT be started.
- disable(ConfigurationContext) - Method in class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler.LongEnablingService
-
- disable(ConfigurationContext) - Method in class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler.SimpleTestService
-
- disable(ScheduledExecutorService) - Method in interface org.apache.nifi.controller.service.ControllerServiceNode
-
Will disable this service.
- disable() - Method in class org.apache.nifi.controller.service.ServiceStateTransition
-
- disable(ScheduledExecutorService) - Method in class org.apache.nifi.controller.service.StandardControllerServiceNode
-
Will atomically disable this service by invoking its @OnDisabled operation.
- disable() - Method in class org.apache.nifi.controller.state.providers.AbstractStateProvider
-
- disable() - Method in class org.apache.nifi.jms.cf.JMSConnectionFactoryProvider
-
- disable() - Method in class org.apache.nifi.redis.state.RedisStateProvider
-
- DISABLE_DIRECTORY_LISTING - Static variable in class org.apache.nifi.processors.standard.util.SFTPTransfer
-
- disableClusterProvider() - Method in interface org.apache.nifi.components.state.StateManagerProvider
-
Disables the Cluster State Provider and begins using the Local State Provider to persist and retrieve
state, even when components request a clustered provider
- disableClusterProvider() - Method in class org.apache.nifi.controller.state.manager.StandardStateManagerProvider
-
- disableControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.FlowController
-
- disableControllerService(ControllerServiceNode) - Method in interface org.apache.nifi.controller.ProcessScheduler
-
Disables the Controller Service so that it can be updated
- disableControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disableControllerService(ControllerServiceNode) - Method in interface org.apache.nifi.controller.service.ControllerServiceProvider
-
Disables the given controller service so that it cannot be used by other
components.
- disableControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.service.StandardControllerServiceProvider
-
- disableControllerService(ControllerService) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
-
- disableControllerService(ControllerService) - Method in interface org.apache.nifi.util.TestRunner
-
Marks the Controller Service as disabled so that it cannot be used by
other components.
- disableControllerServices(List<ControllerServiceNode>) - Method in interface org.apache.nifi.controller.ProcessScheduler
-
Disables all of the given Controller Services in the order provided by the List
- disableControllerServices(List<ControllerServiceNode>) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disabled() - Method in class org.apache.nifi.controller.AbstractControllerService
-
- disableExpressionValidation() - Method in class org.apache.nifi.util.MockProcessContext
-
- disableFunnel(Funnel) - Method in interface org.apache.nifi.controller.ProcessScheduler
-
- disableFunnel(Funnel) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disableInputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
-
- disableInputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup
-
Disables the given Input Port
- disableInputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
-
- disableInvocationCount() - Method in class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler.LongEnablingService
-
- disableInvocationCount() - Method in class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler.SimpleTestService
-
- DisableOnCloseInputStream - Class in org.apache.nifi.controller.repository.io
-
Wraps an existing InputStream, so that when InputStream.close()
is called, the underlying InputStream is NOT closed but this InputStream can no longer be written to
- DisableOnCloseInputStream(InputStream) - Constructor for class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
-
- DisableOnCloseOutputStream - Class in org.apache.nifi.controller.repository.io
-
Wraps an existing OutputStream, so that when OutputStream.close()
is called, the underlying OutputStream is NOT closed but this OutputStream can no longer be written to
- DisableOnCloseOutputStream(OutputStream) - Constructor for class org.apache.nifi.controller.repository.io.DisableOnCloseOutputStream
-
- disableOutputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
-
- disableOutputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup
-
Disables the given Output Port
- disableOutputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
-
- disablePort(Port) - Method in interface org.apache.nifi.controller.ProcessScheduler
-
- disablePort(Port) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disableProcessor(ProcessorNode) - Method in interface org.apache.nifi.controller.ProcessScheduler
-
- disableProcessor(ProcessorNode) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disableProcessor(ProcessorNode) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
-
- disableProcessor(ProcessorNode) - Method in interface org.apache.nifi.groups.ProcessGroup
-
Disables the given Processor
- disableProcessor(ProcessorNode) - Method in class org.apache.nifi.groups.StandardProcessGroup
-
- disableReferencingServices(ControllerServiceNode) - Method in class org.apache.nifi.controller.FlowController
-
- disableReferencingServices(ControllerServiceNode) - Method in interface org.apache.nifi.controller.service.ControllerServiceProvider
-
Disables any Controller Service that references the provided Controller
Service.
- disableReferencingServices(ControllerServiceNode) - Method in class org.apache.nifi.controller.service.StandardControllerServiceProvider
-
- disableReportingTask(ReportingTaskNode) - Method in class org.apache.nifi.controller.FlowController
-
- disableReportingTask(ReportingTaskNode) - Method in interface org.apache.nifi.controller.reporting.ReportingTaskProvider
-
Disables the ability to schedul the reporting task to run
- disableReportingTask(ReportingTaskNode) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
-
- disconnect(DisconnectMessage) - Method in interface org.apache.nifi.cluster.protocol.ClusterCoordinationProtocolSender
-
Sends a "disconnection request" message to a node.
- disconnect(DisconnectMessage) - Method in class org.apache.nifi.cluster.protocol.impl.ClusterCoordinationProtocolSenderListener
-
- disconnect(DisconnectMessage) - Method in class org.apache.nifi.cluster.protocol.impl.StandardClusterCoordinationProtocolSender
-
Requests a node to disconnect from the cluster.
- disconnect() - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
-
- disconnect(long) - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
-
- disconnect(String, String) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter
-
- DisconnectedNodeMutableRequestException - Exception in org.apache.nifi.cluster.manager.exception
-
Represents the exceptional case when a HTTP request that may change a node's dataflow is to be replicated while one or more nodes are disconnected.
- DisconnectedNodeMutableRequestException() - Constructor for exception org.apache.nifi.cluster.manager.exception.DisconnectedNodeMutableRequestException
-
- DisconnectedNodeMutableRequestException(String) - Constructor for exception org.apache.nifi.cluster.manager.exception.DisconnectedNodeMutableRequestException
-
- DisconnectedNodeMutableRequestException(Throwable) - Constructor for exception org.apache.nifi.cluster.manager.exception.DisconnectedNodeMutableRequestException
-
- DisconnectedNodeMutableRequestException(String, Throwable) - Constructor for exception org.apache.nifi.cluster.manager.exception.DisconnectedNodeMutableRequestException
-
- DisconnectedNodeMutableRequestExceptionMapper - Class in org.apache.nifi.web.api.config
-
Maps disconnected node mutable request exceptions into client responses.
- DisconnectedNodeMutableRequestExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.DisconnectedNodeMutableRequestExceptionMapper
-
- disconnectForcibly() - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
-
- disconnectForcibly(long) - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
-
- disconnectForcibly(long, long) - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
-
- DisconnectionCode - Enum in org.apache.nifi.cluster.coordination.node
-
An enumeration of the reasons that a node may be disconnected
from the cluster
- DisconnectionException - Exception in org.apache.nifi.cluster
-
Represents the exceptional case when disconnection from the cluster fails.
- DisconnectionException() - Constructor for exception org.apache.nifi.cluster.DisconnectionException
-
- DisconnectionException(String) - Constructor for exception org.apache.nifi.cluster.DisconnectionException
-
- DisconnectionException(Throwable) - Constructor for exception org.apache.nifi.cluster.DisconnectionException
-
- DisconnectionException(String, Throwable) - Constructor for exception org.apache.nifi.cluster.DisconnectionException
-
- disconnectionRequestedByNode(NodeIdentifier, DisconnectionCode, String) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator
-
Notifies the Cluster Coordinator that the node with the given ID has requested to disconnect
from the cluster.
- disconnectionRequestedByNode(NodeIdentifier, DisconnectionCode, String) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
-
- DisconnectMessage - Class in org.apache.nifi.cluster.protocol.message
-
- DisconnectMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.DisconnectMessage
-
- discontinue() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
-
- DiscontinuedException - Exception in org.apache.nifi.processor.util.pattern
-
Represents a looping process was discontinued.
- DiscontinuedException(String) - Constructor for exception org.apache.nifi.processor.util.pattern.DiscontinuedException
-
- DiscontinuedException(String, Throwable) - Constructor for exception org.apache.nifi.processor.util.pattern.DiscontinuedException
-
- DiscoverableService - Interface in org.apache.nifi.io.socket.multicast
-
A service that may be discovered at runtime.
- DiscoverableServiceImpl - Class in org.apache.nifi.io.socket.multicast
-
A basic implementation of the DiscoverableService interface.
- DiscoverableServiceImpl(String, InetSocketAddress) - Constructor for class org.apache.nifi.io.socket.multicast.DiscoverableServiceImpl
-
- discoverExtensions(Bundle, Set<Bundle>) - Static method in class org.apache.nifi.nar.ExtensionManager
-
Loads all FlowFileProcessor, FlowFileComparator, ReportingTask class types that can be found on the bootstrap classloader and by creating classloaders for all NARs found within the classpath.
- DiskUtils - Class in org.apache.nifi.controller.repository.util
-
- DiskUtils() - Constructor for class org.apache.nifi.controller.repository.util.DiskUtils
-
- dispatcher - Variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
-
- dispatcher - Variable in class org.apache.nifi.processor.util.listen.handler.ChannelHandler
-
- dispatchRequest(Socket) - Method in class org.apache.nifi.cluster.protocol.impl.SocketProtocolListener
-
- dispatchRequest(MulticastSocket, DatagramPacket) - Method in class org.apache.nifi.io.socket.multicast.MulticastListener
-
Implements the action to perform when a new datagram is received.
- dispatchRequest(Socket) - Method in class org.apache.nifi.io.socket.SocketListener
-
Implements the action to perform when a new socket request is received.
- displayName(String) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
-
Sets a unique id for the property.
- displayName(String) - Method in class org.apache.nifi.web.ComponentDescriptor.Builder
-
- displayUrl - Variable in class org.apache.nifi.processors.email.ConsumeEWS
-
- DIST_CACHE_CLIENT - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.hadoop.ListHDFS
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.standard.Notify
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.standard.PutDistributedMapCache
-
- DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.standard.Wait
-
- DistributedCacheServer - Class in org.apache.nifi.distributed.cache.server
-
- DistributedCacheServer() - Constructor for class org.apache.nifi.distributed.cache.server.DistributedCacheServer
-
- DistributedMapCacheClient - Interface in org.apache.nifi.distributed.cache.client
-
This interface defines an API that can be used for interacting with a
Distributed Cache that functions similarly to a Map
.
- DistributedMapCacheClientService - Class in org.apache.nifi.distributed.cache.client
-
- DistributedMapCacheClientService() - Constructor for class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
-
- DistributedMapCacheServer - Class in org.apache.nifi.distributed.cache.server.map
-
- DistributedMapCacheServer() - Constructor for class org.apache.nifi.distributed.cache.server.map.DistributedMapCacheServer
-
- DistributedSetCacheClient - Interface in org.apache.nifi.distributed.cache.client
-
This interface defines an API that can be used for interacting with a
Distributed Cache that functions similarly to a Set
.
- DistributedSetCacheClientService - Class in org.apache.nifi.distributed.cache.client
-
- DistributedSetCacheClientService() - Constructor for class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService
-
- DistributedSetCacheServer - Class in org.apache.nifi.distributed.cache.server
-
- DistributedSetCacheServer() - Constructor for class org.apache.nifi.distributed.cache.server.DistributedSetCacheServer
-
- DistributeLoad - Class in org.apache.nifi.processors.standard
-
- DistributeLoad() - Constructor for class org.apache.nifi.processors.standard.DistributeLoad
-
- DISTRIBUTION_STRATEGY - Static variable in class org.apache.nifi.processors.standard.DistributeLoad
-
- DivideEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
-
- DivideEvaluator(Evaluator<Number>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.DivideEvaluator
-
- DN_ARG - Static variable in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- DNS_QUERY_TYPE - Static variable in class org.apache.nifi.processors.enrich.QueryDNS
-
- DNS_RETRIES - Static variable in class org.apache.nifi.processors.enrich.QueryDNS
-
- DNS_SERVER - Static variable in class org.apache.nifi.processors.enrich.QueryDNS
-
- DNS_TIMEOUT - Static variable in class org.apache.nifi.processors.enrich.QueryDNS
-
- DO_NOT_STORE_STATE - Static variable in class org.apache.nifi.processors.attributes.UpdateAttribute
-
- doAddAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Adds the given policy.
- doAddAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doAddAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- doAddGroup(Group) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Adds a new group.
- doAddGroup(Group) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doAddGroup(Group) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- doAddUser(User) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Adds the given user.
- doAddUser(User) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doAddUser(User) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- DOC_ID - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
-
- DOC_ID - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch
-
- DOC_ID - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5
-
- DOC_ID - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp
-
- DocGenerator - Class in org.apache.nifi.documentation
-
Uses the ExtensionManager to get a list of Processor, ControllerService, and
Reporting Task classes that were loaded and generate documentation for them.
- DocGenerator() - Constructor for class org.apache.nifi.documentation.DocGenerator
-
- DocGeneratorTest - Class in org.apache.nifi.documentation
-
- DocGeneratorTest() - Constructor for class org.apache.nifi.documentation.DocGeneratorTest
-
- DocsReader - Class in org.apache.nifi.provenance.lucene
-
- DocsReader() - Constructor for class org.apache.nifi.provenance.lucene.DocsReader
-
- DOCUMENT_BUILDER_FACTORY - Static variable in class org.apache.nifi.processors.evtx.ParseEvtxTest
-
- DOCUMENT_CHARSET - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DOCUMENT_ID - Static variable in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
-
- DOCUMENT_TYPE - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
-
- DOCUMENT_VALIDATOR - Static variable in class org.apache.nifi.mongodb.Validation
-
- DOCUMENT_VALIDATOR - Static variable in class org.apache.nifi.processors.mongodb.GetMongo
-
- DocumentationController - Class in org.apache.nifi.web.docs
-
- DocumentationController() - Constructor for class org.apache.nifi.web.docs.DocumentationController
-
- DocumentationWriter - Interface in org.apache.nifi.documentation
-
Generates documentation for an instance of a ConfigurableComponent
- DocumentedTypeDTO - Class in org.apache.nifi.web.api.dto
-
Class used for providing documentation of a specified type.
- DocumentedTypeDTO() - Constructor for class org.apache.nifi.web.api.dto.DocumentedTypeDTO
-
- DocumentedTypesMerger - Class in org.apache.nifi.cluster.manager
-
- DocumentReaderCallback - Class in org.apache.nifi.processors.standard.util
-
- DocumentReaderCallback(boolean) - Constructor for class org.apache.nifi.processors.standard.util.DocumentReaderCallback
-
Creates a new DocumentReaderCallback .
- DocumentToEventConverter - Interface in org.apache.nifi.provenance.lucene
-
- DocumentType - Enum in org.apache.nifi.processors.couchbase
-
Supported Couchbase document types.
- doDelete(DeleteRequestBuilder) - Method in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
-
- doDelete(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet
-
- doDelete(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.InputPortTransactionServlet
-
- doDelete(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.OutputPortTransactionServlet
-
- doesPolicyExist(String, RequestAction) - Method in class org.apache.nifi.ranger.authorization.RangerBasePluginWithPolicies
-
Determines if a policy exists for the given resource.
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.nifi.web.filter.CatchAllFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.nifi.web.filter.LoginFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.nifi.web.filter.RequestLogger
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.nifi.web.filter.TimerFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.nifi.web.security.NiFiAuthenticationFilter
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.CookieTestingServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.CookieVerificationTestingServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.HelloWorldServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.HttpErrorServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.RESTServiceContentModified
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.UserAgentTestingServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesTimeoutAfterDataExchangeServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesTimeoutServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.PeersServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.SiteInfoServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.WrongSiteInfoServlet
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.ContentViewerController
-
Gets the content and defers to registered viewers to generate the markup.
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.docs.DocumentationController
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.ImageViewerController
-
Handles generating markup for viewing an image.
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.StandardContentViewerController
-
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.websocket.example.WebSocketServerExample.ConnectionCheckServlet
-
- doHandshake(Peer) - Method in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
-
- doHandshake(Peer) - Method in class org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol
-
- doHandshake(Peer) - Method in class org.apache.nifi.remote.protocol.socket.SocketFlowFileServerProtocol
-
- doHead(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.CaptureServlet
-
- doHead(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
-
- doLookup(String, String) - Method in class org.apache.nifi.processors.enrich.QueryDNS
-
This method performs a simple DNS lookup using JNDI
- doLookup(String, int, int, String) - Method in class org.apache.nifi.processors.enrich.QueryWhois
-
This method performs a simple Whois lookup
- domain(InetAddress) - Method in class org.apache.nifi.lookup.maxmind.DatabaseReader
-
Look up an IP address in a GeoIP2 Domain database.
- domain(InetAddress) - Method in class org.apache.nifi.processors.maxmind.DatabaseReader
-
Look up an IP address in a GeoIP2 Domain database.
- doMain(String[]) - Method in class org.apache.nifi.toolkit.tls.TlsToolkitMain
-
Invokes the main of the relevant service
- DomUtils - Class in org.apache.nifi.util
-
- DomUtils() - Constructor for class org.apache.nifi.util.DomUtils
-
- done() - Method in class org.apache.nifi.processors.email.smtp.SmtpConsumer
-
- doOnConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
Allows sub-classes to take action when onConfigured is called.
- doOnConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doOnConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- doParse(String[]) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
-
- doParse(String[]) - Method in class org.apache.nifi.toolkit.tls.service.BaseCertificateAuthorityCommandLine
-
- doParse(String[]) - Method in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateAuthorityClientCommandLine
-
- doParse(String...) - Method in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.slack.CaptureServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.CaptureServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesTimeoutAfterDataExchangeServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.FlowFilesTimeoutServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.PortTransactionsAccessDeniedServlet
-
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.PortTransactionsServlet
-
- doPut(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.InputPortTransactionServlet
-
- doPut(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.remote.client.http.TestHttpClient.OutputPortTransactionServlet
-
- doSchedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent
-
- doSchedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent
-
- doSchedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.QuartzSchedulingAgent
-
- doSchedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.QuartzSchedulingAgent
-
- doSchedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent
-
- doSchedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent
-
- doSomething() - Method in class org.apache.nifi.documentation.example.FullyDocumentedControllerService
-
- doSomething() - Method in interface org.apache.nifi.documentation.example.SampleService
-
- DOT_RENAME - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
-
- DOTALL - Static variable in class org.apache.nifi.processors.standard.ExtractText
-
- DotEvaluator - Class in org.apache.nifi.hl7.query.evaluator.message
-
- DotEvaluator(Evaluator<?>, IntegerEvaluator) - Constructor for class org.apache.nifi.hl7.query.evaluator.message.DotEvaluator
-
- DoubleParameter - Class in org.apache.nifi.web.api.request
-
Class for parsing double parameters and providing a user friendly error message.
- DoubleParameter(String) - Constructor for class org.apache.nifi.web.api.request.DoubleParameter
-
- DoubleTypeNode - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
Node containing a double value
- DoubleTypeNode(BinaryReader, ChunkHeader, BxmlNode, int) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.DoubleTypeNode
-
- DoubleTypeNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
- DoubleTypeNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.DoubleTypeNodeTest
-
- doUnschedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent
-
- doUnschedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent
-
- doUnschedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.QuartzSchedulingAgent
-
- doUnschedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.QuartzSchedulingAgent
-
- doUnschedule(Connectable, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent
-
- doUnschedule(ReportingTaskNode, ScheduleState) - Method in class org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent
-
- doUpdateGroup(Group) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
The group represented by the provided instance will be updated based on the provided instance.
- doUpdateGroup(Group) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doUpdateGroup(Group) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- doUpdateUser(User) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
-
The user represented by the provided instance will be updated based on the provided instance.
- doUpdateUser(User) - Method in class org.apache.nifi.authorization.FileAuthorizer
-
- doUpdateUser(User) - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
-
- doValidate(String) - Method in class org.apache.nifi.controller.MonitorMemoryTest
-
- DownloadableContent - Class in org.apache.nifi.web
-
Represents content that can be downloaded.
- DownloadableContent(String, String, InputStream) - Constructor for class org.apache.nifi.web.DownloadableContent
-
- downloadFlowFileContent(ClientIdParameter, String, String, String) - Method in class org.apache.nifi.web.api.FlowFileQueueResource
-
Gets the content for the specified flowfile in the specified connection.
- drainClientResponse(ClientResponse) - Static method in class org.apache.nifi.web.util.ClientResponseUtils
-
- drainDestructableClaims(Collection<ResourceClaim>, int) - Method in interface org.apache.nifi.controller.repository.claim.ResourceClaimManager
-
Drains up to maxElements
Content Claims from the internal queue
of destructable content claims to the given destination
so that
they can be destroyed.
- drainDestructableClaims(Collection<ResourceClaim>, int, long, TimeUnit) - Method in interface org.apache.nifi.controller.repository.claim.ResourceClaimManager
-
Drains up to maxElements
Content Claims from the internal queue
of destructable content claims to the given destination
so that
they can be destroyed.
- drainDestructableClaims(Collection<ResourceClaim>, int) - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager
-
- drainDestructableClaims(Collection<ResourceClaim>, int, long, TimeUnit) - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager
-
- drainDestructableClaims(Collection<ResourceClaim>, int) - Method in class org.apache.nifi.controller.TestFileSystemSwapManager.NopResourceClaimManager
-
- drainDestructableClaims(Collection<ResourceClaim>, int, long, TimeUnit) - Method in class org.apache.nifi.controller.TestFileSystemSwapManager.NopResourceClaimManager
-
- drainQueue(Queue<FlowFileRecord>, List<FlowFileRecord>, int, Set<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
-
Drains flow files from the given source queue into the given destination
list.
- drainQueue(Queue<FlowFileRecord>, List<FlowFileRecord>, int, Set<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
-
- DRIVER_LOCATION - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
-
- DRIVER_NAME - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
-
- DROP_REQUEST_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.DropRequestEndpointMerger
-
- DROP_REQUESTS_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.DropRequestEndpointMerger
-
- dropCollection() - Method in interface org.apache.nifi.mongodb.MongoDBClientService
-
- dropCollection() - Method in class org.apache.nifi.mongodb.MongoDBControllerService
-
- dropDatabase() - Method in interface org.apache.nifi.mongodb.MongoDBClientService
-
- dropDatabase() - Method in class org.apache.nifi.mongodb.MongoDBControllerService
-
- DropFlowFileRequest - Class in org.apache.nifi.controller
-
- DropFlowFileRequest(String) - Constructor for class org.apache.nifi.controller.DropFlowFileRequest
-
- dropFlowFiles(String, String) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
-
Initiates a request to drop all FlowFiles in this queue.
- dropFlowFiles(String, String) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
-
- DropFlowFileState - Enum in org.apache.nifi.controller.queue
-
Represents the state that a Drop FlowFile request is in
- DropFlowFileStatus - Interface in org.apache.nifi.controller.queue
-
Represents the status of a Drop FlowFile Request that has been issued to
a
FlowFileQueue
.
- DropRequestDTO - Class in org.apache.nifi.web.api.dto
-
A request to drop the contents of a connection.
- DropRequestDTO() - Constructor for class org.apache.nifi.web.api.dto.DropRequestDTO
-
- DropRequestEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
-
- DropRequestEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.DropRequestEndpointMerger
-
- DropRequestEntity - Class in org.apache.nifi.web.api.entity
-
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
- DropRequestEntity() - Constructor for class org.apache.nifi.web.api.entity.DropRequestEntity
-
- dropSnippet(String) - Method in class org.apache.nifi.web.dao.impl.StandardSnippetDAO
-
- dropSnippet(String) - Method in interface org.apache.nifi.web.dao.SnippetDAO
-
Drops the specified snippet.
- DtoFactory - Class in org.apache.nifi.update.attributes.dto
-
- DtoFactory() - Constructor for class org.apache.nifi.update.attributes.dto.DtoFactory
-
- DtoFactory - Class in org.apache.nifi.web.api.dto
-
- DtoFactory() - Constructor for class org.apache.nifi.web.api.dto.DtoFactory
-
- DummyProcessor - Class in org.apache.nifi.controller.service.mock
-
- DummyProcessor() - Constructor for class org.apache.nifi.controller.service.mock.DummyProcessor
-
- DummyRecord - Class in org.wali
-
- DummyRecord(String, UpdateType) - Constructor for class org.wali.DummyRecord
-
- DummyRecordSerde - Class in org.wali
-
- DummyRecordSerde() - Constructor for class org.wali.DummyRecordSerde
-
- DummyReportingTask - Class in org.apache.nifi.controller.service.mock
-
- DummyReportingTask() - Constructor for class org.apache.nifi.controller.service.mock.DummyReportingTask
-
- DummyScheduledProcessor - Class in org.apache.nifi.controller
-
Dummy processor to test @DefaultSchedule annotation
- DummyScheduledProcessor() - Constructor for class org.apache.nifi.controller.DummyScheduledProcessor
-
- DummyScheduledReportingTask - Class in org.apache.nifi.controller
-
Dummy reporting task to test @DefaultSchedule annotation
- DummyScheduledReportingTask() - Constructor for class org.apache.nifi.controller.DummyScheduledReportingTask
-
- DummyScheduleState - Class in org.apache.nifi.controller.scheduling
-
- DummyScheduleState(boolean) - Constructor for class org.apache.nifi.controller.scheduling.DummyScheduleState
-
- DummySettingsProcessor - Class in org.apache.nifi.controller
-
Dummy Processor to test @DefaultSettings annotation
- DummySettingsProcessor() - Constructor for class org.apache.nifi.controller.DummySettingsProcessor
-
- dump(File) - Method in class org.apache.nifi.bootstrap.RunNiFi
-
Writes a NiFi thread dump to the given file; if file is null, logs at
INFO level instead.
- DUMP_CMD - Static variable in class org.apache.nifi.bootstrap.RunNiFi
-
- DumpEventFile - Class in org.apache.nifi.provenance.util
-
- DumpEventFile() - Constructor for class org.apache.nifi.provenance.util.DumpEventFile
-
- dumpState(long) - Method in class org.apache.nifi.processor.util.list.ListProcessorTestWatcher
-
- dumpState - Variable in class org.apache.nifi.processor.util.list.TestAbstractListProcessor
-
- dumpState - Variable in class org.apache.nifi.processors.standard.TestListFile
-
- DuplicateFlowFile - Class in org.apache.nifi.processors.standard
-
- DuplicateFlowFile() - Constructor for class org.apache.nifi.processors.standard.DuplicateFlowFile
-
- DURABLE_SUBSCRIPTION - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
-
- DURATION_DAYS - Static variable in class org.apache.nifi.security.util.KeyStoreUtilsTest
-
- dynamic(boolean) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
-
- DYNAMIC_QUEUE_URL - Static variable in class org.apache.nifi.processors.aws.sqs.GetSQS
-
- dynamicallyModifiesClasspath(boolean) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
-
Specifies that the value of this property represents one or more resources that the
framework should add to the classpath of the given component.
- DynamicProperties - Annotation Type in org.apache.nifi.annotation.behavior
-
Indicates that a component has more than one dynamic property
- DynamicProperty - Annotation Type in org.apache.nifi.annotation.behavior
-
An annotation that may be placed on a
ConfigurableComponent
to
indicate that it supports a dynamic property.
- DynamicRelationship - Annotation Type in org.apache.nifi.annotation.behavior
-
Annotation to indicate that a
Processor
supports dynamic
relationship.
- dynamoDB - Variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- dynamoDB - Static variable in class org.apache.nifi.processors.aws.dynamodb.ITAbstractDynamoDBTest
-
- DYNAMODB_ERROR_CODE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_EXCEPTION_MESSAGE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_MESSAGE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_REQUEST_ID - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_RETRYABLE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_SERVICE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_STATUS_CODE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ERROR_TYPE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_HASH_KEY_VALUE_ERROR - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ITEM_HASH_KEY_VALUE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ITEM_IO_ERROR - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_ITEM_RANGE_KEY_VALUE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_KEY_ERROR_NOT_FOUND - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_KEY_ERROR_NOT_FOUND_MESSAGE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_KEY_ERROR_UNPROCESSED - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- DYNAMODB_MAX_ITEM_SIZE - Static variable in class org.apache.nifi.processors.aws.dynamodb.PutDynamoDB
-
Dyamodb max item size limit 400 kb
- DYNAMODB_RANGE_KEY_VALUE_ERROR - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-
- dynamoDBrelationships - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
-