A B C D E F G H I J K L M N O P Q R S T U V W X Y Z

M

MAGIC_BYTES - Static variable in interface org.apache.nifi.remote.protocol.CommunicationsSession

MAGIC_HEADER - Static variable in class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake

MAGIC_HEADER - Static variable in class org.apache.nifi.util.FlowFilePackagerV3

main(String[]) - Static method in class org.apache.nifi.bootstrap.RunNiFi

main(String[]) - Static method in class org.apache.nifi.io.nio.example.ServerMain

main(String[]) - Static method in class org.apache.nifi.io.nio.example.TCPClient

main(String[]) - Static method in class org.apache.nifi.io.nio.example.UDPClient

main(String[]) - Static method in class org.apache.nifi.NiFi

Main entry point of the application.

main(String[]) - Static method in class org.apache.nifi.processors.gettcp.Server

main(String[]) - Static method in class org.apache.nifi.processors.splunk.util.LogGenerator

main(String[]) - Static method in class org.apache.nifi.processors.standard.relp.RELPFrameProducer

main(String[]) - Static method in class org.apache.nifi.properties.JavaMain

main(String[]) - Static method in class org.apache.nifi.provenance.util.DumpEventFile

main(String[]) - Static method in class org.apache.nifi.storm.NiFiStormTopology

main(String[]) - Static method in class org.apache.nifi.toolkit.flowanalyzer.FlowAnalyzerDriver

main(String[]) - Static method in class org.apache.nifi.toolkit.repos.flowfile.RepairCorruptedFileEndings

main(String[]) - Static method in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain

main(String[]) - Static method in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateAuthorityClientCommandLine

main(String[]) - Static method in class org.apache.nifi.toolkit.tls.service.server.TlsCertificateAuthorityServiceCommandLine

main(String[]) - Static method in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine

main(String[]) - Static method in class org.apache.nifi.toolkit.tls.TlsToolkitMain

Callthrough to doMain

main(String[]) - Static method in class org.apache.nifi.toolkit.zkmigrator.ZooKeeperMigratorMain

main(String[]) - Static method in class org.apache.nifi.util.Unpackage

main(String[]) - Static method in class TestCustomJoltTransform

main(String[]) - Static method in class TestDynamicEnvironment

main(String[]) - Static method in class TestIngestAndUpdate

main(String[]) - Static method in class TestSuccess

makeBytes() - Static method in class org.apache.nifi.io.nio.example.TCPClient

makeBytes() - Static method in class org.apache.nifi.io.nio.example.UDPClient

makeEndPoint(List<String>, HiveOptions) - Static method in class org.apache.nifi.util.hive.HiveUtils

makeHiveEndPoint(List<String>, HiveOptions) - Method in class org.apache.nifi.processors.hive.PutHiveStreaming

makeHiveWriter(HiveEndPoint, ExecutorService, UserGroupInformation, HiveOptions) - Method in class org.apache.nifi.processors.hive.PutHiveStreaming

makeHiveWriter(HiveEndPoint, ExecutorService, UserGroupInformation, HiveOptions, HiveConf) - Static method in class org.apache.nifi.util.hive.HiveUtils

makeSureExpressionLanguageIsWorkingProperlyWithinTheHdfsPathToWatch() - Method in class org.apache.nifi.processors.hadoop.inotify.TestGetHDFSEvents

makeSureHappyPathForProcessingEventsSendsFlowFilesToCorrectRelationship() - Method in class org.apache.nifi.processors.hadoop.inotify.TestGetHDFSEvents

MalformedChunkException - Exception in org.apache.nifi.processors.evtx.parser

Exception when a chunk is malformed.

MalformedChunkException(String, Throwable, long, int, byte[]) - Constructor for exception org.apache.nifi.processors.evtx.parser.MalformedChunkException

MalformedChunkHandler - Class in org.apache.nifi.processors.evtx

Creates a FlowFile for the malformed chunk and transfers it to the badChunkRelationship

MalformedChunkHandler(Relationship) - Constructor for class org.apache.nifi.processors.evtx.MalformedChunkHandler

MalformedChunkHandlerTest - Class in org.apache.nifi.processors.evtx

MalformedChunkHandlerTest() - Constructor for class org.apache.nifi.processors.evtx.MalformedChunkHandlerTest

MalformedRecordException - Exception in org.apache.nifi.serialization

An Exception that can be thrown to indicate that data was read but could not properly be parsed

MalformedRecordException(String) - Constructor for exception org.apache.nifi.serialization.MalformedRecordException

MalformedRecordException(String, Throwable) - Constructor for exception org.apache.nifi.serialization.MalformedRecordException

MANAGED_BEGINNING_VALUE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk

MANAGED_CURRENT_VALUE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk

ManagedAuthorizer - Interface in org.apache.nifi.authorization

ManagedRangerAuthorizer - Class in org.apache.nifi.ranger.authorization

ManagedRangerAuthorizer() - Constructor for class org.apache.nifi.ranger.authorization.ManagedRangerAuthorizer

ManagedRangerAuthorizerTest - Class in org.apache.nifi.ranger.authorization

ManagedRangerAuthorizerTest() - Constructor for class org.apache.nifi.ranger.authorization.ManagedRangerAuthorizerTest

map2FlowFile(ProcessContext, ProcessSession, Message, boolean, ComponentLog) - Static method in class org.apache.nifi.processors.standard.JmsConsumer

MAP_MESSAGE_PREFIX - Static variable in class org.apache.nifi.processors.standard.JmsConsumer

MapCache - Interface in org.apache.nifi.distributed.cache.server.map

MapCacheRecord - Class in org.apache.nifi.distributed.cache.server.map

MapCacheRecord(ByteBuffer, ByteBuffer) - Constructor for class org.apache.nifi.distributed.cache.server.map.MapCacheRecord

MapCacheRecord(ByteBuffer, ByteBuffer, long) - Constructor for class org.apache.nifi.distributed.cache.server.map.MapCacheRecord

MapCacheServer - Class in org.apache.nifi.distributed.cache.server.map

MapCacheServer(String, SSLContext, int, int, EvictionPolicy, File) - Constructor for class org.apache.nifi.distributed.cache.server.map.MapCacheServer

MapDataType - Class in org.apache.nifi.serialization.record.type

MapDataType(DataType) - Constructor for class org.apache.nifi.serialization.record.type.MapDataType

MapEntryFieldValue - Class in org.apache.nifi.record.path

MapEntryFieldValue(Object, RecordField, FieldValue, String) - Constructor for class org.apache.nifi.record.path.MapEntryFieldValue

