- Wait - Class in org.apache.nifi.processors.standard
-
- Wait() - Constructor for class org.apache.nifi.processors.standard.Wait
-
- WAIT_BUFFER_COUNT - Static variable in class org.apache.nifi.processors.standard.Wait
-
- WAIT_MODE - Static variable in class org.apache.nifi.processors.standard.Wait
-
- WAIT_MODE_KEEP_IN_UPSTREAM - Static variable in class org.apache.nifi.processors.standard.Wait
-
- WAIT_MODE_TRANSFER_TO_WAIT - Static variable in class org.apache.nifi.processors.standard.Wait
-
- WAIT_START_TIMESTAMP - Static variable in class org.apache.nifi.processors.standard.Wait
-
- WAIT_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
-
- waitForClusterCoordinator(long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Cluster
-
- waitForPrimaryNode(long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Cluster
-
- waitForRollover() - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
-
Blocks the calling thread until the repository rolls over.
- WaitNotifyProtocol - Class in org.apache.nifi.processors.standard
-
This class provide a protocol for Wait and Notify processors to work together.
- WaitNotifyProtocol(AtomicDistributedMapCacheClient) - Constructor for class org.apache.nifi.processors.standard.WaitNotifyProtocol
-
- WaitNotifyProtocol.Signal - Class in org.apache.nifi.processors.standard
-
- waitUntilAllNodesConnected(long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Cluster
-
Waits for each node in the cluster to connect.
- waitUntilConditionMet(long, TimeUnit, BooleanSupplier) - Static method in class org.apache.nifi.cluster.integration.ClusterUtils
-
- waitUntilConditionMet(long, TimeUnit, BooleanSupplier, Supplier<String>) - Static method in class org.apache.nifi.cluster.integration.ClusterUtils
-
- waitUntilConnected(long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Node
-
- waitUntilElectedForRole(String, long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Node
-
- waitUntilNonNull(long, TimeUnit, Supplier<T>) - Static method in class org.apache.nifi.cluster.integration.ClusterUtils
-
- wakeup() - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumerLease
-
Trigger the consumer's wakeup() method.
- WARM_CACHE_FREQUENCY - Static variable in class org.apache.nifi.provenance.RepositoryConfiguration
-
- warn(String, Throwable) - Method in interface org.apache.nifi.logging.ComponentLog
-
- warn(String, Object[]) - Method in interface org.apache.nifi.logging.ComponentLog
-
- warn(String, Object[], Throwable) - Method in interface org.apache.nifi.logging.ComponentLog
-
- warn(String) - Method in interface org.apache.nifi.logging.ComponentLog
-
- warn(Marker, String, Throwable) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(Marker, String, Object[]) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(Marker, String, Object, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(Marker, String, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(Marker, String) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String, Throwable) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String, Object, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String, Object[]) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String, Object) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String) - Method in class org.apache.nifi.logging.NiFiLog
-
- warn(String, Throwable) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- warn(String, Object[]) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- warn(String, Object[], Throwable) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- warn(String) - Method in class org.apache.nifi.mock.MockComponentLogger
-
- warn(String, Throwable) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- warn(String, Object[]) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- warn(String, Object[], Throwable) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- warn(String) - Method in class org.apache.nifi.processor.SimpleProcessLogger
-
- warn(Logger, EventReporter, String, Object...) - Static method in class org.apache.nifi.remote.util.EventReportUtil
-
- warn(Logger, EventReporter, String, Throwable) - Static method in class org.apache.nifi.remote.util.EventReportUtil
-
- warn(String) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(String, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(String, Object, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(String, Object...) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(String, Throwable) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(Marker, String) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(Marker, String, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(Marker, String, Object, Object) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(Marker, String, Object...) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(Marker, String, Throwable) - Method in class org.apache.nifi.util.CapturingLogger
-
- warn(String, Throwable) - Method in class org.apache.nifi.util.MockComponentLog
-
- warn(String, Object[]) - Method in class org.apache.nifi.util.MockComponentLog
-
- warn(String, Object[], Throwable) - Method in class org.apache.nifi.util.MockComponentLog
-
- warn(String) - Method in class org.apache.nifi.util.MockComponentLog
-
- WARN_VALUE - Static variable in class org.apache.nifi.hbase.PutHBaseJSON
-
- WARN_VALUE - Static variable in class org.apache.nifi.hbase.PutHBaseRecord
-
- WEB_HTTP_HOST - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTP_NETWORK_INTERFACE_PREFIX - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTP_PORT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTP_PORT_FORWARDING - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTPS_HOST - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTPS_NETWORK_INTERFACE_PREFIX - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTPS_PORT - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_HTTPS_PORT_FORWARDING - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_THREADS - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_WAR_DIR - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WEB_WORKING_DIR - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WebApplicationExceptionMapper - Class in org.apache.nifi.web.api.config
-
Maps web application exceptions into client responses.
- WebApplicationExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.WebApplicationExceptionMapper
-
- WEBHOOK_TEST_TEXT - Static variable in class org.apache.nifi.processors.slack.PutSlackTest
-
- WEBHOOK_TEXT - Static variable in class org.apache.nifi.processors.slack.PutSlack
-
- WEBHOOK_URL - Static variable in class org.apache.nifi.processors.slack.PutSlack
-
- WebSocketClientExample - Class in org.apache.nifi.websocket.example
-
This is a WebSocket client example testcase.
- WebSocketClientExample() - Constructor for class org.apache.nifi.websocket.example.WebSocketClientExample
-
- WebSocketClientService - Interface in org.apache.nifi.websocket
-
Control a WebSocket client instance.
- WebSocketConfigurationException - Exception in org.apache.nifi.websocket
-
- WebSocketConfigurationException(String) - Constructor for exception org.apache.nifi.websocket.WebSocketConfigurationException
-
- WebSocketConnectedMessage - Class in org.apache.nifi.websocket
-
- WebSocketConnectedMessage(WebSocketSessionInfo) - Constructor for class org.apache.nifi.websocket.WebSocketConnectedMessage
-
- WebSocketMessage - Class in org.apache.nifi.websocket
-
- WebSocketMessage(WebSocketSessionInfo) - Constructor for class org.apache.nifi.websocket.WebSocketMessage
-
- WebSocketMessage.Type - Enum in org.apache.nifi.websocket
-
- WebSocketMessageRouter - Class in org.apache.nifi.websocket
-
- WebSocketMessageRouter(String) - Constructor for class org.apache.nifi.websocket.WebSocketMessageRouter
-
- WebSocketMessageRouters - Class in org.apache.nifi.websocket
-
- WebSocketMessageRouters() - Constructor for class org.apache.nifi.websocket.WebSocketMessageRouters
-
- WebSocketProcessorAttributes - Class in org.apache.nifi.processors.websocket
-
- WebSocketServerExample - Class in org.apache.nifi.websocket.example
-
This is a WebSocket server example testcase.
- WebSocketServerExample() - Constructor for class org.apache.nifi.websocket.example.WebSocketServerExample
-
- WebSocketServerExample.ConnectionCheckServlet - Class in org.apache.nifi.websocket.example
-
- WebSocketServerExample.SocketListener - Class in org.apache.nifi.websocket.example
-
- WebSocketServerExample.WSServlet - Class in org.apache.nifi.websocket.example
-
- WebSocketServerService - Interface in org.apache.nifi.websocket
-
Control an embedded WebSocket server instance.
- webSocketService - Variable in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
-
- WebSocketService - Interface in org.apache.nifi.websocket
-
Control an embedded WebSocket service instance.
- WebSocketSession - Interface in org.apache.nifi.websocket
-
This is the concrete WebSocket session interface, which provides session information and operations.
- WebSocketSessionInfo - Interface in org.apache.nifi.websocket
-
This interface only expose session information.
- WebUtils - Class in org.apache.nifi.web.util
-
Common utilities related to web development.
- WEvtApi - Interface in org.apache.nifi.processors.windows.event.log.jna
-
JNA will create the instance of this interface with Native.loadLibrary().
- WEvtApi.EVT_SUBSCRIBE_CALLBACK - Interface in org.apache.nifi.processors.windows.event.log.jna
-
- WEvtApi.EvtRenderFlags - Interface in org.apache.nifi.processors.windows.event.log.jna
-
- WEvtApi.EvtSubscribeErrors - Interface in org.apache.nifi.processors.windows.event.log.jna
-
- WEvtApi.EvtSubscribeFlags - Interface in org.apache.nifi.processors.windows.event.log.jna
-
- WEvtApi.EvtSubscribeNotifyAction - Interface in org.apache.nifi.processors.windows.event.log.jna
-
- whenInetAddressThrowsUnknownHostFlowFileShouldBeSentToNotFound() - Method in class org.apache.nifi.processors.TestGeoEnrichIP
-
- whenInetAddressThrowsUnknownHostFlowFileShouldBeSentToNotFound() - Method in class org.apache.nifi.processors.TestISPEnrichIP
-
- WHERE_CLAUSE - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
-
- WHOIS_QUERY_TYPE - Static variable in class org.apache.nifi.processors.enrich.QueryWhois
-
- WHOIS_SERVER - Static variable in class org.apache.nifi.processors.enrich.QueryWhois
-
- WHOIS_SERVER_PORT - Static variable in class org.apache.nifi.processors.enrich.QueryWhois
-
- WHOIS_TIMEOUT - Static variable in class org.apache.nifi.processors.enrich.QueryWhois
-
- WholeNumberCastEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.cast
-
- WholeNumberCastEvaluator(Evaluator<?>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.cast.WholeNumberCastEvaluator
-
- WholeNumberEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- WholeNumberEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.WholeNumberEvaluator
-
- WholeNumberLiteralEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.literals
-
- WholeNumberLiteralEvaluator(String) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.literals.WholeNumberLiteralEvaluator
-
- WholeNumberQueryResult - Class in org.apache.nifi.attribute.expression.language.evaluation
-
- WholeNumberQueryResult(Long) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.WholeNumberQueryResult
-
- WildcardChildPath - Class in org.apache.nifi.record.path.paths
-
- WildcardDescendantPath - Class in org.apache.nifi.record.path.paths
-
- WildcardIndexPath - Class in org.apache.nifi.record.path.paths
-
- WithAttachments(int) - Method in class org.apache.nifi.processors.email.GenerateAttachment
-
- withAutoCreatePartitions(Boolean) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withBatchInterval(int) - Method in class org.apache.nifi.storm.NiFiBolt
-
- withBatchSize(int) - Method in class org.apache.nifi.storm.NiFiBolt
-
- withBatchSize(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withCallTimeout(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withComponentNarLoader(Class, String) - Static method in class org.apache.nifi.nar.NarCloseable
-
Sets the current thread context class loader to the specific appropriate class loader for the given
component.
- withComponentNarLoader(ClassLoader) - Static method in class org.apache.nifi.nar.NarCloseable
-
Sets the current thread context class loader to the provided class loader, and returns a NarCloseable that will
return the current thread context class loader to it's previous state.
- WithDefaultConstructor() - Constructor for class org.apache.nifi.nar.NarThreadContextClassLoaderTest.WithDefaultConstructor
-
- withFrameworkNar() - Static method in class org.apache.nifi.nar.NarCloseable
-
Creates a Closeable object that can be used to to switch to current class
loader to the framework class loader and will automatically set the
ClassLoader back to the previous class loader when closed
- withHeartBeatInterval(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withIdleTimeout(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withKerberosKeytab(String) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withKerberosPrincipal(String) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withKey(String) - Static method in class org.apache.nifi.properties.NiFiPropertiesLoader
-
Returns an instance of the loader configured with the key.
- withMaxOpenConnections(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withNarLoader(AccessPolicyProvider, ClassLoader) - Static method in class org.apache.nifi.authorization.AccessPolicyProviderFactory
-
- withNarLoader(Authorizer, ClassLoader) - Static method in class org.apache.nifi.authorization.AuthorizerFactory
-
Decorates the base authorizer to ensure the nar context classloader is used when invoking the underlying methods.
- withNarLoader(UserGroupProvider, ClassLoader) - Static method in class org.apache.nifi.authorization.UserGroupProviderFactory
-
- withNarLoader() - Static method in class org.apache.nifi.nar.NarCloseable
-
- WithPropertiesConstructor() - Constructor for class org.apache.nifi.nar.NarThreadContextClassLoaderTest.WithPropertiesConstructor
-
- WithPropertiesConstructor(NiFiProperties) - Constructor for class org.apache.nifi.nar.NarThreadContextClassLoaderTest.WithPropertiesConstructor
-
- withRevision(Revision) - Method in interface org.apache.nifi.web.revision.ReadOnlyRevisionCallback
-
Performs some action while a Read Lock is held for the given
Revision.
- withTickTupleInterval(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withTxnsPerBatch(Integer) - Method in class org.apache.nifi.util.hive.HiveOptions
-
- withWriteLock(NiFiServiceFacade, T, Revision, AuthorizeAccess, Runnable, BiFunction<Revision, T, Response>) - Method in class org.apache.nifi.web.api.ApplicationResource
-
Executes an action through the service facade using the specified revision.
- withWriteLock(NiFiServiceFacade, T, Set<Revision>, AuthorizeAccess, Runnable, BiFunction<Set<Revision>, T, Response>) - Method in class org.apache.nifi.web.api.ApplicationResource
-
Executes an action through the service facade using the specified revision.
- withWriteLock(NiFiServiceFacade, T, AuthorizeAccess, Runnable, Function<T, Response>) - Method in class org.apache.nifi.web.api.ApplicationResource
-
Executes an action through the service facade.
- Worker(Connectable) - Constructor for class org.apache.nifi.controller.EventDrivenWorkerQueue.Worker
-
- WorkerQueue - Interface in org.apache.nifi.controller
-
- WORKING_DIR - Static variable in class org.apache.nifi.processors.standard.ExecuteProcess
-
- workingDir(File) - Method in class org.apache.nifi.bundle.BundleDetails.Builder
-
- WrappedMessageConsumer - Class in org.apache.nifi.processors.standard.util
-
- WrappedMessageConsumer(Connection, Session, MessageConsumer) - Constructor for class org.apache.nifi.processors.standard.util.WrappedMessageConsumer
-
- WrappedMessageProducer - Class in org.apache.nifi.processors.standard.util
-
- WrappedMessageProducer(Connection, Session, MessageProducer) - Constructor for class org.apache.nifi.processors.standard.util.WrappedMessageProducer
-
- WritablePermission - Interface in org.apache.nifi.web.api.dto
-
- write(ContentClaim) - Method in class org.apache.nifi.controller.repository.claim.ContentClaimWriteCache
-
- write(ContentClaim) - Method in interface org.apache.nifi.controller.repository.ContentRepository
-
Obtains an OutputStream to the content for the given claim.
- write(ContentClaim) - Method in class org.apache.nifi.controller.repository.FileSystemRepository
-
- write(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
-
- write(int) - Method in class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
-
- write(int) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessOutputStream
-
- write(int) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessOutputStream
-
- write(int) - Method in class org.apache.nifi.controller.repository.io.SyncOnCloseOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.controller.repository.io.SyncOnCloseOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.SyncOnCloseOutputStream
-
- write(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
-
- write(FlowFile, OutputStreamCallback) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
-
- write(FlowFile, StreamCallback) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
-
- write(ContentClaim) - Method in class org.apache.nifi.controller.repository.VolatileContentRepository
-
- write(ConfigurableComponent, OutputStream, boolean) - Method in interface org.apache.nifi.documentation.DocumentationWriter
-
- write(ConfigurableComponent, OutputStream, boolean) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
- write(FlowFile, OutputStreamCallback) - Method in interface org.apache.nifi.processor.ProcessSession
-
Executes the given callback against the content corresponding to the
given FlowFile.
- write(FlowFile) - Method in interface org.apache.nifi.processor.ProcessSession
-
Provides an OutputStream that can be used to write to the contents of the
given FlowFile.
- write(FlowFile, StreamCallback) - Method in interface org.apache.nifi.processor.ProcessSession
-
Executes the given callback against the content corresponding to the
given flow file.
- write(byte[]) - Method in class org.apache.nifi.processor.util.put.sender.ChannelSender
-
Write the given buffer to the underlying channel.
- write(byte[]) - Method in class org.apache.nifi.processor.util.put.sender.DatagramChannelSender
-
- write(byte[]) - Method in class org.apache.nifi.processor.util.put.sender.SocketChannelSender
-
- write(byte[]) - Method in class org.apache.nifi.processor.util.put.sender.SSLSocketChannelSender
-
- write(Record) - Method in interface org.apache.nifi.processors.hadoop.record.HDFSRecordWriter
-
- write(RecordSet) - Method in interface org.apache.nifi.processors.hadoop.record.HDFSRecordWriter
-
- write(byte[], int, int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
-
- write(int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
-
- write(DataOutput) - Method in class org.apache.nifi.processors.hadoop.util.InputStreamWritable
-
- write(DataOutput) - Method in class org.apache.nifi.processors.hadoop.util.OutputStreamWritable
-
- write(Record) - Method in class org.apache.nifi.processors.parquet.record.AvroParquetHDFSRecordWriter
-
- write(int) - Method in class org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream
-
- write(int) - Method in class org.apache.nifi.remote.io.CompressionOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.remote.io.CompressionOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.remote.io.CompressionOutputStream
-
- write(int) - Method in class org.apache.nifi.remote.io.InterruptableOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.remote.io.InterruptableOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.remote.io.InterruptableOutputStream
-
- write(int) - Method in class org.apache.nifi.remote.io.socket.SocketChannelOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.remote.io.socket.SocketChannelOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.SocketChannelOutputStream
-
- write(int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
-
- write(byte[]) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
-
- write(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
-
- write(int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelOutputStream
-
- write(RecordSet) - Method in class org.apache.nifi.serialization.AbstractRecordSetWriter
-
- write(Record) - Method in class org.apache.nifi.serialization.AbstractRecordSetWriter
-
- write(RecordSet) - Method in interface org.apache.nifi.serialization.RecordSetWriter
-
Writes the given result set to the given output stream
- write(Record) - Method in interface org.apache.nifi.serialization.RecordWriter
-
Writes the given record to the underlying stream
- write(int) - Method in class org.apache.nifi.stream.io.ByteCountingOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.stream.io.ByteCountingOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.stream.io.ByteCountingOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.stream.io.NonCloseableOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.stream.io.NonCloseableOutputStream
-
- write(int) - Method in class org.apache.nifi.stream.io.NonCloseableOutputStream
-
- write(int) - Method in class org.apache.nifi.stream.io.NullOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.stream.io.NullOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.stream.io.NullOutputStream
-
- write(byte[]) - Method in class org.apache.nifi.stream.io.SynchronizedByteCountingOutputStream
-
- write(int) - Method in class org.apache.nifi.stream.io.SynchronizedByteCountingOutputStream
-
- write(byte[], int, int) - Method in class org.apache.nifi.stream.io.SynchronizedByteCountingOutputStream
-
- write(OutputStreamFactory) - Method in class org.apache.nifi.toolkit.tls.manager.BaseTlsManager
-
Writes the KeyStore and configuration information
- write(OutputStreamFactory) - Method in class org.apache.nifi.toolkit.tls.manager.TlsClientManager
-
- write(T, OutputStreamFactory) - Method in interface org.apache.nifi.toolkit.tls.manager.writer.ConfigurationWriter
-
Writes configuration information about the given object
- write(T, OutputStreamFactory) - Method in class org.apache.nifi.toolkit.tls.manager.writer.JsonConfigurationWriter
-
- write(TlsClientConfig, OutputStreamFactory) - Method in class org.apache.nifi.toolkit.tls.manager.writer.NifiPropertiesTlsClientConfigWriter
-
- write(byte[]) - Method in class org.apache.nifi.util.hive.HiveWriter
-
Write the record data to Hive
- write(FlowFile, OutputStreamCallback) - Method in class org.apache.nifi.util.MockProcessSession
-
- write(FlowFile) - Method in class org.apache.nifi.util.MockProcessSession
-
- write(FlowFile, StreamCallback) - Method in class org.apache.nifi.util.MockProcessSession
-
- WRITE_ACL_LIST - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor
-
- WRITE_CLIENT_ID - Static variable in class org.apache.nifi.integration.accesscontrol.AccessControlHelper
-
- WRITE_CONCERN - Static variable in class org.apache.nifi.mongodb.AbstractMongoDBControllerService
-
- WRITE_CONCERN - Static variable in class org.apache.nifi.processors.mongodb.AbstractMongoProcessor
-
- WRITE_DELAY_INTERVAL - Static variable in class org.apache.nifi.util.NiFiProperties
-
- WRITE_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
-
- WRITE_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiTestAuthorizer
-
- WRITE_USER_LIST - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor
-
- writeAdditionalBodyInfo(ConfigurableComponent, XMLStreamWriter) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
This method may be overridden by sub classes to write additional
information to the body of the documentation.
- writeAdditionalBodyInfo(ConfigurableComponent, XMLStreamWriter) - Method in class org.apache.nifi.documentation.html.HtmlProcessorDocumentationWriter
-
- WriteAheadFlowFileRepository - Class in org.apache.nifi.controller.repository
-
Implements FlowFile Repository using WALI as the backing store.
- WriteAheadFlowFileRepository() - Constructor for class org.apache.nifi.controller.repository.WriteAheadFlowFileRepository
-
default no args constructor for service loading only.
- WriteAheadFlowFileRepository(NiFiProperties) - Constructor for class org.apache.nifi.controller.repository.WriteAheadFlowFileRepository
-
- WriteAheadLocalStateProvider - Class in org.apache.nifi.controller.state.providers.local
-
Provides state management for local (standalone) state, backed by a write-ahead log
- WriteAheadLocalStateProvider() - Constructor for class org.apache.nifi.controller.state.providers.local.WriteAheadLocalStateProvider
-
- WriteAheadProvenanceRepository - Class in org.apache.nifi.provenance
-
A Provenance Repository that is made up of two distinct concepts: An
Event Store that is responsible
for storing and accessing the events (this repository makes use of an Event Store that uses a backing Write-Ahead Log, hence the name
WriteAheadProvenanceRepository) and an
Event Index that is responsible for indexing and searching those
events.
- WriteAheadProvenanceRepository() - Constructor for class org.apache.nifi.provenance.WriteAheadProvenanceRepository
-
This constructor exists solely for the use of the Java Service Loader mechanism and should not be used.
- WriteAheadProvenanceRepository(NiFiProperties) - Constructor for class org.apache.nifi.provenance.WriteAheadProvenanceRepository
-
- WriteAheadProvenanceRepository(RepositoryConfiguration) - Constructor for class org.apache.nifi.provenance.WriteAheadProvenanceRepository
-
- WriteAheadRepository<T> - Interface in org.wali
-
A WriteAheadRepository is used to persist state that is otherwise kept
in-memory.
- WriteAheadRepositoryRecordSerde - Class in org.apache.nifi.controller.repository
-
- WriteAheadRepositoryRecordSerde(ResourceClaimManager) - Constructor for class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
-
- WriteAheadStorePartition - Class in org.apache.nifi.provenance.store
-
- WriteAheadStorePartition(File, String, RepositoryConfiguration, RecordWriterFactory, RecordReaderFactory, BlockingQueue<File>, AtomicLong, EventReporter) - Constructor for class org.apache.nifi.provenance.store.WriteAheadStorePartition
-
- WriteAvroResultWithExternalSchema - Class in org.apache.nifi.avro
-
- WriteAvroResultWithExternalSchema(Schema, RecordSchema, SchemaAccessWriter, OutputStream) - Constructor for class org.apache.nifi.avro.WriteAvroResultWithExternalSchema
-
- WriteAvroResultWithSchema - Class in org.apache.nifi.avro
-
- WriteAvroResultWithSchema(Schema, OutputStream, CodecFactory) - Constructor for class org.apache.nifi.avro.WriteAvroResultWithSchema
-
- WriteAvroSchemaAttributeStrategy - Class in org.apache.nifi.schema.access
-
- WriteAvroSchemaAttributeStrategy() - Constructor for class org.apache.nifi.schema.access.WriteAvroSchemaAttributeStrategy
-
- writeBytes(OutputStream) - Method in class org.apache.nifi.cluster.protocol.impl.CopyingInputStream
-
- writeBytesToOutputStream(OutputStream, byte[], String, byte[]) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility
-
- WriteCSVResult - Class in org.apache.nifi.csv
-
- WriteCSVResult(CSVFormat, RecordSchema, SchemaAccessWriter, OutputStream, String, String, String, boolean) - Constructor for class org.apache.nifi.csv.WriteCSVResult
-
- writeDescription(ConfigurableComponent, XMLStreamWriter, boolean) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes a description of the configurable component.
- writeEvent(ProcessSession, String, T, long, Relationship) - Method in interface org.apache.nifi.cdc.event.io.EventWriter
-
Writes the given event to the process session, possibly via transferring it to the specified relationship (usually used for success)
- writeEvent(ProcessSession, String, T, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogEventWriter
-
- writeEvent(ProcessSession, String, T, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogTableEventWriter
-
- writeEvent(ProcessSession, String, DDLEventInfo, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.DDLEventWriter
-
- writeEvent(ProcessSession, String, DeleteRowsEventInfo, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.DeleteRowsWriter
-
Creates and transfers a new flow file whose contents are the JSON-serialized value of the specified event, and the sequence ID attribute set
- writeEvent(ProcessSession, String, InsertRowsEventInfo, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.InsertRowsWriter
-
Creates and transfers a new flow file whose contents are the JSON-serialized value of the specified event, and the sequence ID attribute set
- writeEvent(ProcessSession, String, UpdateRowsEventInfo, long, Relationship) - Method in class org.apache.nifi.cdc.mysql.event.io.UpdateRowsWriter
-
Creates and transfers a new flow file whose contents are the JSON-serialized value of the specified event, and the sequence ID attribute set
- WriteFailure(HiveEndPoint, Long, Throwable) - Constructor for exception org.apache.nifi.util.hive.HiveWriter.WriteFailure
-
- writeHead(ConfigurableComponent, XMLStreamWriter) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes the head portion of the HTML documentation.
- writeHeader(DataOutputStream) - Method in class org.apache.nifi.controller.repository.SchemaRepositoryRecordSerde
-
- writeHeader(long, DataOutputStream) - Method in class org.apache.nifi.provenance.ByteArraySchemaRecordWriter
-
- writeHeader(long, DataOutputStream) - Method in class org.apache.nifi.provenance.EventIdFirstSchemaRecordWriter
-
- writeHeader(long) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordWriter
-
- writeHeader(long, DataOutputStream) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordWriter
-
- writeHeader(long) - Method in interface org.apache.nifi.provenance.serialization.RecordWriter
-
Writes header information to the underlying stream
- writeHeader(long, DataOutputStream) - Method in class org.apache.nifi.provenance.StandardRecordWriter
-
Deprecated.
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.ConfluentSchemaRegistryWriter
-
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.HortonworksAttributeSchemaReferenceWriter
-
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.HortonworksEncodedSchemaReferenceWriter
-
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.NopSchemaAccessWriter
-
- writeHeader(RecordSchema, OutputStream) - Method in interface org.apache.nifi.schema.access.SchemaAccessWriter
-
Writes the given Record Schema to the given OutputStream as header information, if appropriate,
or returns without writing anything if the implementation does not need to write information to
the contents of the FlowFile
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.SchemaNameAsAttribute
-
- writeHeader(RecordSchema, OutputStream) - Method in class org.apache.nifi.schema.access.WriteAvroSchemaAttributeStrategy
-
- writeHeader(DataOutputStream) - Method in interface org.wali.SerDe
-
Provides the SerDe a chance to write header information to the given output stream
- writeIntermediateFooter() - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
-
- writeIV(byte[], OutputStream) - Method in class org.apache.nifi.security.util.crypto.KeyedCipherProvider
-
- writeIV(byte[], OutputStream) - Method in class org.apache.nifi.security.util.crypto.RandomIVPBECipherProvider
-
- writeJson(T) - Method in class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogEventWriter
-
- writeJson(T) - Method in class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogTableEventWriter
-
- writeJson(BeginTransactionEventInfo) - Method in class org.apache.nifi.cdc.mysql.event.io.BeginTransactionEventWriter
-
- writeJson(CommitTransactionEventInfo) - Method in class org.apache.nifi.cdc.mysql.event.io.CommitTransactionEventWriter
-
- WriteJsonResult - Class in org.apache.nifi.json
-
- WriteJsonResult(ComponentLog, RecordSchema, SchemaAccessWriter, OutputStream, boolean, NullSuppression, String, String, String) - Constructor for class org.apache.nifi.json.WriteJsonResult
-
- writeKeyStore(KeyStore, OutputStreamFactory, File, String, boolean) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
-
- writeLink(XMLStreamWriter, String, String) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
A helper method to write a link
- writeNiFiProperties(OutputStream) - Method in class org.apache.nifi.toolkit.tls.properties.NiFiPropertiesWriter
-
Write an updated nifi.properties to the given OutputStream
- writeNullableString(DataOutputStream, String, String) - Method in class org.apache.nifi.provenance.StandardRecordWriter
-
Deprecated.
- writeProperties(ConfigurableComponent, XMLStreamWriter) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes the PropertyDescriptors out as a table.
- writer() - Method in class org.apache.nifi.util.console.TextDevice
-
- WRITER_VERSION - Static variable in class org.apache.nifi.processors.parquet.PutParquet
-
- writeRawRecord(Record) - Method in class org.apache.nifi.csv.WriteCSVResult
-
- writeRawRecord(Record) - Method in class org.apache.nifi.json.WriteJsonResult
-
- writeRawRecord(Record) - Method in interface org.apache.nifi.serialization.record.RawRecordWriter
-
Writes the given result set to the underlying stream
- writeRecord(Record) - Method in class org.apache.nifi.avro.WriteAvroResultWithExternalSchema
-
- writeRecord(Record) - Method in class org.apache.nifi.avro.WriteAvroResultWithSchema
-
- writeRecord(Record) - Method in class org.apache.nifi.csv.WriteCSVResult
-
- writeRecord(Record) - Method in class org.apache.nifi.json.WriteJsonResult
-
- writeRecord(ProvenanceEventRecord, long, DataOutputStream) - Method in class org.apache.nifi.provenance.ByteArraySchemaRecordWriter
-
- writeRecord(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.EncryptedSchemaRecordWriter
-
- writeRecord(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.EventIdFirstSchemaRecordWriter
-
- writeRecord(ProvenanceEventRecord, long, DataOutputStream) - Method in class org.apache.nifi.provenance.EventIdFirstSchemaRecordWriter
-
- writeRecord(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordWriter
-
- writeRecord(ProvenanceEventRecord, long, DataOutputStream) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordWriter
-
- writeRecord(ProvenanceEventRecord) - Method in interface org.apache.nifi.provenance.serialization.RecordWriter
-
Writes the given record out to the underlying stream
- writeRecord(ProvenanceEventRecord, long, DataOutputStream) - Method in class org.apache.nifi.provenance.StandardRecordWriter
-
Deprecated.
- writeRecord(Record, OutputStream) - Method in class org.apache.nifi.repository.schema.SchemaRecordWriter
-
- writeRecord(Record) - Method in class org.apache.nifi.serialization.AbstractRecordSetWriter
-
- writeRecord(Record) - Method in class org.apache.nifi.text.FreeFormTextWriter
-
- writeRequestType(DataOutputStream) - Method in enum org.apache.nifi.remote.protocol.RequestType
-
- WriteResourceToStream - Class in org.apache.nifi.processors
-
- WriteResourceToStream() - Constructor for class org.apache.nifi.processors.WriteResourceToStream
-
- WriteResourceToStreamTest - Class in org.apache.nifi.processors
-
- WriteResourceToStreamTest() - Constructor for class org.apache.nifi.processors.WriteResourceToStreamTest
-
- writeResponse(DataOutputStream) - Method in enum org.apache.nifi.remote.protocol.ResponseCode
-
- writeResponse(DataOutputStream, String) - Method in enum org.apache.nifi.remote.protocol.ResponseCode
-
- WriteResult - Interface in org.apache.nifi.serialization
-
Provides information about what was written to an OutputStream by a
RecordSetWriter.
- writeRow(DeleteRowsEventInfo, Serializable[], BitSet) - Method in class org.apache.nifi.cdc.mysql.event.io.DeleteRowsWriter
-
- writeRow(InsertRowsEventInfo, Serializable[], BitSet) - Method in class org.apache.nifi.cdc.mysql.event.io.InsertRowsWriter
-
- writeRow(UpdateRowsEventInfo, Map.Entry<Serializable[], Serializable[]>, BitSet) - Method in class org.apache.nifi.cdc.mysql.event.io.UpdateRowsWriter
-
- writeSalt(byte[], OutputStream) - Method in class org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider
-
Deprecated.
- writeSalt(byte[], OutputStream) - Method in class org.apache.nifi.security.util.crypto.OpenSSLPKCS5CipherProvider
-
- writeSalt(byte[], OutputStream) - Method in interface org.apache.nifi.security.util.crypto.PBECipherProvider
-
Writes the salt provided as part of the cipher stream, or throws an exception if it cannot be written.
- writeSalt(byte[], OutputStream) - Method in class org.apache.nifi.security.util.crypto.RandomIVPBECipherProvider
-
- WritesAttribute - Annotation Type in org.apache.nifi.annotation.behavior
-
Annotation that may be placed on a
Processor indicating that this
processor writes/updates a specific FlowFile attribute.
- WritesAttributes - Annotation Type in org.apache.nifi.annotation.behavior
-
Annotation that may be placed on a
Processor indicating that this
processor writes/updates specific FlowFile attributes.
- writeSequenceFile(FlowFile, ProcessSession, Configuration, SequenceFile.CompressionType, CompressionCodec) - Method in class org.apache.nifi.processors.hadoop.SequenceFileWriterImpl
-
- writeSequenceFile(FlowFile, ProcessSession, Configuration, SequenceFile.CompressionType, CompressionCodec) - Method in interface org.apache.nifi.processors.hadoop.util.SequenceFileWriter
-
Creates a Sequence File by writing the given FlowFile as key/value pairs.
- writeSimpleElement(XMLStreamWriter, String, String, boolean) - Static method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes a begin element, then text, then end element for the element of a
users choosing.
- writeSimpleElement(XMLStreamWriter, String, String, boolean, String) - Static method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes a begin element, an id attribute(if specified), then text, then
end element for element of the users choosing.
- writeSimpleElement(XMLStreamWriter, String, String) - Static method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Writes a begin element, then text, then end element for the element of a
users choosing.
- writeTo(OutputStream) - Method in class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
-
- writeTo(OutputStream) - Method in class org.apache.nifi.repository.schema.RecordSchema
-
- writeTransactionResponse(ResponseCode) - Method in class org.apache.nifi.remote.AbstractTransaction
-
- writeTransactionResponse(ResponseCode, String) - Method in class org.apache.nifi.remote.AbstractTransaction
-
- writeTransactionResponse(boolean, ResponseCode, CommunicationsSession) - Method in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
-
- writeTransactionResponse(boolean, ResponseCode, CommunicationsSession, String) - Method in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
-
- writeTransactionResponse(ResponseCode, String) - Method in class org.apache.nifi.remote.protocol.http.HttpClientTransaction
-
- writeTransactionResponse(boolean, ResponseCode, CommunicationsSession, String) - Method in class org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol
-
- writeTransactionResponse(ResponseCode, String) - Method in class org.apache.nifi.remote.protocol.socket.SocketClientTransaction
-
- writeUUID(DataOutputStream, String) - Method in class org.apache.nifi.provenance.StandardRecordWriter
-
Deprecated.
- writeUUIDs(DataOutputStream, Collection<String>) - Method in class org.apache.nifi.provenance.StandardRecordWriter
-
Deprecated.
- writeValidValues(XMLStreamWriter, PropertyDescriptor) - Method in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
-
Interrogates a PropertyDescriptor to get a list of AllowableValues, if
there are none, nothing is written to the stream.
- wrongPortTypeResponse(String, String) - Method in class org.apache.nifi.web.api.ApplicationResource.ResponseCreator
-
- WrongSiteInfoServlet() - Constructor for class org.apache.nifi.remote.client.http.TestHttpClient.WrongSiteInfoServlet
-
- WS_URI - Static variable in class org.apache.nifi.websocket.jetty.JettyWebSocketClient
-
- WSServlet() - Constructor for class org.apache.nifi.websocket.example.WebSocketServerExample.WSServlet
-
- WStringArrayTypeNode - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
Node representing an array of wstring values
- WStringArrayTypeNode(BinaryReader, ChunkHeader, BxmlNode, int) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.WStringArrayTypeNode
-
- WStringArrayTypeNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
- WStringArrayTypeNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.WStringArrayTypeNodeTest
-
- WStringTypeNode - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
Node containing string read as UTF16_LE
- WStringTypeNode(BinaryReader, ChunkHeader, BxmlNode, int) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.WStringTypeNode
-
- WStringTypeNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml.value
-
- WStringTypeNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.value.WStringTypeNodeTest
-