mapException(Function<Exception, ErrorTypes>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler

Specify a function that maps an Exception to certain ErrorType.

mapIdentity(String, List<IdentityMapping>) - Static method in class org.apache.nifi.authorization.util.IdentityMappingUtil

Checks the given identity against each provided mapping and performs the mapping using the first one that matches.

mapIdentity(String) - Method in class org.apache.nifi.web.security.NiFiAuthenticationProvider

MAPPED_SCHEMA_VALIDATOR - Static variable in class org.apache.nifi.processors.kite.ConvertAvroSchema

Makes sure the output schema is a valid output schema and that all its fields can be mapped either automatically or are explicitly mapped.

MAPPING - Static variable in class org.apache.nifi.processors.kite.TestConvertAvroSchema

MAPPING_FILE - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping

MAPPING_FILE_REFRESH_INTERVAL - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping

MappingEvaluator<T> - Class in org.apache.nifi.attribute.expression.language.evaluation.selection

MappingEvaluator(ReduceEvaluator<T>, MultiAttributeEvaluator) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.MappingEvaluator

MapPutResult - Class in org.apache.nifi.distributed.cache.server.map

MapPutResult(boolean, MapCacheRecord, MapCacheRecord, MapCacheRecord) - Constructor for class org.apache.nifi.distributed.cache.server.map.MapPutResult

MapRecord - Class in org.apache.nifi.serialization.record

MapRecord(RecordSchema, Map<String, Object>) - Constructor for class org.apache.nifi.serialization.record.MapRecord

MapRecord(RecordSchema, Map<String, Object>, boolean, boolean) - Constructor for class org.apache.nifi.serialization.record.MapRecord

MapRecord(RecordSchema, Map<String, Object>, SerializedForm) - Constructor for class org.apache.nifi.serialization.record.MapRecord

MapRecord(RecordSchema, Map<String, Object>, SerializedForm, boolean, boolean) - Constructor for class org.apache.nifi.serialization.record.MapRecord

MapRecordField - Class in org.apache.nifi.repository.schema

MapRecordField(String, RecordField, RecordField, Repetition) - Constructor for class org.apache.nifi.repository.schema.MapRecordField

mapResponses(URI, String, Set<NodeResponse>, boolean) - Method in interface org.apache.nifi.cluster.coordination.http.HttpResponseMapper

Maps the responses from all nodes in the cluster to a single NodeResponse object that is appropriate to respond with

mapResponses(URI, String, Set<NodeResponse>, boolean) - Method in class org.apache.nifi.cluster.coordination.http.StandardHttpResponseMapper

mark(int) - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream

mark(int) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream

mark(int) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream

mark(int) - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream

mark(int) - Method in class org.apache.nifi.remote.io.InterruptableInputStream

mark(int) - Method in class org.apache.nifi.stream.io.ByteCountingInputStream

mark(int) - Method in class org.apache.nifi.stream.io.LimitingInputStream

mark(int) - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream

mark(int) - Method in class org.apache.nifi.util.LimitingInputStream

markDestructable(ResourceClaim) - Method in interface org.apache.nifi.controller.repository.claim.ResourceClaimManager

Indicates that the given ResourceClaim can now be destroyed by the appropriate Content Repository.

markDestructable(ResourceClaim) - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager

markDestructable(ResourceClaim) - Method in class org.apache.nifi.controller.TestFileSystemSwapManager.NopResourceClaimManager

markDirty() - Method in class org.apache.nifi.provenance.AbstractRecordWriter

markDirty() - Method in interface org.apache.nifi.provenance.serialization.RecordWriter

Indicates that this Record Writer is 'dirty', meaning that it can no longer be updated.

markForAbort() - Method in class org.apache.nifi.controller.repository.StandardRepositoryRecord

markForDelete() - Method in class org.apache.nifi.controller.repository.StandardRepositoryRecord

markSupported() - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream

markSupported() - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream

markSupported() - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream

markSupported() - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream

markSupported() - Method in class org.apache.nifi.remote.io.InterruptableInputStream

markSupported() - Method in class org.apache.nifi.stream.io.ByteCountingInputStream

markSupported() - Method in class org.apache.nifi.stream.io.LimitingInputStream

markSupported() - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream

markSupported() - Method in class org.apache.nifi.util.LimitingInputStream

marshal() - Method in class org.apache.nifi.cluster.BulletinsPayload

marshal(BulletinsPayload, OutputStream) - Static method in class org.apache.nifi.cluster.BulletinsPayload

marshal() - Method in class org.apache.nifi.cluster.protocol.HeartbeatPayload

marshal(HeartbeatPayload, OutputStream) - Static method in class org.apache.nifi.cluster.protocol.HeartbeatPayload

marshal(ConnectionRequest) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.ConnectionRequestAdapter

marshal(ConnectionResponse) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.ConnectionResponseAdapter

marshal(DataFlow) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.DataFlowAdapter

marshal(Heartbeat) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.HeartbeatAdapter

marshal(NodeBulletins) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.NodeBulletinsAdapter

marshal(NodeConnectionStatus) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.NodeConnectionStatusAdapter

marshal(NodeIdentifier) - Method in class org.apache.nifi.cluster.protocol.jaxb.message.NodeIdentifierAdapter

marshal(T, OutputStream) - Method in interface org.apache.nifi.cluster.protocol.ProtocolMessageMarshaller

Serializes the given message to the given output stream.

marshal(Bulletin) - Method in class org.apache.nifi.jaxb.BulletinAdapter

marshal(Counter) - Method in class org.apache.nifi.jaxb.CounterAdapter

marshal(OutputStream) - Method in class org.apache.nifi.remote.cluster.ClusterNodeInformation

marshal(NodeInformation) - Method in class org.apache.nifi.remote.cluster.NodeInformationAdapter

marshal(Date) - Method in class org.apache.nifi.web.api.dto.util.DateTimeAdapter

marshal(Date) - Method in class org.apache.nifi.web.api.dto.util.TimeAdapter

marshal(Date) - Method in class org.apache.nifi.web.api.dto.util.TimestampAdapter

marshal(Date) - Method in class org.apache.nifi.web.api.dto.util.TimezoneAdapter

match(String) - Method in class org.apache.nifi.search.SearchResult.Builder

Set the matching string for the search result.

MATCH_ALL - Static variable in class org.apache.nifi.processors.standard.RouteOnContent

MATCH_ATTRIBUTE_KEY - Static variable in class org.apache.nifi.processors.standard.ScanContent

MATCH_CRITERIA_ALL - Static variable in class org.apache.nifi.processors.standard.ScanAttribute

MATCH_CRITERIA_ANY - Static variable in class org.apache.nifi.processors.standard.ScanAttribute

MATCH_REQUIREMENT - Static variable in class org.apache.nifi.processors.standard.RouteOnContent

MATCH_STRATEGY - Static variable in class org.apache.nifi.processors.standard.RouteText

MATCH_SUBSEQUENCE - Static variable in class org.apache.nifi.processors.standard.RouteOnContent

MATCH_THRESHOLD - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash

MATCHES_REGULAR_EXPRESSION - Static variable in class org.apache.nifi.processors.standard.RouteText

MatchesEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

MatchesEvaluator(Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.MatchesEvaluator

MatchesRegex - Class in org.apache.nifi.record.path.filter

MatchesRegex(RecordPathSegment, RecordPathSegment) - Constructor for class org.apache.nifi.record.path.filter.MatchesRegex

matchExceedsThreshold(double, double) - Method in interface org.apache.nifi.processors.cybersecurity.matchers.FuzzyHashMatcher

matchExceedsThreshold(double, double) - Method in class org.apache.nifi.processors.cybersecurity.matchers.SSDeepHashMatcher

matchExceedsThreshold(double, double) - Method in class org.apache.nifi.processors.cybersecurity.matchers.TLSHHashMatcher

MATCHING_CRITERIA - Static variable in class org.apache.nifi.processors.standard.ScanAttribute

MATCHING_GROUP_FOR_LOOKUP_KEY - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping

MATCHING_MODE - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash

MathEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

MathEvaluator(Evaluator<Number>, Evaluator<String>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.MathEvaluator

MAX_AGE - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS

MAX_AGE - Static variable in class org.apache.nifi.processors.hadoop.ListHDFS

MAX_AGE - Static variable in class org.apache.nifi.processors.standard.GetFile

MAX_AGE - Static variable in class org.apache.nifi.processors.standard.ListFile

MAX_ALLOWED_UTF_LENGTH - Static variable in class org.apache.nifi.provenance.StandardRecordWriter

Deprecated.

MAX_ALLOWED_UTF_LENGTH - Static variable in class org.apache.nifi.repository.schema.SchemaRecordWriter

MAX_APPENDABLE_CLAIM_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties

MAX_ARCHIVE_SIZE_PATTERN - Static variable in class org.apache.nifi.controller.repository.FileSystemRepository

MAX_BATCH_SIZE - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

MAX_BATCH_SIZE - Static variable in class org.apache.nifi.processors.standard.ListenSyslog

MAX_BATCH_SIZE - Static variable in class org.apache.nifi.processors.standard.PostHTTP

MAX_BIN_AGE - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MAX_BIN_AGE - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MAX_BIN_COUNT - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MAX_BIN_COUNT - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MAX_BINARY_MESSAGE_SIZE - Static variable in class org.apache.nifi.websocket.jetty.AbstractJettyWebSocketService

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.kafka.PutKafka

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ConvertCharacterSet

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ExtractGrok

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ExtractText

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ReplaceText

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MAX_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog

MAX_BULLETINS_FOR_CONTROLLER - Static variable in interface org.apache.nifi.reporting.BulletinRepository

MAX_BULLETINS_PER_COMPONENT - Static variable in interface org.apache.nifi.reporting.BulletinRepository

MAX_CACHE_ENTRIES - Static variable in class org.apache.nifi.distributed.cache.server.DistributedCacheServer

MAX_CACHE_SOFT_LIMIT - Static variable in class org.apache.nifi.web.security.otp.OtpService

MAX_CAPTURE_GROUP_LENGTH - Static variable in class org.apache.nifi.processors.standard.ExtractText

MAX_COMPONENT_STATE_ENTRIES - Static variable in class org.apache.nifi.controller.state.SortedStateUtils

The maximum number of state entries to return to a client

MAX_CONNECTIONS - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

MAX_CONNECTIONS - Static variable in class org.apache.nifi.processors.standard.ListenSyslog

MAX_DATA_RATE - Static variable in class org.apache.nifi.processors.standard.ListenHTTP

MAX_DATA_RATE - Static variable in class org.apache.nifi.processors.standard.PostHTTP

MAX_DELETE_INDEX_WAIT_SECONDS - Static variable in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex

MAX_DESTINATION_FILES - Static variable in class org.apache.nifi.processors.standard.PutFile

MAX_DOCUMENTS_PER_THREAD - Static variable in class org.apache.nifi.provenance.index.lucene.EventIndexTask

MAX_ENCODING_VERSION - Static variable in class org.apache.nifi.web.api.dto.TemplateDTO

MAX_ENTRIES - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MAX_EVENT_QUEUE_SIZE - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog

MAX_EXPIRED_RECORDS_PER_ITERATION - Static variable in class org.apache.nifi.controller.StandardFlowFileQueue

MAX_FILE_LOCK_ATTEMPTS - Static variable in class org.apache.nifi.processors.standard.PutFile

MAX_FLOW_FILES_PER_BATCH - Static variable in class org.apache.nifi.processors.standard.ControlRate

MAX_FLOWFILES_PER_CLAIM - Static variable in class org.apache.nifi.util.NiFiProperties

MAX_FRAGMENTS - Static variable in class org.apache.nifi.processors.standard.QueryDatabaseTable

MAX_INDEX_THREADS - Static variable in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex

MAX_INDEXING_FAILURE_COUNT - Static variable in class org.apache.nifi.provenance.PersistentProvenanceRepository

MAX_JOURNAL_ROLLOVER_RETRIES - Static variable in class org.apache.nifi.provenance.PersistentProvenanceRepository

MAX_LINEAGE_NODES - Static variable in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex

MAX_LINEAGE_UUIDS - Static variable in class org.apache.nifi.provenance.lucene.LineageQuery

MAX_MESSAGE_BUFFER_SIZE_MB - Static variable in class org.apache.nifi.processors.aws.kinesis.AbstractBaseKinesisProcessor

MAX_MESSAGE_BUFFER_SIZE_MB - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.AbstractKinesisFirehoseProcessor

MAX_MESSAGE_QUEUE_SIZE - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

MAX_MESSAGE_QUEUE_SIZE - Static variable in class org.apache.nifi.processors.standard.ListenSyslog

MAX_MESSAGE_SIZE - Static variable in class org.apache.nifi.processors.aws.kinesis.AbstractBaseKinesisProcessor

Max buffer size 1 MB

MAX_MESSAGE_SIZE - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose

Max buffer size 1 MB

MAX_NUM_ATTRIBUTES - Static variable in class org.apache.nifi.remote.codec.StandardFlowFileCodec

MAX_NUMBER_OF_ATTRIBUTES - Static variable in class org.apache.nifi.processors.image.ExtractImageMetadata

MAX_OPEN_CONNECTIONS - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming

MAX_ORDER - Static variable in class org.apache.nifi.processors.standard.EnforceOrder

MAX_OUTSTANDING_REQUESTS - Static variable in class org.apache.nifi.http.StandardHttpContextMap

MAX_PADDING_SIZE - Static variable in class org.apache.nifi.processors.parquet.PutParquet

MAX_QUERY_RESULTS - Static variable in class org.apache.nifi.provenance.lucene.LineageQuery

MAX_RATE - Static variable in class org.apache.nifi.processors.standard.ControlRate

MAX_RECORD_ID - Static variable in class org.apache.nifi.controller.swap.SwapSchema

MAX_RECORDS - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MAX_REMOVALS_PER_ITERATION - Static variable in class org.apache.nifi.test.processors.StubTerminationFileProcessor

MAX_REQUEST_SIZE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda

Max request body size

MAX_ROWS_PER_FLOW_FILE - Static variable in class org.apache.nifi.processors.standard.QueryDatabaseTable

MAX_S3_PUTOBJECT_SIZE - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MAX_SELECTS - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer

MAX_SESSION_TIME - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors

Max session time for role based credentials.

MAX_SESSION_TIME - Static variable in class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService

MAX_SIZE - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MAX_SIZE - Static variable in class org.apache.nifi.processors.aws.sns.PutSNS

MAX_SIZE - Static variable in class org.apache.nifi.processors.standard.GetFile

MAX_SIZE - Static variable in class org.apache.nifi.processors.standard.ListFile

MAX_SIZE - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MAX_SIZE_PROPERTY - Static variable in class org.apache.nifi.controller.repository.VolatileContentRepository

MAX_SOCKET_BUFFER_SIZE - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

MAX_SOCKET_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ListenSyslog

MAX_SOCKET_SEND_BUFFER_SIZE - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

MAX_SOCKET_SEND_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.PutSyslog

MAX_TEXT_MESSAGE_SIZE - Static variable in class org.apache.nifi.websocket.jetty.AbstractJettyWebSocketService

MAX_TOTAL_CONNECTIONS - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool

MAX_TOTAL_CONNECTIONS - Static variable in class org.apache.nifi.dbcp.hive.HiveConnectionPool

MAX_UDP_PACKET_SIZE - Static variable in class org.apache.nifi.io.nio.DatagramChannelReader

MAX_UNCONFIRMED_TIME - Static variable in class org.apache.nifi.processors.standard.ListenHTTP

MAX_UNDELETED_QUERY_RESULTS - Static variable in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex

MAX_UNDELETED_QUERY_RESULTS - Static variable in class org.apache.nifi.provenance.PersistentProvenanceRepository

MAX_VALUE_COLUMN_NAMES - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor

MAX_WAIT_TIME - Static variable in class org.apache.nifi.dbcp.DBCPConnectionPool

MAX_WAIT_TIME - Static variable in class org.apache.nifi.dbcp.hive.HiveConnectionPool

MAX_WORKING_QUEUE_SIZE - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS

MAX_WRITE_SIZE - Static variable in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel

MAXIMUM - Static variable in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric

maxOpenConnections - Variable in class org.apache.nifi.util.hive.HiveOptions

maxRows(int) - Method in class org.apache.nifi.processors.standard.util.JdbcCommon.AvroConversionOptions.Builder

maxSendBufferSize - Variable in class org.apache.nifi.processor.util.put.sender.ChannelSender

maxValueProperties - Variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor

MaxValueResultSetRowCollector(String, Map<String, String>, DatabaseAdapter) - Constructor for class org.apache.nifi.processors.standard.QueryDatabaseTable.MaxValueResultSetRowCollector

MD5 - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject

MD5_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

MD5_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

MD5SumMonitor - Class in org.apache.nifi.util.file.monitor

MD5SumMonitor() - Constructor for class org.apache.nifi.util.file.monitor.MD5SumMonitor

MEDIA_LINK_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

MEDIA_LINK_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

MEMORY_POOL_PROPERTY - Static variable in class org.apache.nifi.controller.MonitorMemory

MemoryManager - Class in org.apache.nifi.controller.repository.io

MemoryManager(long, int) - Constructor for class org.apache.nifi.controller.repository.io.MemoryManager

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in interface org.apache.nifi.cluster.coordination.http.EndpointResponseMerger

Maps the given Node Responses to a single NodeResponse that is appropriate to return to the client/user

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleDTOEndpoint

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ConnectionsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServiceReferenceEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServicesEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.FlowSnippetEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.FunnelsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.InputPortsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.LabelsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.OutputPortsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceQueryEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTasksEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.SearchUsersEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.StatusHistoryEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.TemplatesEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.UserGroupsEndpointMerger

merge(URI, String, Set<NodeResponse>, Set<NodeResponse>, NodeResponse) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.UsersEndpointMerger

merge(AccessPolicyEntity, Map<NodeIdentifier, AccessPolicyEntity>) - Method in class org.apache.nifi.cluster.manager.AccessPolicyEntityMerger

merge(AllowableValueEntity, Collection<AllowableValueEntity>) - Static method in class org.apache.nifi.cluster.manager.AllowableValueEntityMerger

merge(EntityType, Map<NodeIdentifier, EntityType>) - Method in interface org.apache.nifi.cluster.manager.ComponentEntityMerger

Merges the ComponentEntity responses according to their PermissionsDTOs.

merge(ConnectionEntity, Map<NodeIdentifier, ConnectionEntity>) - Method in class org.apache.nifi.cluster.manager.ConnectionEntityMerger

merge(PortEntity, Map<NodeIdentifier, PortEntity>) - Method in class org.apache.nifi.cluster.manager.PortEntityMerger

merge(ProcessGroupEntity, Map<NodeIdentifier, ProcessGroupEntity>) - Method in class org.apache.nifi.cluster.manager.ProcessGroupEntityMerger

merge(ProcessorEntity, Map<NodeIdentifier, ProcessorEntity>) - Method in class org.apache.nifi.cluster.manager.ProcessorEntityMerger

merge(PropertyDescriptorDTO, Map<NodeIdentifier, PropertyDescriptorDTO>) - Static method in class org.apache.nifi.cluster.manager.PropertyDescriptorDtoMerger

merge(RemoteProcessGroupEntity, Map<NodeIdentifier, RemoteProcessGroupEntity>) - Method in class org.apache.nifi.cluster.manager.RemoteProcessGroupEntityMerger

merge(ControllerStatusDTO, ControllerStatusDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessGroupStatusDTO, boolean, ProcessGroupStatusDTO, boolean, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessGroupStatusSnapshotEntity, ProcessGroupStatusSnapshotEntity) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessGroupStatusSnapshotDTO, boolean, ProcessGroupStatusSnapshotDTO, boolean) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(RemoteProcessGroupStatusDTO, boolean, RemoteProcessGroupStatusDTO, boolean, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(PortStatusDTO, boolean, PortStatusDTO, boolean, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ConnectionStatusDTO, boolean, ConnectionStatusDTO, boolean, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessorStatusDTO, boolean, ProcessorStatusDTO, boolean, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessorStatusSnapshotEntity, ProcessorStatusSnapshotEntity) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ProcessorStatusSnapshotDTO, boolean, ProcessorStatusSnapshotDTO, boolean) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ConnectionStatusSnapshotEntity, ConnectionStatusSnapshotEntity) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(ConnectionStatusSnapshotDTO, boolean, ConnectionStatusSnapshotDTO, boolean) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(RemoteProcessGroupStatusSnapshotEntity, RemoteProcessGroupStatusSnapshotEntity) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(RemoteProcessGroupStatusSnapshotDTO, boolean, RemoteProcessGroupStatusSnapshotDTO, boolean) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(PortStatusSnapshotEntity, PortStatusSnapshotEntity) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(PortStatusSnapshotDTO, boolean, PortStatusSnapshotDTO, boolean) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(SystemDiagnosticsDTO, SystemDiagnosticsDTO, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(SystemDiagnosticsSnapshotDTO, SystemDiagnosticsSnapshotDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(Set<SystemDiagnosticsSnapshotDTO.StorageUsageDTO>, Set<SystemDiagnosticsSnapshotDTO.StorageUsageDTO>) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(SystemDiagnosticsSnapshotDTO.StorageUsageDTO, SystemDiagnosticsSnapshotDTO.StorageUsageDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(SystemDiagnosticsSnapshotDTO.GarbageCollectionDTO, SystemDiagnosticsSnapshotDTO.GarbageCollectionDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(CountersDTO, CountersDTO, String, String, Integer) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(CountersSnapshotDTO, CountersSnapshotDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(CounterDTO, CounterDTO) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

merge(UserEntity, Map<NodeIdentifier, UserEntity>) - Method in class org.apache.nifi.cluster.manager.UserEntityMerger

merge(UserGroupEntity, Map<NodeIdentifier, UserGroupEntity>) - Method in class org.apache.nifi.cluster.manager.UserGroupEntityMerger

merge(Collection<ContentClaim>, ContentClaim, byte[], byte[], byte[]) - Method in interface org.apache.nifi.controller.repository.ContentRepository

Creates a new content item that is the merger in iteration order of all content for the given claims

merge(Collection<ContentClaim>, ContentClaim, byte[], byte[], byte[]) - Method in class org.apache.nifi.controller.repository.FileSystemRepository

merge(Collection<FlowFile>, FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProcessSession

merge(Collection<FlowFile>, FlowFile, byte[], byte[], byte[]) - Method in class org.apache.nifi.controller.repository.StandardProcessSession

merge(Collection<ContentClaim>, ContentClaim, byte[], byte[], byte[]) - Method in class org.apache.nifi.controller.repository.VolatileContentRepository

merge(ProcessGroupStatus, ProcessGroupStatus) - Static method in class org.apache.nifi.controller.status.ProcessGroupStatus

merge(Collection<FlowFile>, FlowFile) - Method in interface org.apache.nifi.processor.ProcessSession

Combines the content of all given source FlowFiles into a single given destination FlowFile.

merge(Collection<FlowFile>, FlowFile, byte[], byte[], byte[]) - Method in interface org.apache.nifi.processor.ProcessSession

Combines the content of all given source FlowFiles into a single given destination FlowFile.

merge(RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult

merge(RecordSchema, RecordSchema) - Static method in class org.apache.nifi.serialization.record.util.DataTypeUtils

merge(RecordField, RecordField) - Static method in class org.apache.nifi.serialization.record.util.DataTypeUtils

merge(Collection<FlowFile>, FlowFile) - Method in class org.apache.nifi.util.MockProcessSession

merge(Collection<FlowFile>, FlowFile, byte[], byte[], byte[]) - Method in class org.apache.nifi.util.MockProcessSession

MERGE_BIN_AGE_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.merge.RecordBin

MERGE_BIN_AGE_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_BIN_AGE_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MERGE_COUNT_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.merge.RecordBin

MERGE_COUNT_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_COUNT_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MERGE_FORMAT - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_AVRO - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_AVRO_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_CONCAT - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_CONCAT_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_STREAM_V2 - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_STREAM_V2_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_STREAM_V3 - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_STREAM_V3_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_TAR_V1 - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_FLOWFILE_TAR_V1_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_TAR - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_TAR_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_ZIP - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_FORMAT_ZIP_VALUE - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_STRATEGY - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_STRATEGY - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MERGE_STRATEGY_BIN_PACK - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_STRATEGY_BIN_PACK - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MERGE_STRATEGY_DEFRAGMENT - Static variable in class org.apache.nifi.processors.standard.MergeContent

MERGE_STRATEGY_DEFRAGMENT - Static variable in class org.apache.nifi.processors.standard.MergeRecord

mergeAffectedComponents(Set<AffectedComponentEntity>, Map<NodeIdentifier, Set<AffectedComponentEntity>>) - Method in class org.apache.nifi.cluster.manager.AffectedComponentEntityMerger

mergeBulletins(Map<NodeIdentifier, List<BulletinEntity>>, int) - Static method in class org.apache.nifi.cluster.manager.BulletinMerger

Merges the bulletins.

mergeBulletins() - Method in class org.apache.nifi.cluster.manager.BulletinMergerTest

mergeComponents(AccessPolicyEntity, Map<NodeIdentifier, AccessPolicyEntity>) - Method in class org.apache.nifi.cluster.manager.AccessPolicyEntityMerger

Merges the AccessPolicyEntity responses.

mergeComponents(EntityType, Map<NodeIdentifier, EntityType>) - Method in interface org.apache.nifi.cluster.manager.ComponentEntityMerger

Performs the merging of the entities.

mergeComponents(ControllerServiceEntity, Map<NodeIdentifier, ControllerServiceEntity>) - Method in class org.apache.nifi.cluster.manager.ControllerServiceEntityMerger

Merges the ControllerServiceEntity responses.

mergeComponents(PortEntity, Map<NodeIdentifier, PortEntity>) - Method in class org.apache.nifi.cluster.manager.PortEntityMerger

Merges the PortEntity responses.

mergeComponents(ProcessorEntity, Map<NodeIdentifier, ProcessorEntity>) - Method in class org.apache.nifi.cluster.manager.ProcessorEntityMerger

Merges the ProcessorEntity responses.

mergeComponents(RemoteProcessGroupEntity, Map<NodeIdentifier, RemoteProcessGroupEntity>) - Method in class org.apache.nifi.cluster.manager.RemoteProcessGroupEntityMerger

Merges the RemoteProcessGroupEntity responses.

mergeComponents(ReportingTaskEntity, Map<NodeIdentifier, ReportingTaskEntity>) - Method in class org.apache.nifi.cluster.manager.ReportingTaskEntityMerger

Merges the ReportingTaskEntity responses.

mergeComponents(UserEntity, Map<NodeIdentifier, UserEntity>) - Method in class org.apache.nifi.cluster.manager.UserEntityMerger

Merges the UserEntity responses.

mergeComponents(UserGroupEntity, Map<NodeIdentifier, UserGroupEntity>) - Method in class org.apache.nifi.cluster.manager.UserGroupEntityMerger

Merges the UserGroupEntity responses.

mergeConnections(Set<ConnectionEntity>, Map<String, Map<NodeIdentifier, ConnectionEntity>>) - Static method in class org.apache.nifi.cluster.manager.ConnectionsEntityMerger

Merges multiple ConnectionEntity responses.

MergeContent - Class in org.apache.nifi.processors.standard

MergeContent() - Constructor for class org.apache.nifi.processors.standard.MergeContent

mergeControllerServiceReferences(Set<ControllerServiceReferencingComponentEntity>, Map<NodeIdentifier, Set<ControllerServiceReferencingComponentEntity>>) - Static method in class org.apache.nifi.cluster.manager.ControllerServiceEntityMerger

mergeControllerServices(Set<ControllerServiceEntity>, Map<String, Map<NodeIdentifier, ControllerServiceEntity>>) - Static method in class org.apache.nifi.cluster.manager.ControllerServicesEntityMerger

Merges multiple ControllerServiceEntity responses.

mergeDocumentedTypes(Set<DocumentedTypeDTO>, Map<NodeIdentifier, Set<DocumentedTypeDTO>>) - Static method in class org.apache.nifi.cluster.manager.DocumentedTypesMerger

Merges the documented types from all nodes in the cluster.

mergeDtos(PortDTO, Map<NodeIdentifier, PortDTO>) - Static method in class org.apache.nifi.cluster.manager.PortEntityMerger

mergeErrors(Map<String, Set<NodeIdentifier>>, NodeIdentifier, Collection<String>) - Static method in class org.apache.nifi.cluster.manager.ErrorMerger

Merges the validation or authorization errors.

mergeFunnels(Set<FunnelEntity>, Map<String, Map<NodeIdentifier, FunnelEntity>>) - Static method in class org.apache.nifi.cluster.manager.FunnelsEntityMerger

Merges multiple FunnelEntity responses.

mergeGarbageCollection(Set<SystemDiagnosticsSnapshotDTO.GarbageCollectionDTO>, Set<SystemDiagnosticsSnapshotDTO.GarbageCollectionDTO>) - Static method in class org.apache.nifi.cluster.manager.StatusMerger

mergeLabels(Set<LabelEntity>, Map<String, Map<NodeIdentifier, LabelEntity>>) - Static method in class org.apache.nifi.cluster.manager.LabelsEntityMerger

Merges multiple LabelEntity responses.

mergePermissions(PermissionsDTO, PermissionsDTO) - Static method in class org.apache.nifi.cluster.manager.PermissionsDtoMerger

Merges multiple PermissionsDTOs.

mergePorts(Set<PortEntity>, Map<String, Map<NodeIdentifier, PortEntity>>) - Static method in class org.apache.nifi.cluster.manager.PortsEntityMerger

Merges multiple PortEntity responses.

mergeProcessGroups(Set<ProcessGroupEntity>, Map<String, Map<NodeIdentifier, ProcessGroupEntity>>) - Static method in class org.apache.nifi.cluster.manager.ProcessGroupsEntityMerger

Merges multiple ProcessGroupEntity responses.

mergeProcessors(Set<ProcessorEntity>, Map<String, Map<NodeIdentifier, ProcessorEntity>>) - Static method in class org.apache.nifi.cluster.manager.ProcessorsEntityMerger

Merges multiple ProcessorEntity responses.

MergeRecord - Class in org.apache.nifi.processors.standard

MergeRecord() - Constructor for class org.apache.nifi.processors.standard.MergeRecord

mergeRemoteProcessGroups(Set<RemoteProcessGroupEntity>, Map<String, Map<NodeIdentifier, RemoteProcessGroupEntity>>) - Static method in class org.apache.nifi.cluster.manager.RemoteProcessGroupsEntityMerger

Merges multiple RemoteProcessGroupEntity responses.

mergeReportingTasks(Set<ReportingTaskEntity>, Map<String, Map<NodeIdentifier, ReportingTaskEntity>>) - Static method in class org.apache.nifi.cluster.manager.ReportingTasksEntityMerger

Merges multiple ReportingTaskEntity responses.

mergeResponses(DtoType, Map<NodeIdentifier, DtoType>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractNodeStatusEndpoint

mergeResponses(DtoType, Map<NodeIdentifier, DtoType>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractNodeStatusEndpoint

mergeResponses(DtoType, Map<NodeIdentifier, DtoType>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleDTOEndpoint

Merges the responses from all nodes in the given map into the single given DTO

mergeResponses(EntityType, Map<NodeIdentifier, EntityType>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint

Merges the responses from all nodes in the given map into the single given entity

mergeResponses(AccessPolicyEntity, Map<NodeIdentifier, AccessPolicyEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMerger

mergeResponses(BulletinBoardDTO, Map<NodeIdentifier, BulletinBoardDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.BulletinBoardEndpointMerger

mergeResponses(ComponentStateDTO, Map<NodeIdentifier, ComponentStateDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ComponentStateEndpointMerger

mergeResponses(ConnectionEntity, Map<NodeIdentifier, ConnectionEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ConnectionEndpointMerger

mergeResponses(ConnectionStatusEntity, Map<NodeIdentifier, ConnectionStatusEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ConnectionStatusEndpointMerger

mergeResponses(ControllerBulletinsEntity, Map<NodeIdentifier, ControllerBulletinsEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerBulletinsEndpointMerger

mergeResponses(ControllerConfigurationEntity, Map<NodeIdentifier, ControllerConfigurationEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerConfigurationEndpointMerger

mergeResponses(ControllerDTO, Map<NodeIdentifier, ControllerDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerEndpointMerger

mergeResponses(ControllerServiceEntity, Map<NodeIdentifier, ControllerServiceEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServiceEndpointMerger

mergeResponses(Set<DocumentedTypeDTO>, Map<NodeIdentifier, Set<DocumentedTypeDTO>>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServiceTypesEndpointMerger

mergeResponses(ControllerStatusDTO, Map<NodeIdentifier, ControllerStatusDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerStatusEndpointMerger

mergeResponses(CountersDTO, Map<NodeIdentifier, CountersDTO>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.CountersEndpointMerger

mergeResponses(CurrentUserEntity, Map<NodeIdentifier, CurrentUserEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.CurrentUserEndpointMerger

mergeResponses(DropRequestDTO, Map<NodeIdentifier, DropRequestDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.DropRequestEndpointMerger

mergeResponses(FlowConfigurationDTO, Map<NodeIdentifier, FlowConfigurationDTO>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.FlowConfigurationEndpointMerger

mergeResponses(ProcessGroupFlowDTO, Map<NodeIdentifier, ProcessGroupFlowDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.FlowMerger

mergeResponses(FunnelEntity, Map<NodeIdentifier, FunnelEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.FunnelEndpointMerger

mergeResponses(ProcessGroupStatusEntity, Map<NodeIdentifier, ProcessGroupStatusEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.GroupStatusEndpointMerger

mergeResponses(LabelEntity, Map<NodeIdentifier, LabelEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.LabelEndpointMerger

mergeResponses(ListingRequestDTO, Map<NodeIdentifier, ListingRequestDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ListFlowFilesEndpointMerger

mergeResponses(PortEntity, Map<NodeIdentifier, PortEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.PortEndpointMerger

mergeResponses(PortStatusEntity, Map<NodeIdentifier, PortStatusEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.PortStatusEndpointMerger

mergeResponses(Set<DocumentedTypeDTO>, Map<NodeIdentifier, Set<DocumentedTypeDTO>>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.PrioritizerTypesEndpointMerger

mergeResponses(ProcessGroupEntity, Map<NodeIdentifier, ProcessGroupEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupEndpointMerger

mergeResponses(ProcessorEntity, Map<NodeIdentifier, ProcessorEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorEndpointMerger

mergeResponses(ProcessorStatusEntity, Map<NodeIdentifier, ProcessorStatusEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorStatusEndpointMerger

mergeResponses(Set<DocumentedTypeDTO>, Map<NodeIdentifier, Set<DocumentedTypeDTO>>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorTypesEndpointMerger

mergeResponses(ProvenanceEventDTO, Map<NodeIdentifier, ProvenanceEventDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceEventEndpointMerger

mergeResponses(ProvenanceDTO, Map<NodeIdentifier, ProvenanceDTO>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceQueryEndpointMerger

mergeResponses(RemoteProcessGroupEntity, Map<NodeIdentifier, RemoteProcessGroupEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupEndpointMerger

mergeResponses(RemoteProcessGroupStatusEntity, Map<NodeIdentifier, RemoteProcessGroupStatusEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupStatusEndpointMerger

mergeResponses(ReportingTaskEntity, Map<NodeIdentifier, ReportingTaskEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskEndpointMerger

mergeResponses(Set<DocumentedTypeDTO>, Map<NodeIdentifier, Set<DocumentedTypeDTO>>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskTypesEndpointMerger

mergeResponses(SystemDiagnosticsDTO, Map<NodeIdentifier, SystemDiagnosticsDTO>, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.SystemDiagnosticsEndpointMerger

mergeResponses(UserEntity, Map<NodeIdentifier, UserEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.UserEndpointMerger

mergeResponses(UserGroupEntity, Map<NodeIdentifier, UserGroupEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.UserGroupEndpointMerger

mergeResponses(VariableRegistryEntity, Map<NodeIdentifier, VariableRegistryEntity>, Set<NodeResponse>, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.VariableRegistryEndpointMerger

mergeStatus(ConnectionStatusDTO, boolean, ConnectionStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ConnectionStatusEndpointMerger

mergeStatus(ProcessGroupStatusDTO, boolean, ProcessGroupStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.GroupStatusEndpointMerger

mergeStatus(PortStatusDTO, boolean, PortStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.PortStatusEndpointMerger

mergeStatus(ProcessorStatusDTO, boolean, ProcessorStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorStatusEndpointMerger

mergeStatus(RemoteProcessGroupStatusDTO, boolean, RemoteProcessGroupStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupStatusEndpointMerger

mergeStatus(StatusDtoType, boolean, StatusDtoType, boolean, NodeIdentifier) - Method in interface org.apache.nifi.cluster.manager.ComponentEntityStatusMerger

Merges status into clientStatus based on the given permissions.

mergeStatus(ConnectionStatusDTO, boolean, ConnectionStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.manager.ConnectionEntityMerger

mergeStatus(PortStatusDTO, boolean, PortStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.manager.PortEntityMerger

mergeStatus(ProcessGroupStatusDTO, boolean, ProcessGroupStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.manager.ProcessGroupEntityMerger

mergeStatus(ProcessorStatusDTO, boolean, ProcessorStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.manager.ProcessorEntityMerger

mergeStatus(RemoteProcessGroupStatusDTO, boolean, RemoteProcessGroupStatusDTO, boolean, NodeIdentifier) - Method in class org.apache.nifi.cluster.manager.RemoteProcessGroupEntityMerger

mergeUserGroups(Collection<UserGroupEntity>, Map<String, Map<NodeIdentifier, UserGroupEntity>>) - Static method in class org.apache.nifi.cluster.manager.UserGroupsEntityMerger

Merges multiple UserGroupEntity responses.

mergeUsers(Collection<UserEntity>, Map<String, Map<NodeIdentifier, UserEntity>>) - Static method in class org.apache.nifi.cluster.manager.UsersEntityMerger

Merges multiple UserEntity responses.

MESSAGE - Static variable in class org.apache.nifi.processors.standard.PutEmail

MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processors.kafka.PutKafka

MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processors.standard.ListenSyslog

MESSAGE_DEMARCATOR - Static variable in class org.apache.nifi.processors.kafka.GetKafka

MESSAGE_KEY - Static variable in interface org.apache.nifi.hl7.query.evaluator.Evaluator

MESSAGE_PATTERNS - Static variable in class org.apache.nifi.processors.standard.syslog.SyslogParser

MESSAGE_PRIORITY - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MESSAGE_SELECTOR - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MESSAGE_TTL - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MESSAGE_TYPE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

messageDemarcatorBytes - Variable in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

MessageEvaluator - Class in org.apache.nifi.hl7.query.evaluator.message

MessageEvaluator() - Constructor for class org.apache.nifi.hl7.query.evaluator.message.MessageEvaluator

MessageHandler - Interface in org.apache.nifi.processors.gettcp

messageMatches(String) - Method in class org.apache.nifi.reporting.BulletinQuery.Builder

messageQueue - Variable in class org.apache.nifi.processors.email.ConsumeEWS

MessageSender - Interface in org.apache.nifi.websocket

METADATA_STRATEGY - Static variable in class org.apache.nifi.processors.standard.MergeContent

METADATA_STRATEGY_ALL_COMMON - Static variable in class org.apache.nifi.processors.standard.MergeContent

METADATA_STRATEGY_DO_NOT_MERGE - Static variable in class org.apache.nifi.processors.standard.MergeContent

METADATA_STRATEGY_IGNORE - Static variable in class org.apache.nifi.processors.standard.MergeContent

METADATA_STRATEGY_USE_FIRST - Static variable in class org.apache.nifi.processors.standard.MergeContent

METAGENERATION_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

METAGENERATION_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

METASTORE_URI - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming

metaStoreURI - Variable in class org.apache.nifi.util.hive.HiveOptions

MethodProfiler - Class in org.apache.nifi.aop

MethodProfiler() - Constructor for class org.apache.nifi.aop.MethodProfiler

metric(String, String) - Method in class org.apache.nifi.reporting.ambari.api.MetricsBuilder

metric(String, String) - Method in class org.apache.nifi.reporting.datadog.api.MetricsBuilder

METRIC_NAME - Static variable in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric

METRIC_NAME - Static variable in interface org.apache.nifi.reporting.ambari.api.MetricFields

METRIC_NAME - Static variable in interface org.apache.nifi.reporting.datadog.api.MetricFields

METRIC_NAME_SEPARATOR - Static variable in interface org.apache.nifi.reporting.ambari.metrics.MetricNames

MetricBuilder - Class in org.apache.nifi.reporting.ambari.api

Builds the JsonObject for an individual metric.

MetricBuilder(JsonBuilderFactory) - Constructor for class org.apache.nifi.reporting.ambari.api.MetricBuilder

MetricBuilder - Class in org.apache.nifi.reporting.datadog.api

Builds the JsonObject for an individual metric.

MetricBuilder(JsonBuilderFactory) - Constructor for class org.apache.nifi.reporting.datadog.api.MetricBuilder

MetricDescriptor<T> - Interface in org.apache.nifi.controller.status.history

Describes a particular metric that is derived from a Status History

MetricDescriptor.Formatter - Enum in org.apache.nifi.controller.status.history

MetricFields - Interface in org.apache.nifi.reporting.ambari.api

MetricFields - Interface in org.apache.nifi.reporting.datadog.api

metricName(String) - Method in class org.apache.nifi.reporting.ambari.api.MetricBuilder

metricName(String) - Method in class org.apache.nifi.reporting.datadog.api.MetricBuilder

MetricNames - Interface in org.apache.nifi.reporting.ambari.metrics

The Metric names to send to Ambari.

MetricNames - Interface in org.apache.nifi.reporting.datadog.metrics

The Metric names to send to DataDog.

METRICS - Static variable in interface org.apache.nifi.reporting.ambari.api.MetricFields

METRICS - Static variable in interface org.apache.nifi.reporting.datadog.api.MetricFields

METRICS_GROUP - Static variable in class org.apache.nifi.reporting.ganglia.StandardGangliaReporter

METRICS_RESERVOIR_SIZE - Static variable in class org.apache.nifi.controller.FlowController

MetricsBuilder - Class in org.apache.nifi.reporting.ambari.api

Builds the overall JsonObject for the Metrics.

MetricsBuilder(JsonBuilderFactory) - Constructor for class org.apache.nifi.reporting.ambari.api.MetricsBuilder

MetricsBuilder - Class in org.apache.nifi.reporting.datadog.api

Builds the overall JsonObject for the Metrics.

MetricsBuilder(JsonBuilderFactory) - Constructor for class org.apache.nifi.reporting.datadog.api.MetricsBuilder

MetricsService - Class in org.apache.nifi.reporting.ambari.metrics

A service used to produce key/value metrics based on a given input.

MetricsService() - Constructor for class org.apache.nifi.reporting.ambari.metrics.MetricsService

MetricsService - Class in org.apache.nifi.reporting.datadog.metrics

A service used to produce key/value metrics based on a given input.

MetricsService() - Constructor for class org.apache.nifi.reporting.datadog.metrics.MetricsService

metricValue(String) - Method in class org.apache.nifi.reporting.ambari.api.MetricBuilder

metricValue(String) - Method in class org.apache.nifi.reporting.datadog.api.MetricBuilder

migrate(ProcessSession, Collection<FlowFile>) - Method in class org.apache.nifi.controller.repository.StandardProcessSession

migrate(ProcessSession, Collection<FlowFile>) - Method in interface org.apache.nifi.processor.ProcessSession

Migrates ownership of the given FlowFiles from this to the given newOwner.

migrate(ProcessSession, Collection<FlowFile>) - Method in class org.apache.nifi.util.MockProcessSession

MILLIS_BETWEEN_ATTEMPTS - Static variable in class org.apache.nifi.util.file.FileUtils

MILLIS_BETWEEN_ATTEMPTS - Static variable in class org.apache.nifi.util.FileUtils

MIME_TYPE_AVRO_BINARY - Static variable in class org.apache.nifi.processors.standard.util.JdbcCommon

MIME_TYPES - Static variable in class org.apache.nifi.processors.script.engine.ClojureScriptEngineFactory

MIN_AGE - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS

MIN_AGE - Static variable in class org.apache.nifi.processors.hadoop.ListHDFS

MIN_AGE - Static variable in class org.apache.nifi.processors.standard.GetFile

MIN_AGE - Static variable in class org.apache.nifi.processors.standard.ListFile

MIN_BUFFER_SIZE - Static variable in class org.apache.nifi.remote.io.CompressionOutputStream

MIN_CLEANUP_INTERVAL_MILLIS - Static variable in class org.apache.nifi.controller.repository.FileSystemRepository

MIN_ENTRIES - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MIN_RECORDS - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MIN_S3_PART_SIZE - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MIN_SIZE - Static variable in class org.apache.nifi.processor.util.bin.BinFiles

MIN_SIZE - Static variable in class org.apache.nifi.processors.standard.GetFile

MIN_SIZE - Static variable in class org.apache.nifi.processors.standard.ListFile

MIN_SIZE - Static variable in class org.apache.nifi.processors.standard.MergeRecord

MinimalLockingWriteAheadLog<T> - Class in org.wali

This implementation provides as little Locking as possible in order to provide the highest throughput possible.

MinimalLockingWriteAheadLog(Path, int, SerDe<T>, SyncListener) - Constructor for class org.wali.MinimalLockingWriteAheadLog

MinimalLockingWriteAheadLog(Path, int, SerDeFactory<T>, SyncListener) - Constructor for class org.wali.MinimalLockingWriteAheadLog

MinimalLockingWriteAheadLog(SortedSet<Path>, int, SerDe<T>, SyncListener) - Constructor for class org.wali.MinimalLockingWriteAheadLog

MinimalLockingWriteAheadLog(SortedSet<Path>, int, SerDeFactory<T>, SyncListener) - Constructor for class org.wali.MinimalLockingWriteAheadLog

MINIMUM - Static variable in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric

MINIMUM_PENALIZATION_MILLIS - Static variable in class org.apache.nifi.controller.AbstractPort

MINIMUM_PENALIZATION_MILLIS - Static variable in class org.apache.nifi.controller.StandardFunnel

MINIMUM_SCHEDULING_NANOS - Static variable in interface org.apache.nifi.controller.Triggerable

MINIMUM_SWAP_COUNT - Static variable in class org.apache.nifi.controller.FileSystemSwapManager

MINIMUM_YIELD_MILLIS - Static variable in class org.apache.nifi.controller.AbstractPort

MINIMUM_YIELD_MILLIS - Static variable in class org.apache.nifi.controller.StandardFunnel

MinimumLengthInputStream - Class in org.apache.nifi.stream.io

An InputStream that will throw EOFException if the underlying InputStream runs out of data before reaching the configured minimum amount of data

MinimumLengthInputStream(InputStream, long) - Constructor for class org.apache.nifi.stream.io.MinimumLengthInputStream

MinusEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

MinusEvaluator(Evaluator<Number>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.MinusEvaluator

MissedResult - Class in org.apache.nifi.hl7.query.result

MissedResult(List<Selection>) - Constructor for class org.apache.nifi.hl7.query.result.MissedResult

MISSING_EVENT_MESSAGE - Static variable in class org.apache.nifi.processors.windows.event.log.jna.EventSubscribeXmlRenderingCallback

MissingBundleException - Exception in org.apache.nifi.controller

Represents the exceptional case when a node fails to join the cluster because a bundle being used by the cluster does not exist on the node.

MissingBundleException(String, Throwable, boolean, boolean) - Constructor for exception org.apache.nifi.controller.MissingBundleException

MissingBundleException(Throwable) - Constructor for exception org.apache.nifi.controller.MissingBundleException

MissingBundleException(String, Throwable) - Constructor for exception org.apache.nifi.controller.MissingBundleException

MissingBundleException(String) - Constructor for exception org.apache.nifi.controller.MissingBundleException

MissingBundleException() - Constructor for exception org.apache.nifi.controller.MissingBundleException

MissingFlowFileException - Exception in org.apache.nifi.processor.exception

Thrown to indicate that the content for some FlowFile could not be found.

MissingFlowFileException(String, Throwable) - Constructor for exception org.apache.nifi.processor.exception.MissingFlowFileException

mixedCRLF() - Method in class org.apache.nifi.stream.io.util.TextLineDemarcatorTest

MockAbstractAMQPProcessor() - Constructor for class org.apache.nifi.amqp.processors.AbstractAMQPProcessorTest.MockAbstractAMQPProcessor

MockAbstractCassandraProcessor() - Constructor for class org.apache.nifi.processors.cassandra.AbstractCassandraProcessorTest.MockAbstractCassandraProcessor

MockAbstractMongoProcessor() - Constructor for class org.apache.nifi.processors.mongodb.AbstractMongoProcessorTest.MockAbstractMongoProcessor

MockAWSProcessor - Class in org.apache.nifi.processors.aws.credentials.provider.factory

Mock Processor implementation used to test CredentialsProviderFactory.

MockAWSProcessor() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.MockAWSProcessor

MockBulletin - Class in org.apache.nifi.reporting

MockBulletin(long) - Constructor for class org.apache.nifi.reporting.MockBulletin

MockBulletinRepository - Class in org.apache.nifi.util

MockBulletinRepository() - Constructor for class org.apache.nifi.util.MockBulletinRepository

MockComponentLog - Class in org.apache.nifi.util

MockComponentLog(String, Object) - Constructor for class org.apache.nifi.util.MockComponentLog

MockComponentLogger - Class in org.apache.nifi.mock

Stubs out the functionality of a ComponentLog so that it can be used during initialization of a component.

MockComponentLogger() - Constructor for class org.apache.nifi.mock.MockComponentLogger

MockConfigurationContext - Class in org.apache.nifi.mock

MockConfigurationContext() - Constructor for class org.apache.nifi.mock.MockConfigurationContext

MockConfigurationContext - Class in org.apache.nifi.util

MockConfigurationContext(Map<PropertyDescriptor, String>, ControllerServiceLookup) - Constructor for class org.apache.nifi.util.MockConfigurationContext

MockConfigurationContext(Map<PropertyDescriptor, String>, ControllerServiceLookup, VariableRegistry) - Constructor for class org.apache.nifi.util.MockConfigurationContext

MockConfigurationContext(ControllerService, Map<PropertyDescriptor, String>, ControllerServiceLookup, VariableRegistry) - Constructor for class org.apache.nifi.util.MockConfigurationContext

MockControllerServiceInitializationContext - Class in org.apache.nifi.mock

A Mock ControllerServiceInitializationContext so that ControllerServices can be initialized for the purpose of generating documentation.

MockControllerServiceInitializationContext() - Constructor for class org.apache.nifi.mock.MockControllerServiceInitializationContext

MockControllerServiceInitializationContext - Class in org.apache.nifi.util

MockControllerServiceInitializationContext(ControllerService, String) - Constructor for class org.apache.nifi.util.MockControllerServiceInitializationContext

MockControllerServiceInitializationContext(ControllerService, String, StateManager) - Constructor for class org.apache.nifi.util.MockControllerServiceInitializationContext

MockControllerServiceInitializationContext(ControllerService, String, ComponentLog, StateManager) - Constructor for class org.apache.nifi.util.MockControllerServiceInitializationContext

MockControllerServiceLookup - Class in org.apache.nifi.mock

A Mock ControllerServiceLookup that can be used so that ConfigurableComponents can be initialized for the purpose of generating documentation

MockControllerServiceLookup() - Constructor for class org.apache.nifi.mock.MockControllerServiceLookup

MockControllerServiceLookup - Class in org.apache.nifi.util

MockControllerServiceLookup() - Constructor for class org.apache.nifi.util.MockControllerServiceLookup

MockCredentialsFactoryProcessor - Class in org.apache.nifi.processors.gcp.credentials.factory

MockCredentialsFactoryProcessor() - Constructor for class org.apache.nifi.processors.gcp.credentials.factory.MockCredentialsFactoryProcessor

MockCredentialsServiceProcessor - Class in org.apache.nifi.processors.gcp.credentials.service

MockCredentialsServiceProcessor() - Constructor for class org.apache.nifi.processors.gcp.credentials.service.MockCredentialsServiceProcessor

MockEventAccess - Class in org.apache.nifi.util

MockEventAccess() - Constructor for class org.apache.nifi.util.MockEventAccess

mockEventHandles(WEvtApi, Kernel32, List<String>) - Static method in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLogTest

MockFlowFile - Class in org.apache.nifi.controller.swap

MockFlowFile(Map<String, String>, long, ResourceClaimManager) - Constructor for class org.apache.nifi.controller.swap.MockFlowFile

MockFlowFile(Map<String, String>, long, ContentClaim) - Constructor for class org.apache.nifi.controller.swap.MockFlowFile

MockFlowFile(long, Map<String, String>, long, ContentClaim) - Constructor for class org.apache.nifi.controller.swap.MockFlowFile

MockFlowFile - Class in org.apache.nifi.util

MockFlowFile(long) - Constructor for class org.apache.nifi.util.MockFlowFile

MockFlowFile(long, FlowFile) - Constructor for class org.apache.nifi.util.MockFlowFile

MockFlowFileQueue - Class in org.apache.nifi.util

MockFlowFileQueue() - Constructor for class org.apache.nifi.util.MockFlowFileQueue

MockHBaseClientService - Class in org.apache.nifi.hbase

Override methods to create a mock service that can return staged data

MockHBaseClientService(Table, String, KerberosProperties) - Constructor for class org.apache.nifi.hbase.MockHBaseClientService

MockNodeTypeProvider - Class in org.apache.nifi.mock

A Mock NodeTypeProvider that can be used so that ConfigurableComponents can be initialized for the purpose of generating documentation

MockNodeTypeProvider() - Constructor for class org.apache.nifi.mock.MockNodeTypeProvider

MockPolicyBasedAuthorizer - Class in org.apache.nifi.authorization

Mock implementation of AbstractPolicyBasedAuthorizer.

MockPolicyBasedAuthorizer() - Constructor for class org.apache.nifi.authorization.MockPolicyBasedAuthorizer

MockPolicyBasedAuthorizer(Set<Group>, Set<User>, Set<AccessPolicy>) - Constructor for class org.apache.nifi.authorization.MockPolicyBasedAuthorizer

MockProcessContext - Class in org.apache.nifi.mock

MockProcessContext() - Constructor for class org.apache.nifi.mock.MockProcessContext

MockProcessContext - Class in org.apache.nifi.util

MockProcessContext(ConfigurableComponent) - Constructor for class org.apache.nifi.util.MockProcessContext

MockProcessContext(ConfigurableComponent, StateManager, VariableRegistry) - Constructor for class org.apache.nifi.util.MockProcessContext

Creates a new MockProcessContext for the given Processor

MockProcessContext(ControllerService, MockProcessContext, StateManager, VariableRegistry) - Constructor for class org.apache.nifi.util.MockProcessContext

MockProcessGroup - Class in org.apache.nifi.controller.service.mock

MockProcessGroup(FlowController) - Constructor for class org.apache.nifi.controller.service.mock.MockProcessGroup

MockProcessorInitializationContext - Class in org.apache.nifi.mock

A Mock ProcessorInitializationContext that can be used so that Processors can be initialized for the purpose of generating documentation.

MockProcessorInitializationContext() - Constructor for class org.apache.nifi.mock.MockProcessorInitializationContext

MockProcessorInitializationContext - Class in org.apache.nifi.util

MockProcessorInitializationContext(Processor, MockProcessContext) - Constructor for class org.apache.nifi.util.MockProcessorInitializationContext

MockProcessSession - Class in org.apache.nifi.util

MockProcessSession(SharedSessionState, Processor) - Constructor for class org.apache.nifi.util.MockProcessSession

MockProcessSession(SharedSessionState, Processor, boolean) - Constructor for class org.apache.nifi.util.MockProcessSession

MockPropertyValue - Class in org.apache.nifi.util

MockPropertyValue(String) - Constructor for class org.apache.nifi.util.MockPropertyValue

MockPropertyValue(String, ControllerServiceLookup) - Constructor for class org.apache.nifi.util.MockPropertyValue

MockPropertyValue(String, ControllerServiceLookup, VariableRegistry) - Constructor for class org.apache.nifi.util.MockPropertyValue

MockPropertyValue(String, ControllerServiceLookup, VariableRegistry, PropertyDescriptor) - Constructor for class org.apache.nifi.util.MockPropertyValue

MockProvenanceReporter - Class in org.apache.nifi.util

MockProvenanceReporter(MockProcessSession, SharedSessionState, String, String) - Constructor for class org.apache.nifi.util.MockProvenanceReporter

MockProvenanceRepository - Class in org.apache.nifi.provenance

MockProvenanceRepository() - Constructor for class org.apache.nifi.provenance.MockProvenanceRepository

MockPutCloudWatchMetric - Class in org.apache.nifi.processors.aws.cloudwatch

Simple mock PutCloudWatchMetric processor for testing.

MockPutCloudWatchMetric() - Constructor for class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric

MockPutKudu - Class in org.apache.nifi.processors.kudu

MockPutKudu() - Constructor for class org.apache.nifi.processors.kudu.MockPutKudu

MockRecordParser - Class in org.apache.nifi.processors.kafka.pubsub.util

MockRecordParser() - Constructor for class org.apache.nifi.processors.kafka.pubsub.util.MockRecordParser

MockRecordParser(int) - Constructor for class org.apache.nifi.processors.kafka.pubsub.util.MockRecordParser

MockRecordParser - Class in org.apache.nifi.serialization.record

MockRecordParser() - Constructor for class org.apache.nifi.serialization.record.MockRecordParser

MockRecordParser(int) - Constructor for class org.apache.nifi.serialization.record.MockRecordParser

MockRecordWriter - Class in org.apache.nifi.processors.kafka.pubsub.util

MockRecordWriter(String) - Constructor for class org.apache.nifi.processors.kafka.pubsub.util.MockRecordWriter

MockRecordWriter(String, boolean) - Constructor for class org.apache.nifi.processors.kafka.pubsub.util.MockRecordWriter

MockRecordWriter(String, boolean, int) - Constructor for class org.apache.nifi.processors.kafka.pubsub.util.MockRecordWriter

MockRecordWriter - Class in org.apache.nifi.serialization.record

MockRecordWriter() - Constructor for class org.apache.nifi.serialization.record.MockRecordWriter

MockRecordWriter(String) - Constructor for class org.apache.nifi.serialization.record.MockRecordWriter

MockRecordWriter(String, boolean) - Constructor for class org.apache.nifi.serialization.record.MockRecordWriter

MockRecordWriter(String, boolean, int) - Constructor for class org.apache.nifi.serialization.record.MockRecordWriter

MockReportingContext - Class in org.apache.nifi.util

MockReportingContext(Map<String, ControllerService>, StateManager, VariableRegistry) - Constructor for class org.apache.nifi.util.MockReportingContext

MockReportingInitializationContext - Class in org.apache.nifi.mock

A Mock ReportingInitializationContext that can be used to initialize a ReportingTask for the purposes of documentation generation.

MockReportingInitializationContext() - Constructor for class org.apache.nifi.mock.MockReportingInitializationContext

MockReportingInitializationContext - Class in org.apache.nifi.util

MockReportingInitializationContext(String, String, ComponentLog) - Constructor for class org.apache.nifi.util.MockReportingInitializationContext

MockRequestContext() - Constructor for class org.apache.nifi.web.standard.api.processor.TestProcessorResource.MockRequestContext

MockRequestContext() - Constructor for class org.apache.nifi.web.standard.api.transformjson.TestTransformJSONResource.MockRequestContext

MockSchemaRegistry - Class in org.apache.nifi.serialization.record

MockSchemaRegistry() - Constructor for class org.apache.nifi.serialization.record.MockSchemaRegistry

MockServletContext() - Constructor for class org.apache.nifi.web.standard.api.processor.TestProcessorResource.MockServletContext

MockServletContext() - Constructor for class org.apache.nifi.web.standard.api.transformjson.TestTransformJSONResource.MockServletContext

MockSessionFactory - Class in org.apache.nifi.util

MockStateManager - Class in org.apache.nifi.state

MockStateManager(Object) - Constructor for class org.apache.nifi.state.MockStateManager

MockStateMap - Class in org.apache.nifi.state

MockStateMap(Map<String, String>, long) - Constructor for class org.apache.nifi.state.MockStateMap

mockTickTuple() - Static method in class org.apache.nifi.storm.MockTupleHelpers

mockTuple(String, String) - Static method in class org.apache.nifi.storm.MockTupleHelpers

MockTupleHelpers - Class in org.apache.nifi.storm

MockValidationContext - Class in org.apache.nifi.util

MockValidationContext(MockProcessContext) - Constructor for class org.apache.nifi.util.MockValidationContext

MockValidationContext(MockProcessContext, StateManager, VariableRegistry) - Constructor for class org.apache.nifi.util.MockValidationContext

MockVariableRegistry - Class in org.apache.nifi.util

MockVariableRegistry() - Constructor for class org.apache.nifi.util.MockVariableRegistry

mockWebServer - Static variable in class org.apache.nifi.bootstrap.http.TestHttpNotificationServiceCommon

MODE - Static variable in class org.apache.nifi.processors.standard.Base64EncodeContent

MODE - Static variable in class org.apache.nifi.processors.standard.CompressContent

MODE - Static variable in class org.apache.nifi.processors.standard.EncodeContent

MODE - Static variable in class org.apache.nifi.processors.standard.EncryptContent

MODE_COMPRESS - Static variable in class org.apache.nifi.processors.standard.CompressContent

MODE_DECOMPRESS - Static variable in class org.apache.nifi.processors.standard.CompressContent

ModEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

ModEvaluator(Evaluator<Number>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ModEvaluator

MODIFIED_VALUE - Static variable in class org.apache.nifi.ModifyHTMLElement

MODIFIER_DEFAULTR - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON

MODIFIER_DEFINER - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON

MODIFIER_OVERWRITER - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON

ModifiesClasspathNoAnnotationProcessor - Class in org.apache.nifi.test.processors

A processor with a property descriptor that attempts to modify the classpath, but the processor does not have @RequiresInstanceClassLoading.

ModifiesClasspathNoAnnotationProcessor() - Constructor for class org.apache.nifi.test.processors.ModifiesClasspathNoAnnotationProcessor

ModifiesClasspathProcessor - Class in org.apache.nifi.test.processors

ModifiesClasspathProcessor() - Constructor for class org.apache.nifi.test.processors.ModifiesClasspathProcessor

ModifiesClasspathProcessor(List<PropertyDescriptor>) - Constructor for class org.apache.nifi.test.processors.ModifiesClasspathProcessor

modifyAttributes(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyAttributes(FlowFile, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyAttributes(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type ATTRIBUTES_MODIFIED that indicates that the Attributes of the given FlowFile were updated.

modifyAttributes(FlowFile, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type ATTRIBUTES_MODIFIED that indicates that the Attributes of the given FlowFile were updated.

modifyAttributes(FlowFile) - Method in class org.apache.nifi.util.MockProvenanceReporter

modifyAttributes(FlowFile, String) - Method in class org.apache.nifi.util.MockProvenanceReporter

ModifyBytes - Class in org.apache.nifi.processors.standard

ModifyBytes() - Constructor for class org.apache.nifi.processors.standard.ModifyBytes

modifyContent(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyContent(FlowFile, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyContent(FlowFile, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyContent(FlowFile, String, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter

modifyContent(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type CONTENT_MODIFIED that indicates that the content of the given FlowFile has been modified.

modifyContent(FlowFile, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type CONTENT_MODIFIED that indicates that the content of the given FlowFile has been modified.

modifyContent(FlowFile, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type CONTENT_MODIFIED that indicates that the content of the given FlowFile has been modified.

modifyContent(FlowFile, String, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter

Emits a Provenance Event of type CONTENT_MODIFIED that indicates that the content of the given FlowFile has been modified.

modifyContent(FlowFile) - Method in class org.apache.nifi.util.MockProvenanceReporter

modifyContent(FlowFile, String) - Method in class org.apache.nifi.util.MockProvenanceReporter

modifyContent(FlowFile, long) - Method in class org.apache.nifi.util.MockProvenanceReporter

modifyContent(FlowFile, String, long) - Method in class org.apache.nifi.util.MockProvenanceReporter

ModifyHTMLElement - Class in org.apache.nifi

ModifyHTMLElement() - Constructor for class org.apache.nifi.ModifyHTMLElement

MODULES - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON

MODULES - Static variable in class org.apache.nifi.script.ScriptingComponentUtils

A property descriptor for specifying the location of additional modules to be used by the script

mongoClient - Variable in class org.apache.nifi.mongodb.AbstractMongoDBControllerService

mongoClient - Variable in class org.apache.nifi.processors.mongodb.AbstractMongoProcessor

MongoDBClientService - Interface in org.apache.nifi.mongodb

MongoDBControllerService - Class in org.apache.nifi.mongodb

MongoDBControllerService() - Constructor for class org.apache.nifi.mongodb.MongoDBControllerService

MongoDBLookupService - Class in org.apache.nifi.mongodb

MongoDBLookupService() - Constructor for class org.apache.nifi.mongodb.MongoDBLookupService

MonitorActivity - Class in org.apache.nifi.processors.standard

MonitorActivity() - Constructor for class org.apache.nifi.processors.standard.MonitorActivity

MonitorDiskUsage - Class in org.apache.nifi.controller

MonitorDiskUsage() - Constructor for class org.apache.nifi.controller.MonitorDiskUsage

monitorHeartbeats() - Method in class org.apache.nifi.cluster.coordination.heartbeat.AbstractHeartbeatMonitor

Fetches all of the latest heartbeats and updates the Cluster Coordinator as appropriate, based on the heartbeats received.

MONITORING_SCOPE - Static variable in class org.apache.nifi.processors.standard.MonitorActivity

MonitorMemory - Class in org.apache.nifi.controller

Reporting task used to monitor usage of memory after Garbage Collection has been performed.

MonitorMemory() - Constructor for class org.apache.nifi.controller.MonitorMemory

MonitorMemoryTest - Class in org.apache.nifi.controller

MonitorMemoryTest() - Constructor for class org.apache.nifi.controller.MonitorMemoryTest

move(Snippet, ProcessGroup) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup

move(Snippet, ProcessGroup) - Method in interface org.apache.nifi.groups.ProcessGroup

Moves all of the components whose ID's are specified within the given Snippet from this ProcessGroup into the given destination ProcessGroup

move(Snippet, ProcessGroup) - Method in class org.apache.nifi.groups.StandardProcessGroup

move(File, File, boolean) - Method in class org.apache.nifi.processors.standard.FetchFile

moveAndScaleSnippet(FlowSnippetDTO, Double, Double, double, double) - Static method in class org.apache.nifi.util.SnippetUtils

Moves the content of the specified snippet around the specified location and scales the placement of individual components of the template by the given factorX and factorY.

MoveDetails - Interface in org.apache.nifi.action.details

Provides details about a move action.

MoveDetailsDTO - Class in org.apache.nifi.web.api.dto.action.details

Details of the move operation.

MoveDetailsDTO() - Constructor for class org.apache.nifi.web.api.dto.action.details.MoveDetailsDTO

moveNext() - Method in class org.apache.nifi.queryrecord.FlowFileEnumerator

moveSnippet(FlowSnippetDTO, Double, Double) - Static method in class org.apache.nifi.util.SnippetUtils

Moves the content of the specified snippet around the specified location.

MQTT_server - Variable in class org.apache.nifi.processors.mqtt.common.TestConsumeMqttCommon

MQTT_server - Variable in class org.apache.nifi.processors.mqtt.common.TestPublishMqttCommon

mqttCallback - Variable in class org.apache.nifi.processors.mqtt.common.MqttTestClient

mqttClient - Variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

mqttClientConnectLock - Variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

MqttConstants - Class in org.apache.nifi.processors.mqtt.common

MqttConstants() - Constructor for class org.apache.nifi.processors.mqtt.common.MqttConstants

MQTTQueueMessage - Class in org.apache.nifi.processors.mqtt.common

MQTTQueueMessage(String, MqttMessage) - Constructor for class org.apache.nifi.processors.mqtt.common.MQTTQueueMessage

MqttTestClient - Class in org.apache.nifi.processors.mqtt.common

MqttTestClient(String, String, MqttTestClient.ConnectType) - Constructor for class org.apache.nifi.processors.mqtt.common.MqttTestClient

mqttTestClient - Variable in class org.apache.nifi.processors.mqtt.TestConsumeMQTT

mqttTestClient - Variable in class org.apache.nifi.processors.mqtt.TestPublishMQTT

MqttTestClient.ConnectType - Enum in org.apache.nifi.processors.mqtt.common

MqttTestUtils - Class in org.apache.nifi.processors.mqtt.common

MqttTestUtils() - Constructor for class org.apache.nifi.processors.mqtt.common.MqttTestUtils

MSG_BODY - Static variable in class org.apache.nifi.processors.standard.PutSyslog

MSG_COUNT - Static variable in class org.apache.nifi.processors.kafka.pubsub.PublishKafka

MSG_COUNT - Static variable in class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10

MSG_COUNT - Static variable in class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11

MSG_COUNT - Static variable in class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10

MSG_COUNT - Static variable in class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_11

MSG_HOSTNAME - Static variable in class org.apache.nifi.processors.standard.PutSyslog

MSG_NON_CONFIGURABLE_POLICIES - Static variable in interface org.apache.nifi.web.dao.AccessPolicyDAO

MSG_NON_CONFIGURABLE_USERS - Static variable in interface org.apache.nifi.web.dao.AccessPolicyDAO

MSG_NON_MANAGED_AUTHORIZER - Static variable in interface org.apache.nifi.web.dao.AccessPolicyDAO

MSG_PRIORITY - Static variable in class org.apache.nifi.processors.standard.PutSyslog

MSG_TIMESTAMP - Static variable in class org.apache.nifi.processors.standard.PutSyslog

MSG_TYPE_BYTE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MSG_TYPE_EMPTY - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MSG_TYPE_MAP - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MSG_TYPE_STREAM - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MSG_TYPE_TEXT - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties

MSG_VERSION - Static variable in class org.apache.nifi.processors.standard.PutSyslog

msgBody(String) - Method in class org.apache.nifi.processors.standard.syslog.SyslogEvent.Builder

MSSQL2008DatabaseAdapter - Class in org.apache.nifi.processors.standard.db.impl

A database adapter that generates MS SQL Compatible SQL for version 2008.

MSSQL2008DatabaseAdapter() - Constructor for class org.apache.nifi.processors.standard.db.impl.MSSQL2008DatabaseAdapter

MSSQLDatabaseAdapter - Class in org.apache.nifi.processors.standard.db.impl

A database adapter that generates MS SQL Compatible SQL.

MSSQLDatabaseAdapter() - Constructor for class org.apache.nifi.processors.standard.db.impl.MSSQLDatabaseAdapter

MultiArrayIndexPath - Class in org.apache.nifi.record.path.paths

MultiAttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection

MultiAttributeEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.MultiAttributeEvaluator

MulticastConfiguration - Class in org.apache.nifi.io.socket.multicast

MulticastConfiguration() - Constructor for class org.apache.nifi.io.socket.multicast.MulticastConfiguration

MulticastListener - Class in org.apache.nifi.io.socket.multicast

Implements a listener for protocol messages sent over multicast.

MulticastListener(int, InetSocketAddress, MulticastConfiguration) - Constructor for class org.apache.nifi.io.socket.multicast.MulticastListener

MulticastProtocolMessage - Class in org.apache.nifi.cluster.protocol.message

Wraps a protocol message and an identifier for sending the message by way multicast.

MulticastProtocolMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.MulticastProtocolMessage

MulticastProtocolMessage(String, ProtocolMessage) - Constructor for class org.apache.nifi.cluster.protocol.message.MulticastProtocolMessage

MulticastServiceDiscovery - Interface in org.apache.nifi.io.socket.multicast

Defines the interface for discovering services based on name.

MulticastServicesBroadcaster - Interface in org.apache.nifi.io.socket.multicast

Defines the interface for broadcasting a service via multicast.

MulticastTimeToLive - Enum in org.apache.nifi.io.socket.multicast

MulticastUtils - Class in org.apache.nifi.io.socket.multicast

MulticastUtils() - Constructor for class org.apache.nifi.io.socket.multicast.MulticastUtils

MultiConnectionSocketSender(int, int, long, String) - Constructor for class org.apache.nifi.processors.standard.TestListenSyslog.MultiConnectionSocketSender

MULTILINE - Static variable in class org.apache.nifi.processors.standard.ExtractText

MultiMapKeyPath - Class in org.apache.nifi.record.path.paths

multiMatch - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash

MultiMatchAttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection

MultiMatchAttributeEvaluator(List<String>, int) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.MultiMatchAttributeEvaluator

MultiNamedAttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection

MultiNamedAttributeEvaluator(List<String>, int) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.MultiNamedAttributeEvaluator

MULTIPART_PART_SIZE - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MULTIPART_S3_AGEOFF_INTERVAL - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MULTIPART_S3_MAX_AGE - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MULTIPART_THRESHOLD - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object

MultipartState() - Constructor for class org.apache.nifi.processors.aws.s3.PutS3Object.MultipartState

MultipartState(String) - Constructor for class org.apache.nifi.processors.aws.s3.PutS3Object.MultipartState

MultipleSensitivePropertyProtectionException - Exception in org.apache.nifi.properties

MultipleSensitivePropertyProtectionException() - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new throwable with null as its detail message.

MultipleSensitivePropertyProtectionException(String) - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new throwable with the specified detail message.

MultipleSensitivePropertyProtectionException(String, Throwable) - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new throwable with the specified detail message and cause.

MultipleSensitivePropertyProtectionException(Throwable) - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new throwable with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).

MultipleSensitivePropertyProtectionException(String, Collection<String>) - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new exception with the provided message and a unique set of the keys that caused the error.

MultipleSensitivePropertyProtectionException(String, Collection<String>, Throwable) - Constructor for exception org.apache.nifi.properties.MultipleSensitivePropertyProtectionException

Constructs a new exception with the provided message and a unique set of the keys that caused the error.

MultipleURLValidator - Class in org.apache.nifi.confluent.schemaregistry

MultipleURLValidator() - Constructor for class org.apache.nifi.confluent.schemaregistry.MultipleURLValidator

MultiplyEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

MultiplyEvaluator(Evaluator<Number>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.MultiplyEvaluator

mustCallOnStoppedMethods() - Method in class org.apache.nifi.controller.scheduling.ScheduleState

Maintains an AtomicBoolean so that the first thread to call this method after a Processor is no longer scheduled to run will receive a true and MUST call the methods annotated with @OnStopped

MutableRequestException - Exception in org.apache.nifi.cluster.manager.exception

Represents the exceptional case when a HTTP request that may change a node's state is to be replicated while the cluster or connected nodes are unable to change their state (e.g., a new node is connecting to the cluster).

MutableRequestException() - Constructor for exception org.apache.nifi.cluster.manager.exception.MutableRequestException

MutableRequestException(String) - Constructor for exception org.apache.nifi.cluster.manager.exception.MutableRequestException

MutableRequestException(Throwable) - Constructor for exception org.apache.nifi.cluster.manager.exception.MutableRequestException

MutableRequestException(String, Throwable) - Constructor for exception org.apache.nifi.cluster.manager.exception.MutableRequestException

MutableRequestExceptionMapper - Class in org.apache.nifi.web.api.config

Maps mutual request exceptions into client responses.

MutableRequestExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.MutableRequestExceptionMapper

MutableVariableRegistry - Class in org.apache.nifi.registry.variable

MutableVariableRegistry(VariableRegistry) - Constructor for class org.apache.nifi.registry.variable.MutableVariableRegistry

MutativeMethodHandler(TestInvokeHttpCommon.MutativeMethod) - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.MutativeMethodHandler

MutativeMethodHandler(TestInvokeHttpCommon.MutativeMethod, String) - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.MutativeMethodHandler

MyProxyHandler() - Constructor for class org.apache.nifi.processors.standard.TestInvokeHTTP.MyProxyHandler

MySQLCDCUtils - Class in org.apache.nifi.cdc.mysql.event

A utility class to provide MySQL- / binlog-specific constants and methods for processing events and data

MySQLCDCUtils() - Constructor for class org.apache.nifi.cdc.mysql.event.MySQLCDCUtils

MySQLCDCUtilsTest - Class in org.apache.nifi.cdc.mysql.event

Unit Tests for MySQLCDCUtils utility class

MySQLCDCUtilsTest() - Constructor for class org.apache.nifi.cdc.mysql.event.MySQLCDCUtilsTest

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z