nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joew...@apache.org
Subject [51/51] [partial] incubator-nifi git commit: Initial code contribution
Date Mon, 08 Dec 2014 20:30:14 GMT
Initial code contribution


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/4d998c12
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/4d998c12
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/4d998c12

Branch: refs/heads/master
Commit: 4d998c12c95a6e5ce3d66c0d861e75e33b5cf013
Parents: 
Author: joewitt <joewitt@apache.org>
Authored: Mon Dec 8 15:22:14 2014 -0500
Committer: joewitt <joewitt@apache.org>
Committed: Mon Dec 8 15:22:14 2014 -0500

----------------------------------------------------------------------
 .gitignore                                      |    9 +
 DISCLAIMER                                      |   15 +
 LICENSE                                         |  202 +
 NOTICE                                          |    7 +
 README.md                                       |   65 +
 assemblies/nifi/pom.xml                         |  485 +
 .../nifi/src/main/assembly/dependencies.xml     |  123 +
 commons/core-flowfile-attributes/pom.xml        |   32 +
 .../flowfile/attributes/CoreAttributes.java     |   72 +
 .../attributes/FlowFileAttributeKey.java        |   21 +
 commons/data-provenance-utils/.gitignore        |    2 +
 commons/data-provenance-utils/pom.xml           |   42 +
 .../nifi/provenance/AsyncLineageSubmission.java |   87 +
 .../nifi/provenance/AsyncQuerySubmission.java   |   81 +
 .../nifi/provenance/NamedSearchableField.java   |   95 +
 .../nifi/provenance/SearchableFieldParser.java  |   53 +
 .../nifi/provenance/SearchableFields.java       |   84 +
 .../nifi/provenance/StandardLineageResult.java  |  324 +
 .../StandardProvenanceEventRecord.java          |  752 ++
 .../nifi/provenance/StandardQueryResult.java    |  168 +
 .../nifi/provenance/lineage/EdgeNode.java       |   74 +
 .../nifi/provenance/lineage/EventNode.java      |  109 +
 .../provenance/lineage/FlowFileLineage.java     |   76 +
 .../nifi/provenance/lineage/FlowFileNode.java   |   83 +
 commons/flowfile-packager/pom.xml               |   43 +
 .../org/apache/nifi/util/FlowFilePackager.java  |   28 +
 .../apache/nifi/util/FlowFilePackagerV1.java    |  104 +
 .../apache/nifi/util/FlowFilePackagerV2.java    |  146 +
 .../apache/nifi/util/FlowFilePackagerV3.java    |   93 +
 .../apache/nifi/util/FlowFileUnpackager.java    |   30 +
 .../apache/nifi/util/FlowFileUnpackagerV1.java  |  155 +
 .../apache/nifi/util/FlowFileUnpackagerV2.java  |  143 +
 .../apache/nifi/util/FlowFileUnpackagerV3.java  |  161 +
 .../java/org/apache/nifi/util/Unpackage.java    |  119 +
 .../nifi/util/TestPackageUnpackageV3.java       |   56 +
 commons/naive-search-ring-buffer/pom.xml        |   30 +
 .../apache/nifi/util/NaiveSearchRingBuffer.java |  135 +
 .../nifi/util/TestNaiveSearchRingBuffer.java    |   72 +
 commons/nifi-expression-language/pom.xml        |   59 +
 .../language/antlr/AttributeExpressionLexer.g   |  207 +
 .../language/antlr/AttributeExpressionParser.g  |  139 +
 .../output/AttributeExpressionLexer.tokens      |   72 +
 .../expression/language/EmptyPreparedQuery.java |   62 +
 .../expression/language/PreparedQuery.java      |   39 +
 .../attribute/expression/language/Query.java    | 1183 +++
 .../language/StandardAttributeExpression.java   |   65 +
 .../StandardExpressionLanguageCompiler.java     |   58 +
 .../language/StandardPreparedQuery.java         |   83 +
 .../language/evaluation/BooleanEvaluator.java   |   32 +
 .../language/evaluation/BooleanQueryResult.java |   43 +
 .../language/evaluation/DateEvaluator.java      |   34 +
 .../language/evaluation/DateQueryResult.java    |   45 +
 .../language/evaluation/Evaluator.java          |   32 +
 .../language/evaluation/NumberEvaluator.java    |   33 +
 .../language/evaluation/NumberQueryResult.java  |   43 +
 .../language/evaluation/QueryResult.java        |   26 +
 .../language/evaluation/StringEvaluator.java    |   32 +
 .../language/evaluation/StringQueryResult.java  |   43 +
 .../evaluation/cast/BooleanCastEvaluator.java   |   50 +
 .../evaluation/cast/DateCastEvaluator.java      |  115 +
 .../evaluation/cast/NumberCastEvaluator.java    |   72 +
 .../evaluation/cast/StringCastEvaluator.java    |   49 +
 .../evaluation/functions/AndEvaluator.java      |   60 +
 .../evaluation/functions/AppendEvaluator.java   |   50 +
 .../functions/AttributeEvaluator.java           |   45 +
 .../evaluation/functions/ContainsEvaluator.java |   53 +
 .../functions/DateToNumberEvaluator.java        |   50 +
 .../evaluation/functions/DivideEvaluator.java   |   57 +
 .../evaluation/functions/EndsWithEvaluator.java |   53 +
 .../evaluation/functions/EqualsEvaluator.java   |   89 +
 .../functions/EqualsIgnoreCaseEvaluator.java    |   60 +
 .../evaluation/functions/FindEvaluator.java     |   72 +
 .../evaluation/functions/FormatEvaluator.java   |   60 +
 .../functions/GreaterThanEvaluator.java         |   60 +
 .../functions/GreaterThanOrEqualEvaluator.java  |   60 +
 .../evaluation/functions/HostnameEvaluator.java |   58 +
 .../evaluation/functions/IPEvaluator.java       |   46 +
 .../evaluation/functions/IndexOfEvaluator.java  |   53 +
 .../evaluation/functions/IsNullEvaluator.java   |   45 +
 .../functions/LastIndexOfEvaluator.java         |   53 +
 .../evaluation/functions/LengthEvaluator.java   |   46 +
 .../evaluation/functions/LessThanEvaluator.java |   60 +
 .../functions/LessThanOrEqualEvaluator.java     |   60 +
 .../evaluation/functions/MatchesEvaluator.java  |   71 +
 .../evaluation/functions/MinusEvaluator.java    |   57 +
 .../evaluation/functions/ModEvaluator.java      |   57 +
 .../evaluation/functions/MultiplyEvaluator.java |   57 +
 .../evaluation/functions/NotEvaluator.java      |   49 +
 .../evaluation/functions/NotNullEvaluator.java  |   45 +
 .../evaluation/functions/NowEvaluator.java      |   39 +
 .../functions/NumberToDateEvaluator.java        |   52 +
 .../functions/OneUpSequenceEvaluator.java       |   41 +
 .../evaluation/functions/OrEvaluator.java       |   60 +
 .../evaluation/functions/PlusEvaluator.java     |   57 +
 .../evaluation/functions/PrependEvaluator.java  |   50 +
 .../functions/ReplaceAllEvaluator.java          |   55 +
 .../evaluation/functions/ReplaceEvaluator.java  |   55 +
 .../functions/ReplaceNullEvaluator.java         |   47 +
 .../functions/StartsWithEvaluator.java          |   53 +
 .../functions/StringToDateEvaluator.java        |   64 +
 .../functions/SubstringAfterEvaluator.java      |   59 +
 .../functions/SubstringAfterLastEvaluator.java  |   55 +
 .../functions/SubstringBeforeEvaluator.java     |   58 +
 .../functions/SubstringBeforeLastEvaluator.java |   55 +
 .../functions/SubstringEvaluator.java           |   65 +
 .../evaluation/functions/ToLowerEvaluator.java  |   45 +
 .../evaluation/functions/ToNumberEvaluator.java |   46 +
 .../evaluation/functions/ToRadixEvaluator.java  |   77 +
 .../evaluation/functions/ToStringEvaluator.java |   45 +
 .../evaluation/functions/ToUpperEvaluator.java  |   45 +
 .../evaluation/functions/TrimEvaluator.java     |   45 +
 .../functions/UrlDecodeEvaluator.java           |   55 +
 .../functions/UrlEncodeEvaluator.java           |   55 +
 .../evaluation/functions/UuidEvaluator.java     |   39 +
 .../literals/BooleanLiteralEvaluator.java       |   44 +
 .../literals/NumberLiteralEvaluator.java        |   44 +
 .../literals/StringLiteralEvaluator.java        |   77 +
 .../selection/AllAttributesEvaluator.java       |   68 +
 .../selection/AnyAttributeEvaluator.java        |   68 +
 .../AnyMatchingAttributeEvaluator.java          |   21 +
 .../selection/DelineatedAttributeEvaluator.java |   83 +
 .../selection/MultiAttributeEvaluator.java      |   24 +
 .../selection/MultiMatchAttributeEvaluator.java |   82 +
 .../selection/MultiNamedAttributeEvaluator.java |   64 +
 .../AttributeExpressionLanguageException.java   |   34 +
 ...ibuteExpressionLanguageParsingException.java |   34 +
 .../exception/IllegalAttributeException.java    |   28 +
 .../expression/language/TestQuery.java          | 1068 +++
 .../language/TestStandardPreparedQuery.java     |   92 +
 commons/nifi-file-utils/pom.xml                 |   35 +
 .../java/org/apache/nifi/file/FileUtils.java    |  612 ++
 commons/nifi-logging-utils/pom.xml              |   35 +
 .../java/org/apache/nifi/logging/NiFiLog.java   |  367 +
 commons/nifi-parent/pom.xml                     |  217 +
 commons/nifi-properties/.gitignore              |    3 +
 commons/nifi-properties/pom.xml                 |   29 +
 .../org/apache/nifi/util/NiFiProperties.java    |  882 ++
 .../java/org/apache/nifi/util/StringUtils.java  |   66 +
 commons/nifi-security-utils/pom.xml             |   40 +
 .../nifi/security/util/CertificateUtils.java    |  158 +
 .../nifi/security/util/EncryptionMethod.java    |   84 +
 .../apache/nifi/security/util/KeystoreType.java |   26 +
 .../nifi/security/util/SecurityStoreTypes.java  |  144 +
 .../nifi/security/util/SslContextFactory.java   |  180 +
 commons/nifi-socket-utils/pom.xml               |   65 +
 .../nifi/io/nio/AbstractChannelReader.java      |  166 +
 .../java/org/apache/nifi/io/nio/BufferPool.java |  114 +
 .../apache/nifi/io/nio/ChannelDispatcher.java   |  160 +
 .../org/apache/nifi/io/nio/ChannelListener.java |  228 +
 .../nifi/io/nio/DatagramChannelReader.java      |   59 +
 .../apache/nifi/io/nio/SocketChannelReader.java |   55 +
 .../io/nio/consumer/AbstractStreamConsumer.java |  132 +
 .../nifi/io/nio/consumer/StreamConsumer.java    |   80 +
 .../io/nio/consumer/StreamConsumerFactory.java  |   27 +
 .../nifi/io/socket/SSLContextFactory.java       |  102 +
 .../io/socket/ServerSocketConfiguration.java    |   83 +
 .../nifi/io/socket/SocketConfiguration.java     |  116 +
 .../apache/nifi/io/socket/SocketListener.java   |  211 +
 .../org/apache/nifi/io/socket/SocketUtils.java  |  169 +
 .../socket/multicast/DiscoverableService.java   |   43 +
 .../multicast/DiscoverableServiceImpl.java      |   78 +
 .../multicast/MulticastConfiguration.java       |   99 +
 .../io/socket/multicast/MulticastListener.java  |  193 +
 .../multicast/MulticastServiceDiscovery.java    |   34 +
 .../multicast/MulticastServicesBroadcaster.java |   33 +
 .../socket/multicast/MulticastTimeToLive.java   |   50 +
 .../io/socket/multicast/MulticastUtils.java     |  109 +
 .../io/socket/multicast/ServiceDiscovery.java   |   31 +
 .../socket/multicast/ServicesBroadcaster.java   |   56 +
 .../apache/nifi/io/nio/example/ServerMain.java  |  141 +
 .../apache/nifi/io/nio/example/TCPClient.java   |   86 +
 .../apache/nifi/io/nio/example/UDPClient.java   |   51 +
 .../io/nio/example/UselessStreamConsumer.java   |   43 +
 .../src/test/resources/log4j.xml                |   36 +
 commons/nifi-stream-utils/.gitignore            |    1 +
 commons/nifi-stream-utils/pom.xml               |   42 +
 .../org/apache/nifi/io/BufferedInputStream.java |   37 +
 .../apache/nifi/io/BufferedOutputStream.java    |  140 +
 .../apache/nifi/io/ByteArrayInputStream.java    |  250 +
 .../apache/nifi/io/ByteArrayOutputStream.java   |  250 +
 .../apache/nifi/io/ByteCountingInputStream.java |  104 +
 .../nifi/io/ByteCountingOutputStream.java       |   63 +
 .../org/apache/nifi/io/DataOutputStream.java    |  417 +
 .../org/apache/nifi/io/GZIPOutputStream.java    |   41 +
 .../nifi/io/LeakyBucketStreamThrottler.java     |  324 +
 .../apache/nifi/io/NonCloseableInputStream.java |   56 +
 .../nifi/io/NonCloseableOutputStream.java       |   51 +
 .../org/apache/nifi/io/NullOutputStream.java    |   46 +
 .../org/apache/nifi/io/StreamThrottler.java     |   33 +
 .../java/org/apache/nifi/io/StreamUtils.java    |  257 +
 .../org/apache/nifi/io/ZipOutputStream.java     |   38 +
 .../exception/BytePatternNotFoundException.java |   28 +
 .../io/util/NonThreadSafeCircularBuffer.java    |   69 +
 .../nifi/io/TestLeakyBucketThrottler.java       |  144 +
 .../src/test/resources/logback-test.xml         |   48 +
 commons/nifi-utils/.gitignore                   |    8 +
 commons/nifi-utils/pom.xml                      |   28 +
 .../apache/nifi/io/CompoundUpdateMonitor.java   |  115 +
 .../org/apache/nifi/io/LastModifiedMonitor.java |   30 +
 .../java/org/apache/nifi/io/MD5SumMonitor.java  |   49 +
 .../apache/nifi/io/SynchronousFileWatcher.java  |  123 +
 .../java/org/apache/nifi/io/UpdateMonitor.java  |   25 +
 .../org/apache/nifi/util/BooleanHolder.java     |   25 +
 .../java/org/apache/nifi/util/FormatUtils.java  |  204 +
 .../org/apache/nifi/util/IntegerHolder.java     |   54 +
 .../java/org/apache/nifi/util/LongHolder.java   |   60 +
 .../java/org/apache/nifi/util/ObjectHolder.java |   39 +
 .../java/org/apache/nifi/util/RingBuffer.java   |  292 +
 .../java/org/apache/nifi/util/StopWatch.java    |  127 +
 .../main/java/org/apache/nifi/util/Tuple.java   |   83 +
 .../concurrency/DebugDisabledTimedLock.java     |   67 +
 .../util/concurrency/DebugEnabledTimedLock.java |  136 +
 .../util/concurrency/DebuggableTimedLock.java   |   30 +
 .../apache/nifi/util/concurrency/TimedLock.java |   59 +
 .../nifi/util/timebuffer/EntityAccess.java      |   26 +
 .../nifi/util/timebuffer/LongEntityAccess.java  |   43 +
 .../nifi/util/timebuffer/TimedBuffer.java       |  114 +
 .../nifi/util/timebuffer/TimestampedLong.java   |   35 +
 .../timebuffer/TestCompoundUpdateMonitor.java   |   75 +
 .../nifi/util/timebuffer/TestRingBuffer.java    |  182 +
 .../timebuffer/TestSynchronousFileWatcher.java  |   64 +
 .../nifi/util/timebuffer/TestTimedBuffer.java   |  106 +
 commons/nifi-web-utils/pom.xml                  |   56 +
 .../org/apache/nifi/web/util/ClientUtils.java   |  132 +
 .../nifi/web/util/ObjectMapperResolver.java     |   48 +
 .../java/org/apache/nifi/web/util/WebUtils.java |  198 +
 commons/processor-utilities/pom.xml             |   47 +
 .../nifi/processor/util/FlowFileFilters.java    |   65 +
 .../nifi/processor/util/SSLProperties.java      |  226 +
 .../nifi/processor/util/StandardValidators.java |  544 ++
 .../apache/nifi/processor/TestFormatUtils.java  |   40 +
 .../processor/util/TestStandardValidators.java  |   54 +
 commons/remote-communications-utils/pom.xml     |   29 +
 .../nifi/remote/StandardVersionNegotiator.java  |   81 +
 .../apache/nifi/remote/VersionNegotiator.java   |   65 +
 .../TransmissionDisabledException.java          |   25 +
 .../nifi/remote/io/CompressionInputStream.java  |  184 +
 .../nifi/remote/io/CompressionOutputStream.java |  147 +
 .../remote/io/InterruptableInputStream.java     |  117 +
 .../remote/io/InterruptableOutputStream.java    |   81 +
 .../remote/io/socket/BufferStateManager.java    |  111 +
 .../io/socket/SocketChannelInputStream.java     |  157 +
 .../io/socket/SocketChannelOutputStream.java    |  113 +
 .../remote/io/socket/ssl/SSLSocketChannel.java  |  602 ++
 .../socket/ssl/SSLSocketChannelInputStream.java |   62 +
 .../ssl/SSLSocketChannelOutputStream.java       |   53 +
 .../io/TestCompressionInputOutputStreams.java   |  153 +
 commons/search-utils/pom.xml                    |   32 +
 .../org/apache/nifi/util/search/Search.java     |   57 +
 .../org/apache/nifi/util/search/SearchTerm.java |  141 +
 .../util/search/ahocorasick/AhoCorasick.java    |  155 +
 .../nifi/util/search/ahocorasick/Node.java      |   72 +
 .../util/search/ahocorasick/SearchState.java    |   63 +
 commons/wali/.gitignore                         |    2 +
 commons/wali/pom.xml                            |   42 +
 .../org/wali/MinimalLockingWriteAheadLog.java   | 1008 ++
 commons/wali/src/main/java/org/wali/SerDe.java  |  128 +
 .../src/main/java/org/wali/SyncListener.java    |   62 +
 .../wali/src/main/java/org/wali/UpdateType.java |   49 +
 .../java/org/wali/WriteAheadRepository.java     |  122 +
 .../src/test/java/org/wali/DummyRecord.java     |   61 +
 .../test/java/org/wali/DummyRecordSerde.java    |  107 +
 .../wali/TestMinimalLockingWriteAheadLog.java   |  298 +
 extensions/file-authorization-provider/pom.xml  |   90 +
 .../FileAuthorizationProvider.java              |  568 ++
 ....apache.nifi.authorization.AuthorityProvider |   15 +
 .../src/main/xsd/users.xsd                      |   64 +
 .../FileAuthorizationProviderTest.java          |  127 +
 misc/build-order.sh                             |   79 +
 misc/nar-maven-plugin/pom.xml                   |   83 +
 .../src/main/java/nifi/NarMojo.java             |  610 ++
 .../resources/META-INF/plexus/components.xml    |   52 +
 .../distributed-cache-client-service/pom.xml    |   67 +
 .../distributed/cache/client/CommsSession.java  |   46 +
 .../DistributedMapCacheClientService.java       |  301 +
 .../DistributedSetCacheClientService.java       |  212 +
 .../cache/client/SSLCommsSession.java           |  106 +
 .../cache/client/StandardCommsSession.java      |  124 +
 ...org.apache.nifi.controller.ControllerService |   16 +
 .../index.html                                  |   78 +
 .../index.html                                  |    0
 .../distributed-cache-protocol/pom.xml          |   39 +
 .../cache/protocol/ProtocolHandshake.java       |  119 +
 .../protocol/exception/HandshakeException.java  |   27 +
 .../distributed-cache-server/pom.xml            |   81 +
 .../cache/server/AbstractCacheServer.java       |  199 +
 .../distributed/cache/server/CacheRecord.java   |   57 +
 .../distributed/cache/server/CacheServer.java   |   26 +
 .../cache/server/DistributedCacheServer.java    |  107 +
 .../cache/server/DistributedSetCacheServer.java |   68 +
 .../cache/server/EvictionPolicy.java            |   73 +
 .../cache/server/SetCacheServer.java            |  104 +
 .../server/map/DistributedMapCacheServer.java   |   71 +
 .../distributed/cache/server/map/MapCache.java  |   29 +
 .../cache/server/map/MapCacheRecord.java        |   58 +
 .../cache/server/map/MapCacheServer.java        |  145 +
 .../cache/server/map/MapPutResult.java          |   59 +
 .../cache/server/map/PersistentMapCache.java    |  210 +
 .../cache/server/map/SimpleMapCache.java        |  165 +
 .../cache/server/set/PersistentSetCache.java    |  194 +
 .../distributed/cache/server/set/SetCache.java  |   29 +
 .../cache/server/set/SetCacheRecord.java        |   55 +
 .../cache/server/set/SetCacheResult.java        |   43 +
 .../cache/server/set/SimpleSetCache.java        |  117 +
 ...org.apache.nifi.controller.ControllerService |   16 +
 .../index.html                                  |   82 +
 .../cache/server/TestServerAndClient.java       |  530 +
 .../src/test/resources/localhost-ks.jks         |  Bin 0 -> 1298 bytes
 .../src/test/resources/localhost-ts.jks         |  Bin 0 -> 891 bytes
 .../distributed-cache-services-nar/pom.xml      |   49 +
 .../distributed-cache-services-bundle/pom.xml   |   83 +
 .../execute-script-processors/pom.xml           |   81 +
 .../nifi/processors/script/ExecuteScript.java   |  566 ++
 .../apache/nifi/scripting/ConverterScript.java  |  131 +
 .../nifi/scripting/JRubyScriptFactory.java      |   46 +
 .../nifi/scripting/JavaScriptScriptFactory.java |   56 +
 .../nifi/scripting/JythonScriptFactory.java     |   45 +
 .../nifi/scripting/OutputStreamHandler.java     |   24 +
 .../org/apache/nifi/scripting/ReaderScript.java |   79 +
 .../java/org/apache/nifi/scripting/Script.java  |  303 +
 .../nifi/scripting/ScriptEngineFactory.java     |  117 +
 .../apache/nifi/scripting/ScriptFactory.java    |  269 +
 .../org/apache/nifi/scripting/WriterScript.java |   67 +
 .../org.apache.nifi.processor.Processor         |   15 +
 .../index.html                                  |  264 +
 .../processors/script/TestExecuteScript.java    |  939 ++
 .../src/test/resources/alwaysFail.js            |   24 +
 .../src/test/resources/alwaysFail.py            |   19 +
 .../src/test/resources/alwaysFail.rb            |   21 +
 .../src/test/resources/ffTest.js                |   28 +
 .../src/test/resources/ffTest.py                |   22 +
 .../src/test/resources/ffTest.rb                |   30 +
 .../src/test/resources/lib/Sub.py               |   18 +
 .../src/test/resources/lib/sub.js               |   22 +
 .../src/test/resources/lib/sub.rb               |   17 +
 .../src/test/resources/loadLocal.js             |   30 +
 .../src/test/resources/loadLocal.py             |   26 +
 .../src/test/resources/loadLocal.rb             |   29 +
 .../src/test/resources/log4j.xml                |   54 +
 .../src/test/resources/optionalValidators.js    |   28 +
 .../src/test/resources/optionalValidators.py    |   22 +
 .../src/test/resources/optionalValidators.rb    |   39 +
 .../src/test/resources/paramTest.js             |   28 +
 .../src/test/resources/paramTest.py             |   26 +
 .../src/test/resources/paramTest.rb             |   31 +
 .../src/test/resources/parseXml.js              |   36 +
 .../src/test/resources/readTest.js              |   30 +
 .../src/test/resources/readTest.py              |   32 +
 .../src/test/resources/readTest.rb              |   30 +
 .../src/test/resources/readWithParams.js        |   32 +
 .../src/test/resources/readWithParams.py        |   32 +
 .../src/test/resources/readWithParams.rb        |   33 +
 .../src/test/resources/routeTest.js             |   41 +
 .../src/test/resources/routeTest.py             |   37 +
 .../src/test/resources/routeTest.rb             |   39 +
 .../src/test/resources/simpleConverter.js       |   45 +
 .../src/test/resources/simpleConverter.py       |   60 +
 .../src/test/resources/simpleConverter.rb       |   42 +
 .../src/test/resources/writeTest.js             |   26 +
 .../src/test/resources/writeTest.py             |   22 +
 .../src/test/resources/writeTest.rb             |   32 +
 nar-bundles/execute-script-bundle/nar/pom.xml   |   36 +
 nar-bundles/execute-script-bundle/pom.xml       |   81 +
 .../framework/administration/.gitignore         |    1 +
 .../framework/administration/pom.xml            |  116 +
 .../nifi/admin/AuditDataSourceFactoryBean.java  |  222 +
 .../org/apache/nifi/admin/RepositoryUtils.java  |   91 +
 .../nifi/admin/UserDataSourceFactoryBean.java   |  247 +
 .../org/apache/nifi/admin/dao/ActionDAO.java    |   74 +
 .../org/apache/nifi/admin/dao/AuthorityDAO.java |   58 +
 .../org/apache/nifi/admin/dao/DAOFactory.java   |   29 +
 .../nifi/admin/dao/DataAccessException.java     |   39 +
 .../java/org/apache/nifi/admin/dao/UserDAO.java |  127 +
 .../nifi/admin/dao/impl/DAOFactoryImpl.java     |   51 +
 .../nifi/admin/dao/impl/StandardActionDAO.java  | 1056 ++
 .../admin/dao/impl/StandardAuthorityDAO.java    |  172 +
 .../nifi/admin/dao/impl/StandardUserDAO.java    |  634 ++
 .../admin/service/AccountDisabledException.java |   40 +
 .../admin/service/AccountNotFoundException.java |   40 +
 .../admin/service/AccountPendingException.java  |   41 +
 .../admin/service/AdministrationException.java  |   39 +
 .../apache/nifi/admin/service/AuditService.java |   76 +
 .../apache/nifi/admin/service/UserService.java  |  148 +
 .../service/action/AbstractUserAction.java      |   97 +
 .../admin/service/action/AddActionsAction.java  |   48 +
 .../service/action/AdministrationAction.java    |   38 +
 .../service/action/AuthorizeUserAction.java     |  175 +
 .../admin/service/action/CreateUserAction.java  |   53 +
 .../admin/service/action/DeleteUserAction.java  |   68 +
 .../admin/service/action/DisableUserAction.java |   76 +
 .../service/action/DisableUserGroupAction.java  |   69 +
 .../service/action/FindUserByDnAction.java      |   49 +
 .../service/action/FindUserByIdAction.java      |   49 +
 .../admin/service/action/GetActionAction.java   |   41 +
 .../admin/service/action/GetActionsAction.java  |   48 +
 .../admin/service/action/GetPreviousValues.java |   43 +
 .../service/action/GetUserGroupAction.java      |   50 +
 .../admin/service/action/GetUsersAction.java    |   39 +
 .../service/action/HasPendingUserAccounts.java  |   34 +
 .../action/InvalidateUserAccountAction.java     |   58 +
 .../InvalidateUserGroupAccountsAction.java      |   45 +
 .../service/action/PurgeActionsAction.java      |   51 +
 .../action/RequestUserAccountAction.java        |   67 +
 .../service/action/SeedUserAccountsAction.java  |  164 +
 .../admin/service/action/UngroupUserAction.java |   69 +
 .../service/action/UngroupUserGroupAction.java  |   57 +
 .../admin/service/action/UpdateUserAction.java  |  124 +
 .../UpdateUserAuthoritiesCacheAction.java       |   73 +
 .../service/action/UpdateUserCacheAction.java   |   47 +
 .../service/action/UpdateUserGroupAction.java   |  171 +
 .../service/impl/StandardAuditService.java      |  230 +
 .../admin/service/impl/StandardUserService.java |  629 ++
 .../admin/service/transaction/Transaction.java  |   49 +
 .../service/transaction/TransactionBuilder.java |   25 +
 .../transaction/TransactionException.java       |   40 +
 .../transaction/impl/StandardTransaction.java   |   93 +
 .../impl/StandardTransactionBuilder.java        |   57 +
 .../AuthorityProviderFactoryBean.java           |  516 +
 ...rdAuthorityProviderConfigurationContext.java |   50 +
 ...dAuthorityProviderInitializationContext.java |   42 +
 .../java/org/apache/nifi/history/History.java   |   56 +
 .../org/apache/nifi/history/HistoryQuery.java   |   99 +
 .../org/apache/nifi/history/PreviousValue.java  |   54 +
 .../org/apache/nifi/user/AccountStatus.java     |   47 +
 .../java/org/apache/nifi/user/NiFiUser.java     |  154 +
 .../org/apache/nifi/user/NiFiUserGroup.java     |   45 +
 .../resources/nifi-administration-context.xml   |   62 +
 .../src/main/xsd/authority-providers.xsd        |   49 +
 .../service/action/AuthorizeUserActionTest.java |  433 +
 .../service/action/CreateUserActionTest.java    |  144 +
 .../service/action/DisableUserActionTest.java   |  171 +
 .../action/InvalidateUserAccountActionTest.java |  131 +
 .../action/RequestUserAccountActionTest.java    |  127 +
 .../action/SeedUserAccountsActionTest.java      |  263 +
 .../action/SetUserAuthoritiesActionTest.java    |  223 +
 .../impl/NiFiAuthorizationServiceTest.java      |  284 +
 .../framework/client-dto/.gitignore             |    6 +
 .../framework/client-dto/pom.xml                |   47 +
 .../org/apache/nifi/web/api/dto/AboutDTO.java   |   57 +
 .../org/apache/nifi/web/api/dto/BannerDTO.java  |   57 +
 .../nifi/web/api/dto/BulletinBoardDTO.java      |   63 +
 .../apache/nifi/web/api/dto/BulletinDTO.java    |  161 +
 .../nifi/web/api/dto/BulletinQueryDTO.java      |  113 +
 .../org/apache/nifi/web/api/dto/ClusterDTO.java |   61 +
 .../apache/nifi/web/api/dto/ConnectableDTO.java |  146 +
 .../apache/nifi/web/api/dto/ConnectionDTO.java  |  215 +
 .../web/api/dto/ControllerConfigurationDTO.java |  158 +
 .../apache/nifi/web/api/dto/ControllerDTO.java  |  262 +
 .../org/apache/nifi/web/api/dto/CounterDTO.java |   94 +
 .../apache/nifi/web/api/dto/CountersDTO.java    |   61 +
 .../nifi/web/api/dto/DocumentedTypeDTO.java     |   71 +
 .../apache/nifi/web/api/dto/FlowSnippetDTO.java |  141 +
 .../org/apache/nifi/web/api/dto/FunnelDTO.java  |   29 +
 .../org/apache/nifi/web/api/dto/LabelDTO.java   |   94 +
 .../nifi/web/api/dto/NiFiComponentDTO.java      |   95 +
 .../org/apache/nifi/web/api/dto/NodeDTO.java    |  188 +
 .../apache/nifi/web/api/dto/NodeEventDTO.java   |   74 +
 .../web/api/dto/NodeSystemDiagnosticsDTO.java   |   56 +
 .../org/apache/nifi/web/api/dto/PortDTO.java    |  161 +
 .../apache/nifi/web/api/dto/PositionDTO.java    |   65 +
 .../nifi/web/api/dto/PreviousValueDTO.java      |   73 +
 .../nifi/web/api/dto/ProcessGroupDTO.java       |  219 +
 .../nifi/web/api/dto/ProcessorConfigDTO.java    |  486 +
 .../apache/nifi/web/api/dto/ProcessorDTO.java   |  181 +
 .../nifi/web/api/dto/ProcessorHistoryDTO.java   |   56 +
 .../nifi/web/api/dto/PropertyHistoryDTO.java    |   43 +
 .../nifi/web/api/dto/RelationshipDTO.java       |   69 +
 .../api/dto/RemoteProcessGroupContentsDTO.java  |   56 +
 .../nifi/web/api/dto/RemoteProcessGroupDTO.java |  279 +
 .../web/api/dto/RemoteProcessGroupPortDTO.java  |  192 +
 .../apache/nifi/web/api/dto/RevisionDTO.java    |   63 +
 .../org/apache/nifi/web/api/dto/SnippetDTO.java |  239 +
 .../nifi/web/api/dto/SystemDiagnosticsDTO.java  |  461 +
 .../apache/nifi/web/api/dto/TemplateDTO.java    |  117 +
 .../org/apache/nifi/web/api/dto/UserDTO.java    |  177 +
 .../apache/nifi/web/api/dto/UserGroupDTO.java   |   84 +
 .../nifi/web/api/dto/action/ActionDTO.java      |  176 +
 .../nifi/web/api/dto/action/HistoryDTO.java     |   74 +
 .../web/api/dto/action/HistoryQueryDTO.java     |  144 +
 .../component/details/ComponentDetailsDTO.java  |   32 +
 .../component/details/ProcessorDetailsDTO.java  |   41 +
 .../details/RemoteProcessGroupDetailsDTO.java   |   41 +
 .../dto/action/details/ActionDetailsDTO.java    |   34 +
 .../dto/action/details/ConfigureDetailsDTO.java |   69 +
 .../dto/action/details/ConnectDetailsDTO.java   |  126 +
 .../api/dto/action/details/MoveDetailsDTO.java  |   83 +
 .../api/dto/action/details/PurgeDetailsDTO.java |   45 +
 .../web/api/dto/provenance/AttributeDTO.java    |   69 +
 .../web/api/dto/provenance/ProvenanceDTO.java   |  165 +
 .../api/dto/provenance/ProvenanceEventDTO.java  |  630 ++
 .../dto/provenance/ProvenanceOptionsDTO.java    |   43 +
 .../dto/provenance/ProvenanceRequestDTO.java    |  118 +
 .../dto/provenance/ProvenanceResultsDTO.java    |  136 +
 .../ProvenanceSearchableFieldDTO.java           |   84 +
 .../api/dto/provenance/lineage/LineageDTO.java  |  161 +
 .../provenance/lineage/LineageRequestDTO.java   |   88 +
 .../provenance/lineage/LineageResultsDTO.java   |   73 +
 .../provenance/lineage/ProvenanceLinkDTO.java   |  101 +
 .../provenance/lineage/ProvenanceNodeDTO.java   |  162 +
 .../dto/search/ComponentSearchResultDTO.java    |   85 +
 .../web/api/dto/search/NodeSearchResultDTO.java |   56 +
 .../web/api/dto/search/SearchResultsDTO.java    |  128 +
 .../dto/search/UserGroupSearchResultDTO.java    |   42 +
 .../web/api/dto/search/UserSearchResultDTO.java |   56 +
 .../dto/status/ClusterConnectionStatusDTO.java  |   89 +
 .../api/dto/status/ClusterPortStatusDTO.java    |   89 +
 .../dto/status/ClusterProcessorStatusDTO.java   |  117 +
 .../ClusterRemoteProcessGroupStatusDTO.java     |   89 +
 .../web/api/dto/status/ClusterStatusDTO.java    |   44 +
 .../api/dto/status/ClusterStatusHistoryDTO.java |   75 +
 .../web/api/dto/status/ConnectionStatusDTO.java |  198 +
 .../web/api/dto/status/ControllerStatusDTO.java |  187 +
 .../api/dto/status/NodeConnectionStatusDTO.java |   57 +
 .../web/api/dto/status/NodePortStatusDTO.java   |   57 +
 .../api/dto/status/NodeProcessorStatusDTO.java  |   57 +
 .../status/NodeRemoteProcessGroupStatusDTO.java |   57 +
 .../nifi/web/api/dto/status/NodeStatusDTO.java  |   57 +
 .../api/dto/status/NodeStatusHistoryDTO.java    |   57 +
 .../nifi/web/api/dto/status/PortStatusDTO.java  |  142 +
 .../api/dto/status/ProcessGroupStatusDTO.java   |  244 +
 .../web/api/dto/status/ProcessorStatusDTO.java  |  203 +
 .../web/api/dto/status/RemotePortStatusDTO.java |   98 +
 .../dto/status/RemoteProcessGroupStatusDTO.java |  159 +
 .../nifi/web/api/dto/status/StatusDTO.java      |   43 +
 .../web/api/dto/status/StatusDescriptorDTO.java |  101 +
 .../web/api/dto/status/StatusHistoryDTO.java    |   92 +
 .../api/dto/status/StatusHistoryDetailDTO.java  |   56 +
 .../web/api/dto/status/StatusSnapshotDTO.java   |   58 +
 .../nifi/web/api/dto/util/DateTimeAdapter.java  |   45 +
 .../nifi/web/api/dto/util/TimeAdapter.java      |   45 +
 .../nifi/web/api/dto/util/TimestampAdapter.java |   45 +
 .../apache/nifi/web/api/entity/AboutEntity.java |   45 +
 .../nifi/web/api/entity/ActionEntity.java       |   45 +
 .../nifi/web/api/entity/AuthorityEntity.java    |   60 +
 .../nifi/web/api/entity/BannerEntity.java       |   46 +
 .../web/api/entity/BulletinBoardEntity.java     |   45 +
 .../entity/ClusterConnectionStatusEntity.java   |   45 +
 .../nifi/web/api/entity/ClusterEntity.java      |   45 +
 .../web/api/entity/ClusterPortStatusEntity.java |   45 +
 .../entity/ClusterProcessorStatusEntity.java    |   45 +
 .../ClusterRemoteProcessGroupStatusEntity.java  |   45 +
 .../api/entity/ClusterSearchResultsEntity.java  |   46 +
 .../web/api/entity/ClusterStatusEntity.java     |   45 +
 .../api/entity/ClusterStatusHistoryEntity.java  |   45 +
 .../nifi/web/api/entity/ConnectionEntity.java   |   45 +
 .../nifi/web/api/entity/ConnectionsEntity.java  |   47 +
 .../entity/ControllerConfigurationEntity.java   |   45 +
 .../nifi/web/api/entity/ControllerEntity.java   |   45 +
 .../web/api/entity/ControllerStatusEntity.java  |   45 +
 .../nifi/web/api/entity/CounterEntity.java      |   45 +
 .../nifi/web/api/entity/CountersEntity.java     |   46 +
 .../org/apache/nifi/web/api/entity/Entity.java  |   43 +
 .../nifi/web/api/entity/FlowSnippetEntity.java  |   45 +
 .../nifi/web/api/entity/FunnelEntity.java       |   45 +
 .../nifi/web/api/entity/FunnelsEntity.java      |   47 +
 .../nifi/web/api/entity/HistoryEntity.java      |   45 +
 .../nifi/web/api/entity/InputPortEntity.java    |   45 +
 .../nifi/web/api/entity/InputPortsEntity.java   |   47 +
 .../apache/nifi/web/api/entity/LabelEntity.java |   45 +
 .../nifi/web/api/entity/LabelsEntity.java       |   47 +
 .../nifi/web/api/entity/LineageEntity.java      |   45 +
 .../apache/nifi/web/api/entity/NodeEntity.java  |   45 +
 .../nifi/web/api/entity/NodeStatusEntity.java   |   45 +
 .../api/entity/NodeSystemDiagnosticsEntity.java |   45 +
 .../nifi/web/api/entity/OutputPortEntity.java   |   45 +
 .../nifi/web/api/entity/OutputPortsEntity.java  |   47 +
 .../web/api/entity/PrioritizerTypesEntity.java  |   46 +
 .../nifi/web/api/entity/ProcessGroupEntity.java |   45 +
 .../api/entity/ProcessGroupStatusEntity.java    |   45 +
 .../web/api/entity/ProcessGroupsEntity.java     |   46 +
 .../nifi/web/api/entity/ProcessorEntity.java    |   45 +
 .../web/api/entity/ProcessorHistoryEntity.java  |   45 +
 .../web/api/entity/ProcessorTypesEntity.java    |   46 +
 .../nifi/web/api/entity/ProcessorsEntity.java   |   47 +
 .../nifi/web/api/entity/ProvenanceEntity.java   |   40 +
 .../web/api/entity/ProvenanceEventEntity.java   |   45 +
 .../web/api/entity/ProvenanceOptionsEntity.java |   46 +
 .../api/entity/RemoteProcessGroupEntity.java    |   45 +
 .../entity/RemoteProcessGroupPortEntity.java    |   45 +
 .../api/entity/RemoteProcessGroupsEntity.java   |   47 +
 .../web/api/entity/SearchResultsEntity.java     |   46 +
 .../nifi/web/api/entity/SnippetEntity.java      |   45 +
 .../web/api/entity/StatusHistoryEntity.java     |   45 +
 .../web/api/entity/SystemDiagnosticsEntity.java |   45 +
 .../nifi/web/api/entity/TemplateEntity.java     |   45 +
 .../nifi/web/api/entity/TemplatesEntity.java    |   63 +
 .../apache/nifi/web/api/entity/UserEntity.java  |   45 +
 .../nifi/web/api/entity/UserGroupEntity.java    |   45 +
 .../web/api/entity/UserSearchResultsEntity.java |   61 +
 .../apache/nifi/web/api/entity/UsersEntity.java |   64 +
 .../cluster-authorization-provider/.gitignore   |    1 +
 .../cluster-authorization-provider/pom.xml      |   48 +
 .../ClusterManagerAuthorizationProvider.java    |  225 +
 .../NodeAuthorizationProvider.java              |  381 +
 .../protocol/message/DoesDnExistMessage.java    |   56 +
 .../protocol/message/GetAuthoritiesMessage.java |   58 +
 .../message/GetGroupForUserMessage.java         |   55 +
 .../protocol/message/ProtocolMessage.java       |   57 +
 .../message/jaxb/JaxbProtocolUtils.java         |   42 +
 .../protocol/message/jaxb/ObjectFactory.java    |   45 +
 ....apache.nifi.authorization.AuthorityProvider |   16 +
 .../framework/cluster-protocol/.gitignore       |    1 +
 .../framework/cluster-protocol/pom.xml          |   69 +
 .../protocol/ClusterManagerProtocolSender.java  |   69 +
 .../cluster/protocol/ConnectionRequest.java     |   44 +
 .../cluster/protocol/ConnectionResponse.java    |  141 +
 .../apache/nifi/cluster/protocol/Heartbeat.java |   68 +
 .../nifi/cluster/protocol/NodeBulletins.java    |   44 +
 .../nifi/cluster/protocol/NodeIdentifier.java   |  172 +
 .../cluster/protocol/NodeProtocolSender.java    |   73 +
 .../nifi/cluster/protocol/ProtocolContext.java  |   39 +
 .../cluster/protocol/ProtocolException.java     |   40 +
 .../nifi/cluster/protocol/ProtocolHandler.java  |   44 +
 .../nifi/cluster/protocol/ProtocolListener.java |   72 +
 .../protocol/ProtocolMessageMarshaller.java     |   38 +
 .../protocol/ProtocolMessageUnmarshaller.java   |   38 +
 .../nifi/cluster/protocol/StandardDataFlow.java |  105 +
 .../UnknownServiceAddressException.java         |   39 +
 .../impl/ClusterManagerProtocolSenderImpl.java  |  245 +
 .../ClusterManagerProtocolSenderListener.java   |  118 +
 .../protocol/impl/ClusterServiceDiscovery.java  |  181 +
 .../protocol/impl/ClusterServiceLocator.java    |  229 +
 .../impl/ClusterServicesBroadcaster.java        |  182 +
 .../protocol/impl/CopyingInputStream.java       |   77 +
 .../impl/MulticastProtocolListener.java         |  204 +
 .../protocol/impl/NodeProtocolSenderImpl.java   |  171 +
 .../impl/NodeProtocolSenderListener.java        |  115 +
 .../protocol/impl/SocketProtocolListener.java   |  205 +
 .../protocol/jaxb/JaxbProtocolContext.java      |  148 +
 .../jaxb/message/AdaptedConnectionRequest.java  |   40 +
 .../jaxb/message/AdaptedConnectionResponse.java |  109 +
 .../protocol/jaxb/message/AdaptedCounter.java   |   56 +
 .../protocol/jaxb/message/AdaptedDataFlow.java  |   64 +
 .../protocol/jaxb/message/AdaptedHeartbeat.java |   66 +
 .../jaxb/message/AdaptedNodeBulletins.java      |   50 +
 .../jaxb/message/AdaptedNodeIdentifier.java     |   76 +
 .../jaxb/message/ConnectionRequestAdapter.java  |   41 +
 .../jaxb/message/ConnectionResponseAdapter.java |   55 +
 .../protocol/jaxb/message/DataFlowAdapter.java  |   50 +
 .../protocol/jaxb/message/HeartbeatAdapter.java |   54 +
 .../jaxb/message/JaxbProtocolUtils.java         |   42 +
 .../jaxb/message/NodeBulletinsAdapter.java      |   48 +
 .../jaxb/message/NodeIdentifierAdapter.java     |   51 +
 .../protocol/jaxb/message/ObjectFactory.java    |  104 +
 .../message/ConnectionRequestMessage.java       |   46 +
 .../message/ConnectionResponseMessage.java      |   66 +
 .../ControllerStartupFailureMessage.java        |   49 +
 .../protocol/message/DisconnectMessage.java     |   55 +
 .../protocol/message/ExceptionMessage.java      |   44 +
 .../protocol/message/FlowRequestMessage.java    |   46 +
 .../protocol/message/FlowResponseMessage.java   |   44 +
 .../protocol/message/HeartbeatMessage.java      |   43 +
 .../message/MulticastProtocolMessage.java       |   66 +
 .../protocol/message/NodeBulletinsMessage.java  |   43 +
 .../cluster/protocol/message/PingMessage.java   |   55 +
 .../message/PrimaryRoleAssignmentMessage.java   |   56 +
 .../protocol/message/ProtocolMessage.java       |   61 +
 .../message/ReconnectionFailureMessage.java     |   45 +
 .../message/ReconnectionRequestMessage.java     |   94 +
 .../message/ReconnectionResponseMessage.java    |   32 +
 .../message/ServiceBroadcastMessage.java        |   64 +
 .../MulticastConfigurationFactoryBean.java      |   60 +
 .../ServerSocketConfigurationFactoryBean.java   |   65 +
 .../spring/SocketConfigurationFactoryBean.java  |   66 +
 .../resources/nifi-cluster-protocol-context.xml |  110 +
 .../ClusterManagerProtocolSenderImplTest.java   |  134 +
 .../impl/ClusterServiceDiscoveryTest.java       |  133 +
 .../impl/ClusterServiceLocatorTest.java         |  121 +
 .../impl/ClusterServicesBroadcasterTest.java    |  133 +
 .../impl/MulticastProtocolListenerTest.java     |  171 +
 .../impl/NodeProtocolSenderImplTest.java        |  203 +
 .../impl/testutils/DelayedProtocolHandler.java  |   57 +
 .../testutils/ReflexiveProtocolHandler.java     |   47 +
 .../framework/cluster-web/.gitignore            |    1 +
 .../framework/cluster-web/pom.xml               |   50 +
 .../nifi/cluster/context/ClusterContext.java    |   59 +
 .../cluster/context/ClusterContextImpl.java     |   69 +
 .../context/ClusterContextThreadLocal.java      |   47 +
 .../ClusterAwareOptimisticLockingManager.java   |   96 +
 .../framework/cluster/.gitignore                |    1 +
 .../framework-bundle/framework/cluster/pom.xml  |  133 +
 .../cluster/client/MulticastTestClient.java     |  149 +
 .../org/apache/nifi/cluster/event/Event.java    |  122 +
 .../apache/nifi/cluster/event/EventManager.java |   65 +
 .../cluster/event/impl/EventManagerImpl.java    |  143 +
 .../cluster/firewall/ClusterNodeFirewall.java   |   35 +
 .../impl/FileBasedClusterNodeFirewall.java      |  207 +
 .../nifi/cluster/flow/ClusterDataFlow.java      |   45 +
 .../apache/nifi/cluster/flow/DaoException.java  |   40 +
 .../apache/nifi/cluster/flow/DataFlowDao.java   |   62 +
 .../cluster/flow/DataFlowManagementService.java |  115 +
 .../nifi/cluster/flow/PersistedFlowState.java   |   37 +
 .../nifi/cluster/flow/StaleFlowException.java   |   42 +
 .../nifi/cluster/flow/impl/DataFlowDaoImpl.java |  551 ++
 .../impl/DataFlowManagementServiceImpl.java     |  356 +
 .../nifi/cluster/manager/ClusterManager.java    |  225 +
 .../cluster/manager/HttpClusterManager.java     |  169 +
 .../cluster/manager/HttpRequestReplicator.java  |   99 +
 .../cluster/manager/HttpResponseMapper.java     |   42 +
 .../nifi/cluster/manager/NodeResponse.java      |  329 +
 .../exception/BlockedByFirewallException.java   |   60 +
 .../manager/exception/ClusterException.java     |   40 +
 .../ConnectingNodeMutableRequestException.java  |   41 +
 ...DisconnectedNodeMutableRequestException.java |   41 +
 .../exception/IllegalClusterStateException.java |   41 +
 .../exception/IllegalNodeDeletionException.java |   41 +
 .../IllegalNodeDisconnectionException.java      |   42 +
 .../IllegalNodeReconnectionException.java       |   41 +
 .../IneligiblePrimaryNodeException.java         |   41 +
 .../exception/MutableRequestException.java      |   42 +
 .../exception/NoConnectedNodesException.java    |   41 +
 .../exception/NoResponseFromNodesException.java |   42 +
 .../exception/NodeDisconnectionException.java   |   41 +
 .../exception/NodeReconnectionException.java    |   40 +
 .../PrimaryRoleAssignmentException.java         |   41 +
 .../SafeModeMutableRequestException.java        |   41 +
 .../manager/exception/UnknownNodeException.java |   41 +
 .../exception/UriConstructionException.java     |   42 +
 .../manager/impl/ClusteredEventAccess.java      |  135 +
 .../manager/impl/ClusteredReportingContext.java |  165 +
 .../manager/impl/HttpRequestReplicatorImpl.java |  531 ++
 .../manager/impl/HttpResponseMapperImpl.java    |   85 +
 .../cluster/manager/impl/WebClusterManager.java | 3616 +++++++
 .../java/org/apache/nifi/cluster/node/Node.java |  252 +
 ...anagerProtocolServiceLocatorFactoryBean.java |  116 +
 ...FileBasedClusterNodeFirewallFactoryBean.java |   58 +
 .../spring/WebClusterManagerFactoryBean.java    |  139 +
 .../reporting/ClusteredReportingTaskNode.java   |   49 +
 .../resources/nifi-cluster-manager-context.xml  |  124 +
 .../event/impl/EventManagerImplTest.java        |  119 +
 .../impl/FileBasedClusterNodeFirewallTest.java  |   99 +
 .../impl/DataFlowManagementServiceImplTest.java |  341 +
 .../impl/HttpRequestReplicatorImplTest.java     |  368 +
 .../impl/HttpResponseMapperImplTest.java        |  126 +
 .../manager/impl/TestWebClusterManager.java     |   52 +
 .../cluster/manager/testutils/HttpRequest.java  |  239 +
 .../cluster/manager/testutils/HttpResponse.java |   93 +
 .../manager/testutils/HttpResponseAction.java   |   60 +
 .../cluster/manager/testutils/HttpServer.java   |  240 +
 .../ClusterManagerProtocolSenderImplTest.java   |  133 +
 .../impl/ClusterServiceLocatorTest.java         |  119 +
 .../impl/ClusterServicesBroadcasterTest.java    |  131 +
 .../impl/MulticastProtocolListenerTest.java     |  170 +
 .../impl/NodeProtocolSenderImplTest.java        |  201 +
 .../impl/SocketProtocolListenerTest.java        |  132 +
 .../testutils/DelayedProtocolHandler.java       |   57 +
 .../testutils/ReflexiveProtocolHandler.java     |   47 +
 .../cluster/src/test/resources/logback-test.xml |   48 +
 .../apache/nifi/cluster/firewall/impl/empty.txt |    0
 .../apache/nifi/cluster/firewall/impl/ips.txt   |   12 +
 .../framework/core-api/.gitignore               |    1 +
 .../framework-bundle/framework/core-api/pom.xml |   60 +
 .../nifi/cluster/AdaptedNodeInformation.java    |   66 +
 .../nifi/cluster/ClusterNodeInformation.java    |   67 +
 .../org/apache/nifi/cluster/NodeInformant.java  |   22 +
 .../apache/nifi/cluster/NodeInformation.java    |   98 +
 .../nifi/cluster/NodeInformationAdapter.java    |   39 +
 .../apache/nifi/cluster/protocol/DataFlow.java  |   41 +
 .../apache/nifi/connectable/Connectable.java    |  291 +
 .../nifi/connectable/ConnectableType.java       |   44 +
 .../org/apache/nifi/connectable/Connection.java |   78 +
 .../org/apache/nifi/connectable/Funnel.java     |   24 +
 .../java/org/apache/nifi/connectable/Port.java  |   31 +
 .../org/apache/nifi/connectable/Position.java   |   36 +
 .../java/org/apache/nifi/connectable/Size.java  |   36 +
 .../controller/AbstractConfiguredComponent.java |  280 +
 .../apache/nifi/controller/AbstractPort.java    |  636 ++
 .../apache/nifi/controller/Availability.java    |   24 +
 .../nifi/controller/ConfiguredComponent.java    |   63 +
 .../nifi/controller/ContentAvailability.java    |   65 +
 .../org/apache/nifi/controller/Counter.java     |   32 +
 .../nifi/controller/EventBasedWorker.java       |   32 +
 .../org/apache/nifi/controller/Heartbeater.java |   22 +
 .../nifi/controller/ProcessScheduler.java       |  146 +
 .../apache/nifi/controller/ProcessorNode.java   |   80 +
 .../nifi/controller/ReportingTaskNode.java      |   56 +
 .../nifi/controller/StandardFlowFileQueue.java  | 1093 +++
 .../apache/nifi/controller/StandardFunnel.java  |  541 ++
 .../controller/ValidationContextFactory.java    |   27 +
 .../org/apache/nifi/controller/WorkerQueue.java |   36 +
 .../exception/CommunicationsException.java      |   40 +
 ...ControllerServiceAlreadyExistsException.java |   30 +
 .../ControllerServiceNotFoundException.java     |   51 +
 .../ProcessorInstantiationException.java        |   27 +
 .../exception/ProcessorLifeCycleException.java  |   30 +
 .../org/apache/nifi/controller/label/Label.java |   48 +
 .../ReportingTaskInstantiationException.java    |   31 +
 .../repository/ContentNotFoundException.java    |   48 +
 .../repository/CounterRepository.java           |   34 +
 .../controller/repository/FlowFileEvent.java    |   54 +
 .../repository/FlowFileEventRepository.java     |   50 +
 .../repository/RepositoryStatusReport.java      |   28 +
 .../service/ControllerServiceNode.java          |   40 +
 .../service/ControllerServiceProvider.java      |   47 +
 .../service/ControllerServiceReference.java     |   50 +
 .../org/apache/nifi/events/BulletinFactory.java |   52 +
 .../nifi/events/BulletinProcessingStrategy.java |   27 +
 .../apache/nifi/events/ComponentBulletin.java   |   30 +
 .../org/apache/nifi/events/SystemBulletin.java  |   30 +
 .../org/apache/nifi/groups/ProcessGroup.java    |  723 ++
 .../apache/nifi/groups/ProcessGroupCounts.java  |   66 +
 .../apache/nifi/groups/RemoteProcessGroup.java  |  253 +
 .../RemoteProcessGroupPortDescriptor.java       |   92 +
 .../org/apache/nifi/logging/LogMessage.java     |   73 +
 .../org/apache/nifi/logging/LogObserver.java    |   22 +
 .../org/apache/nifi/logging/LogRepository.java  |   67 +
 .../nifi/logging/LogRepositoryFactory.java      |   61 +
 .../java/org/apache/nifi/nar/NarCloseable.java  |   44 +
 .../nifi/nar/NarThreadContextClassLoader.java   |  188 +
 .../main/java/org/apache/nifi/remote/Peer.java  |  107 +
 .../java/org/apache/nifi/remote/PeerStatus.java |   72 +
 .../nifi/remote/PortAuthorizationResult.java    |   25 +
 .../nifi/remote/RemoteAuthorizationState.java   |   27 +
 .../org/apache/nifi/remote/RemoteGroupPort.java |   35 +
 .../org/apache/nifi/remote/RootGroupPort.java   |   78 +
 .../apache/nifi/remote/TransferDirection.java   |   23 +
 .../nifi/remote/VersionedRemoteResource.java    |   24 +
 .../apache/nifi/remote/codec/FlowFileCodec.java |   79 +
 .../remote/exception/BadRequestException.java   |   30 +
 .../remote/exception/HandshakeException.java    |   30 +
 .../exception/NotAuthorizedException.java       |   26 +
 .../exception/PortNotRunningException.java      |   26 +
 .../remote/exception/ProtocolException.java     |   34 +
 .../exception/RequestExpiredException.java      |   26 +
 .../remote/exception/UnknownPortException.java  |   26 +
 .../nifi/remote/protocol/ClientProtocol.java    |   78 +
 .../remote/protocol/CommunicationsInput.java    |   27 +
 .../remote/protocol/CommunicationsOutput.java   |   27 +
 .../remote/protocol/CommunicationsSession.java  |   64 +
 .../nifi/remote/protocol/RequestType.java       |   43 +
 .../nifi/remote/protocol/ServerProtocol.java    |  143 +
 .../framework-bundle/framework/core/.gitignore  |    1 +
 .../framework-bundle/framework/core/pom.xml     |  130 +
 .../apache/nifi/cluster/BulletinsPayload.java   |   95 +
 .../nifi/cluster/ConnectionException.java       |   42 +
 .../nifi/cluster/DisconnectionException.java    |   42 +
 .../apache/nifi/cluster/HeartbeatPayload.java   |  170 +
 .../org/apache/nifi/connectable/LocalPort.java  |  172 +
 .../nifi/connectable/StandardConnection.java    |  336 +
 .../nifi/controller/EventDrivenWorkerQueue.java |  329 +
 .../nifi/controller/FileSystemSwapManager.java  |  709 ++
 .../apache/nifi/controller/FlowController.java  | 3534 +++++++
 .../nifi/controller/FlowFromDOMFactory.java     |  418 +
 .../controller/FlowSerializationException.java  |   48 +
 .../apache/nifi/controller/FlowSerializer.java  |   42 +
 .../FlowSynchronizationException.java           |   47 +
 .../nifi/controller/FlowSynchronizer.java       |   53 +
 .../nifi/controller/FlowUnmarshaller.java       |   78 +
 .../apache/nifi/controller/SnippetManager.java  |   96 +
 .../apache/nifi/controller/StandardCounter.java |  108 +
 .../nifi/controller/StandardFlowSerializer.java |  404 +
 .../nifi/controller/StandardFlowService.java    |  875 ++
 .../controller/StandardFlowSynchronizer.java    | 1026 ++
 .../nifi/controller/StandardProcessorNode.java  | 1243 +++
 .../apache/nifi/controller/StandardSnippet.java |  186 +
 .../org/apache/nifi/controller/Template.java    |   37 +
 .../apache/nifi/controller/TemplateManager.java |  507 +
 .../controller/UninheritableFlowException.java  |   48 +
 .../exception/FlowFileConsumptionException.java |   38 +
 .../ReportingTaskInstantiationException.java    |   31 +
 .../exception/ValidationException.java          |   47 +
 .../nifi/controller/label/StandardLabel.java    |  110 +
 .../reporting/AbstractReportingTaskNode.java    |  111 +
 .../reporting/StandardReportingContext.java     |  132 +
 .../StandardReportingInitializationContext.java |   96 +
 .../reporting/StandardReportingTaskNode.java    |   40 +
 .../repository/BatchingSessionFactory.java      |  247 +
 .../repository/ConnectionSwapInfo.java          |   58 +
 .../repository/FileSystemRepository.java        | 1345 +++
 .../controller/repository/ProcessContext.java   |  291 +
 .../repository/ProvenanceEventEnricher.java     |   34 +
 .../repository/RepositoryPurgeException.java    |   59 +
 .../repository/RingBufferEventRepository.java   |  312 +
 .../repository/StandardCounterRepository.java   |  109 +
 .../repository/StandardFlowFileEvent.java       |  237 +
 .../repository/StandardFlowFileRecord.java      |  312 +
 .../repository/StandardProcessSession.java      | 2563 +++++
 .../StandardProcessSessionFactory.java          |   33 +
 .../repository/StandardProvenanceReporter.java  |  433 +
 .../repository/StandardRepositoryRecord.java    |  196 +
 .../StandardRepositoryStatusReport.java         |   88 +
 .../repository/VolatileContentRepository.java   |  642 ++
 .../repository/VolatileFlowFileRepository.java  |  109 +
 .../WriteAheadFlowFileRepository.java           |  861 ++
 .../repository/claim/ContentDirection.java      |   35 +
 .../repository/claim/StandardContentClaim.java  |  154 +
 .../claim/StandardContentClaimManager.java      |  155 +
 .../repository/io/ArrayManagedOutputStream.java |  245 +
 .../repository/io/ByteCountingInputStream.java  |  100 +
 .../repository/io/ByteCountingOutputStream.java |   64 +
 .../io/DisableOnCloseOutputStream.java          |   73 +
 .../io/FlowFileAccessInputStream.java           |  168 +
 .../io/FlowFileAccessOutputStream.java          |   95 +
 .../repository/io/LimitedInputStream.java       |  107 +
 .../controller/repository/io/LongHolder.java    |   48 +
 .../controller/repository/io/MemoryManager.java |   55 +
 .../repository/io/SyncOnCloseOutputStream.java  |   58 +
 .../scheduling/ConnectableProcessContext.java   |  173 +
 .../scheduling/EventDrivenSchedulingAgent.java  |  326 +
 .../scheduling/ProcessContextFactory.java       |   51 +
 .../scheduling/QuartzSchedulingAgent.java       |  220 +
 .../controller/scheduling/ScheduleState.java    |   90 +
 .../controller/scheduling/SchedulingAgent.java  |   45 +
 .../scheduling/StandardProcessScheduler.java    |  566 ++
 .../scheduling/TimerDrivenSchedulingAgent.java  |  139 +
 .../service/ControllerServiceLoader.java        |  156 +
 .../service/StandardConfigurationContext.java   |   64 +
 ...dControllerServiceInitializationContext.java |   64 +
 .../service/StandardControllerServiceNode.java  |  125 +
 .../StandardControllerServiceProvider.java      |  196 +
 .../StandardControllerServiceReference.java     |  100 +
 .../history/StandardMetricDescriptor.java       |  128 +
 .../status/history/StandardStatusHistory.java   |   54 +
 .../status/history/StandardStatusSnapshot.java  |   70 +
 .../status/history/StatusHistoryUtil.java       |  107 +
 .../VolatileComponentStatusRepository.java      |  649 ++
 .../tasks/ContinuallyRunConnectableTask.java    |   97 +
 .../tasks/ContinuallyRunProcessorTask.java      |  185 +
 .../nifi/controller/tasks/ExpireFlowFiles.java  |  114 +
 .../controller/tasks/ReportingTaskWrapper.java  |   63 +
 .../nifi/diagnostics/DiagnosticUtils.java       |   28 +
 .../nifi/diagnostics/GarbageCollection.java     |   60 +
 .../apache/nifi/diagnostics/StorageUsage.java   |   72 +
 .../nifi/diagnostics/SystemDiagnostics.java     |  212 +
 .../diagnostics/SystemDiagnosticsFactory.java   |  133 +
 .../nifi/encrypt/EncryptionException.java       |   43 +
 .../apache/nifi/encrypt/StringEncryptor.java    |  152 +
 .../java/org/apache/nifi/engine/FlowEngine.java |  120 +
 .../events/NodeBulletinProcessingStrategy.java  |   66 +
 .../nifi/events/VolatileBulletinRepository.java |  240 +
 .../events/network/CommunicationsFailure.java   |   36 +
 .../nifi/events/network/NetworkTransfer.java    |   48 +
 .../nifi/fingerprint/FingerprintException.java  |   41 +
 .../nifi/fingerprint/FingerprintFactory.java    |  983 ++
 .../nifi/groups/StandardProcessGroup.java       | 2015 ++++
 .../org/apache/nifi/jaxb/AdaptedBulletin.java   |  100 +
 .../org/apache/nifi/jaxb/AdaptedCounter.java    |   64 +
 .../org/apache/nifi/jaxb/BulletinAdapter.java   |   59 +
 .../org/apache/nifi/jaxb/CounterAdapter.java    |   51 +
 .../org/apache/nifi/lifecycle/LifeCycle.java    |   54 +
 .../nifi/lifecycle/LifeCycleException.java      |   48 +
 .../nifi/lifecycle/LifeCycleStartException.java |   49 +
 .../nifi/lifecycle/LifeCycleStopException.java  |   48 +
 .../nifi/logging/ProcessorLogObserver.java      |   48 +
 .../repository/StandardLogRepository.java       |  173 +
 .../nifi/persistence/FlowConfigurationDAO.java  |  135 +
 .../StandardSnippetDeserializer.java            |   42 +
 .../persistence/StandardSnippetSerializer.java  |   47 +
 .../StandardXMLFlowConfigurationDAO.java        |  345 +
 .../nifi/persistence/TemplateDeserializer.java  |   42 +
 .../nifi/persistence/TemplateSerializer.java    |   47 +
 .../nifi/processor/SimpleProcessLogger.java     |  307 +
 .../nifi/processor/StandardProcessContext.java  |  145 +
 .../StandardProcessorInitializationContext.java |   49 +
 .../nifi/processor/StandardPropertyValue.java   |  163 +
 .../processor/StandardSchedulingContext.java    |  107 +
 .../processor/StandardValidationContext.java    |   97 +
 .../StandardValidationContextFactory.java       |   39 +
 .../nifi/remote/StandardRemoteProcessGroup.java | 1612 ++++
 ...tandardRemoteProcessGroupPortDescriptor.java |  148 +
 .../org/apache/nifi/services/FlowService.java   |  139 +
 .../nifi/spring/FlowControllerFactoryBean.java  |  103 +
 .../spring/RingBufferEventRepositoryBean.java   |   45 +
 .../spring/StandardFlowServiceFactoryBean.java  |   98 +
 .../apache/nifi/util/ComponentStatusReport.java |  139 +
 .../java/org/apache/nifi/util/Connectables.java |   56 +
 .../java/org/apache/nifi/util/DomUtils.java     |   79 +
 .../org/apache/nifi/util/ReflectionUtils.java   |  149 +
 .../java/org/apache/nifi/util/SnippetUtils.java |  241 +
 .../ControllerServiceConfiguration.xsd          |   61 +
 .../src/main/resources/FlowConfiguration.xsd    |  335 +
 .../resources/ReportingTaskConfiguration.xsd    |   87 +
 .../core/src/main/resources/nifi-context.xml    |   49 +
 .../nifi/cluster/HeartbeatPayloadTest.java      |  121 +
 .../controller/StandardFlowServiceTest.java     |  300 +
 .../controller/TestFileSystemSwapManager.java   |  104 +
 .../repository/TestFileSystemRepository.java    |  352 +
 .../TestRingBufferEventRepository.java          |  138 +
 .../repository/TestStandardProcessSession.java  | 1018 ++
 .../TestStandardProvenanceReporter.java         |   65 +
 .../TestVolatileContentRepository.java          |  183 +
 .../TestWriteAheadFlowFileRepository.java       |  135 +
 .../repository/io/TestLimitedOutputStream.java  |   77 +
 .../controller/repository/util/DiskUtils.java   |   77 +
 .../fingerprint/FingerprintFactoryTest.java     |   60 +
 .../processor/TestStandardPropertyValue.java    |  167 +
 .../processors/DataGeneratorTestProcessor.java  |   85 +
 .../StubAttributeLoggerProcessor.java           |  111 +
 .../StubTerminationFileProcessor.java           |   40 +
 .../core/src/test/resources/conf/0bytes.xml     |    0
 .../test/resources/conf/all-flow-corrupt.xml    |  201 +
 .../resources/conf/all-flow-inheritable.xml     |  196 +
 .../resources/conf/all-flow-uninheritable.xml   |  202 +
 .../core/src/test/resources/conf/all-flow.xml   |  198 +
 .../src/test/resources/conf/nifi.properties     |  127 +
 .../test/resources/conf/only-termination.xml    |   37 +
 .../src/test/resources/conf/remote-flow.xml     |  145 +
 .../src/test/resources/conf/standard-flow.xml   |  196 +
 .../core/src/test/resources/conf/taskConfig.xml |   17 +
 .../test/resources/conf/termination-only.xml    |    0
 .../framework/core/src/test/resources/hello.txt |    1 +
 .../core/src/test/resources/logback-test.xml    |   36 +
 .../test/resources/nifi-with-remote.properties  |  127 +
 .../core/src/test/resources/nifi.properties     |  127 +
 .../test/resources/nifi/fingerprint/flow1a.xml  |  160 +
 .../test/resources/nifi/fingerprint/flow1b.xml  |  160 +
 .../test/resources/nifi/fingerprint/flow2.xml   |  160 +
 .../core/src/test/resources/old-swap-file.swap  |  Bin 0 -> 1730054 bytes
 .../framework-bundle/framework/nar/.gitignore   |    1 +
 .../framework-bundle/framework/nar/pom.xml      |   36 +
 .../org/apache/nifi/nar/ExtensionManager.java   |  188 +
 .../org/apache/nifi/nar/ExtensionMapping.java   |   73 +
 .../org/apache/nifi/nar/NarClassLoader.java     |  205 +
 .../org/apache/nifi/nar/NarClassLoaders.java    |  301 +
 .../java/org/apache/nifi/nar/NarUnpacker.java   |  351 +
 .../java/org/apache/nifi/util/FileUtils.java    |  187 +
 nar-bundles/framework-bundle/framework/pom.xml  |   50 +
 .../framework/resources/pom.xml                 |   49 +
 .../src/main/assembly/dependencies.xml          |   36 +
 .../resources/src/main/resources/DISCLAIMER     |   15 +
 .../resources/src/main/resources/LICENSE        |  202 +
 .../resources/src/main/resources/NOTICE         |    7 +
 .../resources/src/main/resources/bin/nifi.sh    |  350 +
 .../main/resources/conf/authority-providers.xml |   43 +
 .../main/resources/conf/authorized-users.xml    |   57 +
 .../main/resources/conf/controller-services.xml |   18 +
 .../src/main/resources/conf/logback.xml         |  114 +
 .../src/main/resources/conf/nifi.properties     |  159 +
 .../src/main/resources/conf/reporting-tasks.xml |   49 +
 .../resources/src/main/resources/docs/README.md |   65 +
 .../framework/runtime/.gitignore                |    2 +
 .../framework-bundle/framework/runtime/pom.xml  |   36 +
 .../src/main/java/org/apache/nifi/NiFi.java     |  178 +
 .../main/java/org/apache/nifi/NiFiServer.java   |   31 +
 .../framework/security/.gitignore               |    1 +
 .../framework-bundle/framework/security/pom.xml |   42 +
 .../util/SslContextCreationException.java       |   40 +
 .../security/util/SslContextFactory.java        |  119 +
 .../framework/security/util/SslException.java   |   40 +
 .../security/util/SslServerSocketFactory.java   |   81 +
 ...SslServerSocketFactoryCreationException.java |   40 +
 .../security/util/SslSocketFactory.java         |   91 +
 .../util/SslSocketFactoryCreationException.java |   40 +
 .../security/util/SslContextFactoryTest.java    |   69 +
 .../src/test/resources/localhost-ks.jks         |  Bin 0 -> 1298 bytes
 .../src/test/resources/localhost-ts.jks         |  Bin 0 -> 891 bytes
 .../src/test/resources/log4j.properties         |   21 +
 .../framework/site-to-site/.gitignore           |    1 +
 .../framework/site-to-site/pom.xml              |   80 +
 .../util/RemoteProcessGroupUtils.java           |  216 +
 .../remote/AbstractCommunicationsSession.java   |   54 +
 .../nifi/remote/RemoteResourceFactory.java      |  202 +
 .../nifi/remote/RemoteResourceManager.java      |  227 +
 .../apache/nifi/remote/RemoteSiteListener.java  |   33 +
 .../nifi/remote/SocketRemoteSiteListener.java   |  332 +
 .../nifi/remote/StandardRemoteGroupPort.java    |  764 ++
 .../nifi/remote/StandardRootGroupPort.java      |  629 ++
 .../remote/codec/StandardFlowFileCodec.java     |  169 +
 .../exception/UnsupportedCodecException.java    |   31 +
 .../SocketChannelCommunicationsSession.java     |   90 +
 .../remote/io/socket/SocketChannelInput.java    |   66 +
 .../remote/io/socket/SocketChannelOutput.java   |   58 +
 .../SSLSocketChannelCommunicationsSession.java  |   93 +
 .../io/socket/ssl/SSLSocketChannelInput.java    |   50 +
 .../io/socket/ssl/SSLSocketChannelOutput.java   |   44 +
 .../socket/ClusterManagerServerProtocol.java    |  208 +
 .../protocol/socket/HandshakeProperty.java      |   23 +
 .../nifi/remote/protocol/socket/Response.java   |   51 +
 .../remote/protocol/socket/ResponseCode.java    |  152 +
 .../protocol/socket/SocketClientProtocol.java   |  510 +
 .../socket/SocketFlowFileServerProtocol.java    |  581 ++
 .../org.apache.nifi.remote.codec.FlowFileCodec  |   15 +
 ...g.apache.nifi.remote.protocol.ClientProtocol |   15 +
 ...g.apache.nifi.remote.protocol.ServerProtocol |   16 +
 .../remote/TestStandardRemoteGroupPort.java     |   97 +
 .../remote/TestStandardSiteToSiteProtocol.java  |  116 +
 .../io/socket/TestSocketChannelStreams.java     |  231 +
 .../io/socket/ssl/TestSSLSocketChannel.java     |  381 +
 .../test/resources/dummy-certs/localhost-ks.jks |  Bin 0 -> 1298 bytes
 .../test/resources/dummy-certs/localhost-ts.jks |  Bin 0 -> 891 bytes
 .../src/test/resources/logback-test.xml         |   30 +
 .../src/test/resources/nifi.properties          |  111 +
 .../framework/user-actions/.gitignore           |    1 +
 .../framework/user-actions/pom.xml              |   27 +
 .../java/org/apache/nifi/action/Action.java     |  121 +
 .../java/org/apache/nifi/action/Component.java  |   31 +
 .../java/org/apache/nifi/action/Operation.java  |   36 +
 .../component/details/ComponentDetails.java     |   26 +
 .../component/details/ProcessorDetails.java     |   34 +
 .../details/RemoteProcessGroupDetails.java      |   34 +
 .../nifi/action/details/ActionDetails.java      |   26 +
 .../nifi/action/details/ConfigureDetails.java   |   52 +
 .../nifi/action/details/ConnectDetails.java     |   90 +
 .../apache/nifi/action/details/MoveDetails.java |   61 +
 .../nifi/action/details/PurgeDetails.java       |   41 +
 .../web/custom-ui-utilities/.gitignore          |    1 +
 .../framework/web/custom-ui-utilities/pom.xml   |   36 +
 .../web/HttpServletRequestContextConfig.java    |  118 +
 .../framework/web/nifi-jetty/.gitignore         |    1 +
 .../framework/web/nifi-jetty/pom.xml            |  139 +
 .../src/main/assembly/distribution.xml          |   42 +
 .../org/apache/nifi/web/server/JettyServer.java |  682 ++
 .../server/ServerConfigurationException.java    |   36 +
 .../org/apache/nifi/web/webdefault.xml          |  556 ++
 .../framework/web/nifi-web-api/.gitignore       |    1 +
 .../web/nifi-web-api/nb-configuration.xml       |   18 +
 .../framework/web/nifi-web-api/pom.xml          |  302 +
 .../nifi-web-api/src/main/enunciate/default.css |  266 +
 .../src/main/enunciate/enunciate.xml            |   34 +
 .../src/main/enunciate/images/bgcode.gif        |  Bin 0 -> 56 bytes
 .../src/main/enunciate/images/bgcontainer.png   |  Bin 0 -> 386 bytes
 .../src/main/enunciate/images/bgul.gif          |  Bin 0 -> 304 bytes
 .../src/main/enunciate/images/header.png        |  Bin 0 -> 51928 bytes
 .../src/main/enunciate/images/li.png            |  Bin 0 -> 191 bytes
 .../src/main/enunciate/images/quote.gif         |  Bin 0 -> 228 bytes
 .../src/main/enunciate/images/search.gif        |  Bin 0 -> 680 bytes
 .../org/apache/nifi/aop/MethodProfiler.java     |   45 +
 .../apache/nifi/audit/ControllerAuditor.java    |  257 +
 .../org/apache/nifi/audit/FunnelAuditor.java    |  135 +
 .../java/org/apache/nifi/audit/NiFiAuditor.java |  119 +
 .../java/org/apache/nifi/audit/PortAuditor.java |  334 +
 .../apache/nifi/audit/ProcessGroupAuditor.java  |  263 +
 .../org/apache/nifi/audit/ProcessorAuditor.java |  408 +
 .../apache/nifi/audit/RelationshipAuditor.java  |  412 +
 .../nifi/audit/RemoteProcessGroupAuditor.java   |  376 +
 .../org/apache/nifi/audit/SnippetAuditor.java   |  519 +
 .../nifi/web/ClusterRequestException.java       |   38 +
 .../IllegalClusterResourceRequestException.java |   33 +
 .../org/apache/nifi/web/NiFiCoreException.java  |   32 +
 .../org/apache/nifi/web/NiFiServiceFacade.java  | 1263 +++
 .../apache/nifi/web/NiFiServiceFacadeLock.java  |  177 +
 .../nifi/web/StandardNiFiServiceFacade.java     | 2877 ++++++
 .../apache/nifi/web/StandardNiFiWebContext.java |  336 +
 .../nifi/web/api/ApplicationResource.java       |  399 +
 .../nifi/web/api/BulletinBoardResource.java     |  116 +
 .../apache/nifi/web/api/ClusterResource.java    |  724 ++
 .../apache/nifi/web/api/ConnectionResource.java |  771 ++
 .../apache/nifi/web/api/ControllerResource.java |  803 ++
 .../org/apache/nifi/web/api/FunnelResource.java |  493 +
 .../apache/nifi/web/api/HistoryResource.java    |  271 +
 .../apache/nifi/web/api/InputPortResource.java  |  531 ++
 .../org/apache/nifi/web/api/LabelResource.java  |  547 ++
 .../org/apache/nifi/web/api/NodeResource.java   |  302 +
 .../apache/nifi/web/api/OutputPortResource.java |  532 ++
 .../nifi/web/api/ProcessGroupResource.java      | 1102 +++
 .../apache/nifi/web/api/ProcessorResource.java  |  693 ++
 .../apache/nifi/web/api/ProvenanceResource.java | 1068 +++
 .../web/api/RemoteProcessGroupResource.java     |  912 ++
 .../apache/nifi/web/api/SnippetResource.java    |  601 ++
 .../nifi/web/api/SystemDiagnosticsResource.java |   81 +
 .../apache/nifi/web/api/TemplateResource.java   |  400 +
 .../apache/nifi/web/api/UserGroupResource.java  |  383 +
 .../org/apache/nifi/web/api/UserResource.java   |  469 +
 .../api/config/AccessDeniedExceptionMapper.java |   54 +
 .../config/AccountNotFoundExceptionMapper.java  |   47 +
 .../config/AdministrationExceptionMapper.java   |   48 +
 ...ationCredentialsNotFoundExceptionMapper.java |   48 +
 .../web/api/config/ClusterExceptionMapper.java  |   47 +
 ...ectingNodeMutableRequestExceptionMapper.java |   49 +
 ...nectedNodeMutableRequestExceptionMapper.java |   49 +
 .../config/IllegalArgumentExceptionMapper.java  |   46 +
 ...alClusterResourceRequestExceptionMapper.java |   47 +
 .../IllegalClusterStateExceptionMapper.java     |   47 +
 .../IllegalNodeDeletionExceptionMapper.java     |   46 +
 ...IllegalNodeDisconnectionExceptionMapper.java |   46 +
 .../IllegalNodeReconnectionExceptionMapper.java |   46 +
 .../api/config/IllegalStateExceptionMapper.java |   46 +
 .../IneligiblePrimaryNodeExceptionMapper.java   |   47 +
 .../config/InvalidRevisionExceptionMapper.java  |   47 +
 .../api/config/JsonMappingExceptionMapper.java  |   46 +
 .../api/config/JsonParseExceptionMapper.java    |   46 +
 .../config/MutableRequestExceptionMapper.java   |   48 +
 .../web/api/config/NiFiCoreExceptionMapper.java |   47 +
 .../config/NoConnectedNodesExceptionMapper.java |   47 +
 .../NoResponseFromNodesExceptionMapper.java     |   49 +
 .../NodeDisconnectionExceptionMapper.java       |   47 +
 .../config/NodeReconnectionExceptionMapper.java |   47 +
 .../PrimaryRoleAssignmentExceptionMapper.java   |   47 +
 .../config/ResourceNotFoundExceptionMapper.java |   48 +
 .../SafeModeMutableRequestExceptionMapper.java  |   48 +
 .../nifi/web/api/config/ThrowableMapper.java    |   46 +
 .../api/config/UnknownNodeExceptionMapper.java  |   47 +
 .../api/config/ValidationExceptionMapper.java   |   49 +
 .../config/WebApplicationExceptionMapper.java   |   63 +
 .../org/apache/nifi/web/api/dto/DtoFactory.java | 2141 +++++
 .../org/apache/nifi/web/api/package-info.java   |   58 +
 .../request/BulletinBoardPatternParameter.java  |   47 +
 .../nifi/web/api/request/ClientIdParameter.java |   45 +
 .../api/request/ConnectableTypeParameter.java   |   41 +
 .../nifi/web/api/request/DateTimeParameter.java |   62 +
 .../nifi/web/api/request/DoubleParameter.java   |   40 +
 .../nifi/web/api/request/IntegerParameter.java  |   40 +
 .../nifi/web/api/request/LongParameter.java     |   40 +
 .../ApplicationStartupContextListener.java      |  157 +
 .../nifi/web/controller/ControllerFacade.java   | 1339 +++
 .../web/controller/StandardSearchContext.java   |   80 +
 .../org/apache/nifi/web/dao/ConnectionDAO.java  |  112 +
 .../java/org/apache/nifi/web/dao/FunnelDAO.java |   88 +
 .../java/org/apache/nifi/web/dao/LabelDAO.java  |   79 +
 .../java/org/apache/nifi/web/dao/PortDAO.java   |   96 +
 .../apache/nifi/web/dao/ProcessGroupDAO.java    |   89 +
 .../org/apache/nifi/web/dao/ProcessorDAO.java   |   97 +
 .../nifi/web/dao/RemoteProcessGroupDAO.java     |  135 +
 .../org/apache/nifi/web/dao/SnippetDAO.java     |   92 +
 .../org/apache/nifi/web/dao/TemplateDAO.java    |   77 +
 .../apache/nifi/web/dao/impl/ComponentDAO.java  |   72 +
 .../web/dao/impl/StandardConnectionDAO.java     |  519 +
 .../nifi/web/dao/impl/StandardFunnelDAO.java    |  180 +
 .../nifi/web/dao/impl/StandardInputPortDAO.java |  309 +
 .../nifi/web/dao/impl/StandardLabelDAO.java     |  184 +
 .../web/dao/impl/StandardOutputPortDAO.java     |  309 +
 .../web/dao/impl/StandardProcessGroupDAO.java   |  171 +
 .../nifi/web/dao/impl/StandardProcessorDAO.java |  503 +
 .../dao/impl/StandardRemoteProcessGroupDAO.java |  402 +
 .../nifi/web/dao/impl/StandardSnippetDAO.java   |  344 +
 .../nifi/web/dao/impl/StandardTemplateDAO.java  |  141 +
 .../nifi/web/filter/NodeRequestFilter.java      |  130 +
 .../apache/nifi/web/filter/RequestLogger.java   |   78 +
 .../nifi/web/filter/ThreadLocalFilter.java      |   54 +
 .../org/apache/nifi/web/filter/TimerFilter.java |   70 +
 .../nifi/web/util/ClientResponseUtils.java      |   48 +
 .../nifi/web/util/DownloadableContent.java      |   47 +
 .../org/apache/nifi/web/util/SnippetUtils.java  |  426 +
 .../src/main/resources/nifi-web-api-context.xml |  302 +
 .../src/main/webapp/WEB-INF/web.xml             |   99 +
 .../apache/nifi/integration/NiFiWebApiTest.java |  274 +
 .../accesscontrol/AdminAccessControlTest.java   | 1090 +++
 .../accesscontrol/DfmAccessControlTest.java     | 1386 +++
 .../ReadOnlyAccessControlTest.java              | 1064 +++
 .../util/NiFiTestAuthorizationProvider.java     |  172 +
 .../nifi/integration/util/NiFiTestServer.java   |  235 +
 .../nifi/integration/util/NiFiTestUser.java     |  257 +
 .../integration/util/SourceTestProcessor.java   |   49 +
 .../util/TerminationTestProcessor.java          |   44 +
 .../nifi/integration/util/TestPrioritizer.java  |   31 +
 ....apache.nifi.authorization.AuthorityProvider |   15 +
 ...org.apache.nifi.flowfile.FlowFilePrioritizer |   15 +
 .../org.apache.nifi.processor.Processor         |   16 +
 .../access-control/authority-providers.xml      |   24 +
 .../access-control/controller-services.xml      |   18 +
 .../resources/access-control/localhost-ks.jks   |  Bin 0 -> 2246 bytes
 .../resources/access-control/localhost-ts.jks   |  Bin 0 -> 957 bytes
 .../resources/access-control/nifi.properties    |  136 +
 .../access-control/reporting-tasks.xml          |   17 +
 .../src/test/resources/logback-test.xml         |   36 +
 .../framework/web/nifi-web-docs/.gitignore      |    1 +
 .../framework/web/nifi-web-docs/pom.xml         |   57 +
 .../nifi/web/docs/DocumentationController.java  |   88 +
 .../main/webapp/WEB-INF/jsp/documentation.jsp   |  114 +
 .../WEB-INF/jsp/no-documentation-found.jsp      |   31 +
 .../src/main/webapp/WEB-INF/web.xml             |   33 +
 .../src/main/webapp/css/component-usage.css     |   71 +
 .../nifi-web-docs/src/main/webapp/css/main.css  |  203 +
 .../src/main/webapp/images/bgBannerFoot.png     |  Bin 0 -> 189 bytes
 .../src/main/webapp/images/bgHeader.png         |  Bin 0 -> 1697 bytes
 .../src/main/webapp/images/bgTableHeader.png    |  Bin 0 -> 232 bytes
 .../src/main/webapp/js/application.js           |  275 +
 .../framework/web/nifi-web-error/.gitignore     |    1 +
 .../framework/web/nifi-web-error/pom.xml        |   48 +
 .../apache/nifi/web/filter/CatchAllFilter.java  |   45 +
 .../src/main/webapp/WEB-INF/web.xml             |   26 +
 .../nifi-web-error/src/main/webapp/index.jsp    |   36 +
 .../framework/web/nifi-web-ui/.gitignore        |    1 +
 .../framework/web/nifi-web-ui/pom.xml           |  655 ++
 .../apache/nifi/web/filter/IeEdgeHeader.java    |   57 +
 .../org/apache/nifi/web/servlet/ConvertSvg.java |  115 +
 .../filters/bulletin-board-min.properties       |   18 +
 .../resources/filters/bulletin-board.properties |   25 +
 .../resources/filters/canvas-min.properties     |   18 +
 .../main/resources/filters/canvas.properties    |   69 +
 .../resources/filters/cluster-min.properties    |   18 +
 .../main/resources/filters/cluster.properties   |   26 +
 .../resources/filters/counters-min.properties   |   18 +
 .../main/resources/filters/counters.properties  |   26 +
 .../resources/filters/history-min.properties    |   18 +
 .../main/resources/filters/history.properties   |   27 +
 .../resources/filters/provenance-min.properties |   18 +
 .../resources/filters/provenance.properties     |   26 +
 .../resources/filters/summary-min.properties    |   18 +
 .../main/resources/filters/summary.properties   |   32 +
 .../resources/filters/templates-min.properties  |   18 +
 .../main/resources/filters/templates.properties |   26 +
 .../main/resources/filters/users-min.properties |   18 +
 .../src/main/resources/filters/users.properties |   26 +
 .../webapp/WEB-INF/pages/bulletin-board.jsp     |   49 +
 .../src/main/webapp/WEB-INF/pages/canvas.jsp    |  118 +
 .../src/main/webapp/WEB-INF/pages/cluster.jsp   |   61 +
 .../src/main/webapp/WEB-INF/pages/counters.jsp  |   60 +
 .../src/main/webapp/WEB-INF/pages/history.jsp   |   64 +
 .../main/webapp/WEB-INF/pages/message-page.jsp  |   34 +
 .../main/webapp/WEB-INF/pages/provenance.jsp    |   67 +
 .../src/main/webapp/WEB-INF/pages/summary.jsp   |   72 +
 .../src/main/webapp/WEB-INF/pages/templates.jsp |   62 +
 .../src/main/webapp/WEB-INF/pages/users.jsp     |   70 +
 .../webapp/WEB-INF/partials/banners-main.jsp    |   19 +
 .../webapp/WEB-INF/partials/banners-utility.jsp |   19 +
 .../bulletin-board/bulletin-board-content.jsp   |   40 +
 .../WEB-INF/partials/canvas/about-dialog.jsp    |   29 +
 .../WEB-INF/partials/canvas/canvas-header.jsp   |   55 +
 .../canvas/connection-configuration.jsp         |  180 +
 .../partials/canvas/connections-dialog.jsp      |   35 +
 .../partials/canvas/fill-color-dialog.jsp       |   42 +
 .../WEB-INF/partials/canvas/flow-status.jsp     |   55 +
 .../canvas/instantiate-template-dialog.jsp      |   22 +
 .../partials/canvas/label-configuration.jsp     |   38 +
 .../WEB-INF/partials/canvas/navigation.jsp      |   57 +
 .../WEB-INF/partials/canvas/new-port-dialog.jsp |   27 +
 .../canvas/new-process-group-dialog.jsp         |   27 +
 .../partials/canvas/new-processor-dialog.jsp    |   50 +
 .../canvas/new-processor-property-dialog.jsp    |   34 +
 .../canvas/new-remote-process-group-dialog.jsp  |   27 +
 .../partials/canvas/new-template-dialog.jsp     |   33 +
 .../partials/canvas/port-configuration.jsp      |   54 +
 .../WEB-INF/partials/canvas/port-details.jsp    |   39 +
 .../canvas/process-group-configuration.jsp      |   34 +
 .../partials/canvas/process-group-details.jsp   |   33 +
 .../partials/canvas/processor-configuration.jsp |  209 +
 .../WEB-INF/partials/canvas/registration.jsp    |   44 +
 .../canvas/remote-port-configuration.jsp        |   42 +
 .../remote-process-group-configuration.jsp      |   50 +
 .../canvas/remote-process-group-details.jsp     |   48 +
 .../canvas/remote-process-group-ports.jsp       |   47 +
 .../canvas/secure-port-configuration.jsp        |   81 +
 .../partials/canvas/secure-port-details.jsp     |   67 +
 .../partials/canvas/settings-content.jsp        |   60 +
 .../webapp/WEB-INF/partials/canvas/shell.jsp    |   27 +
 .../partials/cluster/cluster-content.jsp        |   39 +
 .../partials/cluster/node-details-dialog.jsp    |   42 +
 .../WEB-INF/partials/connection-details.jsp     |  123 +
 .../partials/counters/counters-content.jsp      |   39 +
 .../partials/history/action-details-dialog.jsp  |   27 +
 .../partials/history/history-content.jsp        |   36 +
 .../partials/history/history-filter-dialog.jsp  |   73 +
 .../partials/history/history-purge-dialog.jsp   |   42 +
 .../webapp/WEB-INF/partials/message-pane.jsp    |   23 +
 .../main/webapp/WEB-INF/partials/ok-dialog.jsp  |   22 +
 .../WEB-INF/partials/processor-details.jsp      |  158 +
 .../provenance/lineage-query-dialog.jsp         |   26 +
 .../partials/provenance/provenance-content.jsp  |   73 +
 .../provenance-event-details-dialog.jsp         |  196 +
 .../provenance/provenance-query-dialog.jsp      |   26 +
 .../provenance/provenance-search-dialog.jsp     |  101 +
 .../WEB-INF/partials/status-history-dialog.jsp  |   37 +
 .../cluster-connection-summary-dialog.jsp       |   36 +
 .../cluster-input-port-summary-dialog.jsp       |   36 +
 .../cluster-output-port-summary-dialog.jsp      |   36 +
 .../cluster-processor-summary-dialog.jsp        |   36 +
 ...ster-remote-process-group-summary-dialog.jsp |   36 +
 .../partials/summary/summary-content.jsp        |   64 +
 .../summary/system-diagnostics-dialog.jsp       |  131 +
 .../summary/view-single-node-dialog.jsp         |   23 +
 .../partials/templates/templates-content.jsp    |   59 +
 .../partials/users/group-revoke-dialog.jsp      |   22 +
 .../partials/users/group-roles-dialog.jsp       |   52 +
 .../partials/users/user-delete-dialog.jsp       |   23 +
 .../partials/users/user-details-dialog.jsp      |   56 +
 .../partials/users/user-group-dialog.jsp        |   27 +
 .../partials/users/user-revoke-dialog.jsp       |   23 +
 .../partials/users/user-roles-dialog.jsp        |   60 +
 .../WEB-INF/partials/users/users-content.jsp    |   46 +
 .../webapp/WEB-INF/partials/yes-no-dialog.jsp   |   22 +
 .../nifi-web-ui/src/main/webapp/WEB-INF/web.xml |  120 +
 .../nifi-web-ui/src/main/webapp/css/about.css   |   54 +
 .../nifi-web-ui/src/main/webapp/css/banner.css  |   80 +
 .../src/main/webapp/css/bulletin-board.css      |  238 +
 .../nifi-web-ui/src/main/webapp/css/canvas.css  |   41 +
 .../nifi-web-ui/src/main/webapp/css/cluster.css |  148 +
 .../webapp/css/connection-configuration.css     |  168 +
 .../src/main/webapp/css/connection-details.css  |   77 +
 .../src/main/webapp/css/counters.css            |  134 +
 .../nifi-web-ui/src/main/webapp/css/dialog.css  |  351 +
 .../src/main/webapp/css/flow-status.css         |  110 +
 .../nifi-web-ui/src/main/webapp/css/graph.css   |  265 +
 .../nifi-web-ui/src/main/webapp/css/header.css  |  676 ++
 .../nifi-web-ui/src/main/webapp/css/history.css |  216 +
 .../src/main/webapp/css/label-configuration.css |   55 +
 .../nifi-web-ui/src/main/webapp/css/main.css    |  279 +
 .../src/main/webapp/css/message-page.css        |   30 +
 .../src/main/webapp/css/message-pane.css        |   44 +
 .../src/main/webapp/css/navigation.css          |  292 +
 .../main/webapp/css/new-processor-dialog.css    |  168 +
 .../src/main/webapp/css/port-configuration.css  |  180 +
 .../src/main/webapp/css/port-details.css        |   55 +
 .../webapp/css/process-group-configuration.css  |   40 +
 .../main/webapp/css/process-group-details.css   |   27 +
 .../main/webapp/css/processor-configuration.css |  366 +
 .../src/main/webapp/css/processor-details.css   |  119 +
 .../src/main/webapp/css/provenance.css          |  644 ++
 .../src/main/webapp/css/registration.css        |   53 +
 .../css/remote-process-group-configuration.css  |  233 +
 .../nifi-web-ui/src/main/webapp/css/reset.css   |   43 +
 .../src/main/webapp/css/settings.css            |   66 +
 .../nifi-web-ui/src/main/webapp/css/shell.css   |   98 +
 .../src/main/webapp/css/status-history.css      |  199 +
 .../nifi-web-ui/src/main/webapp/css/summary.css |  757 ++
 .../src/main/webapp/css/templates.css           |  229 +
 .../nifi-web-ui/src/main/webapp/css/users.css   |  254 +
 .../src/main/webapp/images/addConnect.png       |  Bin 0 -> 1996 bytes
 .../src/main/webapp/images/bg-error.png         |  Bin 0 -> 90275 bytes
 .../src/main/webapp/images/bgBannerFoot.png     |  Bin 0 -> 189 bytes
 .../src/main/webapp/images/bgBannerHead.png     |  Bin 0 -> 422 bytes
 .../src/main/webapp/images/bgBreadcrumbs.png    |  Bin 0 -> 2130 bytes
 .../src/main/webapp/images/bgButton.png         |  Bin 0 -> 234 bytes
 .../src/main/webapp/images/bgButtonOver.png     |  Bin 0 -> 234 bytes
 .../src/main/webapp/images/bgButtonSelected.png |  Bin 0 -> 166 bytes
 .../main/webapp/images/bgButtonSelectedOver.png |  Bin 0 -> 168 bytes
 .../src/main/webapp/images/bgContextMenu.png    |  Bin 0 -> 746 bytes
 .../src/main/webapp/images/bgControlsInset.png  |  Bin 0 -> 618 bytes
 .../src/main/webapp/images/bgHeader.png         |  Bin 0 -> 1697 bytes
 .../src/main/webapp/images/bgInputText.png      |  Bin 0 -> 139 bytes
 .../src/main/webapp/images/bgNifiLogo.png       |  Bin 0 -> 1682 bytes
 .../src/main/webapp/images/bgNifiToolbar.png    |  Bin 0 -> 2123 bytes
 .../main/webapp/images/bgNifiToolbarEdge.png    |  Bin 0 -> 541 bytes
 .../src/main/webapp/images/bgOutline.png        |  Bin 0 -> 585 bytes
 .../src/main/webapp/images/bgPanCenter.png      |  Bin 0 -> 362 bytes
 .../src/main/webapp/images/bgPanZoom.png        |  Bin 0 -> 832 bytes
 .../webapp/images/bgProcessGroupDetailsArea.png |  Bin 0 -> 6596 bytes
 .../main/webapp/images/bgProcessorStatArea.png  |  Bin 0 -> 4062 bytes
 .../images/bgRemoteProcessGroupDetailsArea.png  |  Bin 0 -> 4433 bytes
 .../src/main/webapp/images/bgSearchInput.png    |  Bin 0 -> 221 bytes
 .../src/main/webapp/images/bgShellClose.png     |  Bin 0 -> 169 bytes
 .../src/main/webapp/images/bgStatusPanel.png    |  Bin 0 -> 229 bytes
 .../src/main/webapp/images/bgTabContainer.png   |  Bin 0 -> 234 bytes
 .../src/main/webapp/images/bgTableHeader.png    |  Bin 0 -> 232 bytes
 .../main/webapp/images/bgToolbarBtnBorder.png   |  Bin 0 -> 227 bytes
 .../src/main/webapp/images/blueBtnBg-over.jpg   |  Bin 0 -> 356 bytes
 .../src/main/webapp/images/blueBtnBg.jpg        |  Bin 0 -> 356 bytes
 .../src/main/webapp/images/buttonColor.png      |  Bin 0 -> 1679 bytes
 .../src/main/webapp/images/buttonCopy.png       |  Bin 0 -> 1166 bytes
 .../src/main/webapp/images/buttonDelete.png     |  Bin 0 -> 1837 bytes
 .../src/main/webapp/images/buttonDisable.png    |  Bin 0 -> 1737 bytes
 .../src/main/webapp/images/buttonEnable.png     |  Bin 0 -> 1375 bytes
 .../src/main/webapp/images/buttonGroup.png      |  Bin 0 -> 880 bytes
 .../main/webapp/images/buttonNewProperty.png    |  Bin 0 -> 590 bytes
 .../src/main/webapp/images/buttonOutline.png    |  Bin 0 -> 495 bytes
 .../src/main/webapp/images/buttonPanDown.png    |  Bin 0 -> 554 bytes
 .../src/main/webapp/images/buttonPanLeft.png    |  Bin 0 -> 588 bytes
 .../src/main/webapp/images/buttonPanRight.png   |  Bin 0 -> 530 bytes
 .../src/main/webapp/images/buttonPanUp.png      |  Bin 0 -> 551 bytes
 .../src/main/webapp/images/buttonPaste.png      |  Bin 0 -> 1372 bytes
 .../src/main/webapp/images/buttonRefresh.png    |  Bin 0 -> 915 bytes
 .../src/main/webapp/images/buttonRun.png        |  Bin 0 -> 1163 bytes
 .../src/main/webapp/images/buttonStop.png       |  Bin 0 -> 869 bytes
 .../src/main/webapp/images/buttonTemplate.png   |  Bin 0 -> 1290 bytes
 .../src/main/webapp/images/buttonZoom100.png    |  Bin 0 -> 449 bytes
 .../src/main/webapp/images/buttonZoomFit.png    |  Bin 0 -> 499 bytes
 .../src/main/webapp/images/buttonZoomIn.png     |  Bin 0 -> 435 bytes
 .../src/main/webapp/images/buttonZoomOut.png    |  Bin 0 -> 339 bytes
 .../src/main/webapp/images/cluster.png          |  Bin 0 -> 326 bytes
 .../src/main/webapp/images/grayBtnBg-over.jpg   |  Bin 0 -> 319 bytes
 .../src/main/webapp/images/grayBtnBg.jpg        |  Bin 0 -> 317 bytes
 .../nifi-web-ui/src/main/webapp/images/grid.gif |  Bin 0 -> 135 bytes
 .../src/main/webapp/images/headerTabBg.gif      |  Bin 0 -> 131 bytes
 .../src/main/webapp/images/iconAdminUser.png    |  Bin 0 -> 1960 bytes
 .../src/main/webapp/images/iconAlert.png        |  Bin 0 -> 1396 bytes
 .../src/main/webapp/images/iconAlertDialog.png  |  Bin 0 -> 1241 bytes
 .../src/main/webapp/images/iconAutoRefresh.png  |  Bin 0 -> 3102 bytes
 .../src/main/webapp/images/iconBulletin.png     |  Bin 0 -> 1066 bytes
 .../main/webapp/images/iconBulletinBoard.png    |  Bin 0 -> 2523 bytes
 .../src/main/webapp/images/iconCenterView.png   |  Bin 0 -> 338 bytes
 .../src/main/webapp/images/iconChart.png        |  Bin 0 -> 510 bytes
 .../src/main/webapp/images/iconClose.png        |  Bin 0 -> 231 bytes
 .../src/main/webapp/images/iconCluster.png      |  Bin 0 -> 2112 bytes
 .../src/main/webapp/images/iconClusterSmall.png |  Bin 0 -> 757 bytes
 .../main/webapp/images/iconCollapseChildren.png |  Bin 0 -> 571 bytes
 .../main/webapp/images/iconCollapseParents.png  |  Bin 0 -> 645 bytes
 .../src/main/webapp/images/iconColor.png        |  Bin 0 -> 738 bytes
 .../src/main/webapp/images/iconCommit.png       |  Bin 0 -> 445 bytes
 .../src/main/webapp/images/iconConfigure.png    |  Bin 0 -> 696 bytes
 .../src/main/webapp/images/iconConnect.png      |  Bin 0 -> 589 bytes
 .../src/main/webapp/images/iconConnection.png   |  Bin 0 -> 1517 bytes
 .../src/main/webapp/images/iconCopy.png         |  Bin 0 -> 514 bytes
 .../src/main/webapp/images/iconCounter.png      |  Bin 0 -> 1369 bytes
 .../src/main/webapp/images/iconDelete.png       |  Bin 0 -> 670 bytes
 .../src/main/webapp/images/iconDetails.png      |  Bin 0 -> 549 bytes
 .../src/main/webapp/images/iconDisable.png      |  Bin 0 -> 764 bytes
 .../src/main/webapp/images/iconDisconnect.png   |  Bin 0 -> 569 bytes
 .../src/main/webapp/images/iconEdit.png         |  Bin 0 -> 493 bytes
 .../src/main/webapp/images/iconEditButton.png   |  Bin 0 -> 915 bytes
 .../main/webapp/images/iconExpandChildren.png   |  Bin 0 -> 521 bytes
 .../main/webapp/images/iconExpandParents.png    |  Bin 0 -> 585 bytes
 .../src/main/webapp/images/iconExport.png       |  Bin 0 -> 453 bytes
 .../main/webapp/images/iconExportLineage.png    |  Bin 0 -> 405 bytes
 .../src/main/webapp/images/iconFlowSettings.png |  Bin 0 -> 2624 bytes
 .../src/main/webapp/images/iconFunnel.png       |  Bin 0 -> 1223 bytes
 .../src/main/webapp/images/iconGoTo.png         |  Bin 0 -> 448 bytes
 .../src/main/webapp/images/iconHistory.png      |  Bin 0 -> 2347 bytes
 .../src/main/webapp/images/iconInfo.png         |  Bin 0 -> 550 bytes
 .../src/main/webapp/images/iconInputPort.png    |  Bin 0 -> 1842 bytes
 .../main/webapp/images/iconInputPortSmall.png   |  Bin 0 -> 532 bytes
 .../webapp/images/iconIsolatedProcessor.png     |  Bin 0 -> 1781 bytes
 .../src/main/webapp/images/iconLineage.png      |  Bin 0 -> 432 bytes
 .../src/main/webapp/images/iconLoading.gif      |  Bin 0 -> 2438 bytes
 .../src/main/webapp/images/iconNotSecure.png    |  Bin 0 -> 137 bytes
 .../src/main/webapp/images/iconOutputPort.png   |  Bin 0 -> 1658 bytes
 .../main/webapp/images/iconOutputPortSmall.png  |  Bin 0 -> 459 bytes
 .../src/main/webapp/images/iconPaste.png        |  Bin 0 -> 601 bytes
 .../src/main/webapp/images/iconPopOut.png       |  Bin 0 -> 217 bytes
 .../webapp/images/iconPortNotTransmitting.png   |  Bin 0 -> 231 bytes
 .../src/main/webapp/images/iconPortRemoved.png  |  Bin 0 -> 456 bytes
 .../main/webapp/images/iconPortTransmitting.png |  Bin 0 -> 235 bytes
 .../src/main/webapp/images/iconPrimary.png      |  Bin 0 -> 647 bytes
 .../src/main/webapp/images/iconProcessor.png    |  Bin 0 -> 1446 bytes
 .../src/main/webapp/images/iconProvenance.png   |  Bin 0 -> 1104 bytes
 .../src/main/webapp/images/iconRefresh.png      |  Bin 0 -> 492 bytes
 .../src/main/webapp/images/iconRemotePorts.png  |  Bin 0 -> 456 bytes
 .../webapp/images/iconRemoteProcessGroup.png    |  Bin 0 -> 674 bytes
 .../src/main/webapp/images/iconReporting.png    |  Bin 0 -> 803 bytes
 .../src/main/webapp/images/iconResetCounter.png |  Bin 0 -> 304 bytes
 .../src/main/webapp/images/iconResize.png       |  Bin 0 -> 142 bytes
 .../src/main/webapp/images/iconRevoke.png       |  Bin 0 -> 676 bytes
 .../src/main/webapp/images/iconRun.png          |  Bin 0 -> 538 bytes
 .../src/main/webapp/images/iconSecure.png       |  Bin 0 -> 133 bytes
 .../src/main/webapp/images/iconSmallFunnel.png  |  Bin 0 -> 455 bytes
 .../main/webapp/images/iconSmallInputPort.png   |  Bin 0 -> 216 bytes
 .../main/webapp/images/iconSmallOutputPort.png  |  Bin 0 -> 264 bytes
 .../webapp/images/iconSmallProcessGroup.png     |  Bin 0 -> 479 bytes
 .../main/webapp/images/iconSmallProcessor.png   |  Bin 0 -> 647 bytes
 .../webapp/images/iconSmallRelationship.png     |  Bin 0 -> 770 bytes
 .../images/iconSmallRemoteProcessGroup.png      |  Bin 0 -> 402 bytes
 .../src/main/webapp/images/iconStop.png         |  Bin 0 -> 402 bytes
 .../src/main/webapp/images/iconTemplates.png    |  Bin 0 -> 2659 bytes
 .../src/main/webapp/images/iconToFront.png      |  Bin 0 -> 475 bytes
 .../webapp/images/iconTransmissionActive.png    |  Bin 0 -> 1330 bytes
 .../webapp/images/iconTransmissionInactive.png  |  Bin 0 -> 1248 bytes
 .../src/main/webapp/images/iconTwistArrow.png   |  Bin 0 -> 256 bytes
 .../src/main/webapp/images/iconUndo.png         |  Bin 0 -> 642 bytes
 .../src/main/webapp/images/iconUsage.png        |  Bin 0 -> 470 bytes
 .../src/main/webapp/images/inputCheckbox.png    |  Bin 0 -> 389 bytes
 .../src/main/webapp/images/loadAnimation.gif    |  Bin 0 -> 7854 bytes
 .../src/main/webapp/images/nifi16.ico           |  Bin 0 -> 1150 bytes
 .../src/main/webapp/images/nifi_about.png       |  Bin 0 -> 18958 bytes
 .../src/main/webapp/images/panelBg.jpg          |  Bin 0 -> 312 bytes
 .../src/main/webapp/images/portRemoved.png      |  Bin 0 -> 1090 bytes
 .../src/main/webapp/images/portRunning.png      |  Bin 0 -> 337 bytes
 .../src/main/webapp/images/portStopped.png      |  Bin 0 -> 192 bytes
 .../src/main/webapp/images/spacer.png           |  Bin 0 -> 110 bytes
 .../src/main/webapp/images/starburst.png        |  Bin 0 -> 190 bytes
 .../src/main/webapp/images/tabBg.jpg            |  Bin 0 -> 320 bytes
 .../src/main/webapp/images/toolbarBg.gif        |  Bin 0 -> 45 bytes
 .../main/webapp/images/toolboxIconFunnel.png    |  Bin 0 -> 2409 bytes
 .../main/webapp/images/toolboxIconInputPort.png |  Bin 0 -> 2680 bytes
 .../src/main/webapp/images/toolboxIconLabel.png |  Bin 0 -> 2871 bytes
 .../webapp/images/toolboxIconOutputPort.png     |  Bin 0 -> 2209 bytes
 .../webapp/images/toolboxIconProcessGroup.png   |  Bin 0 -> 4176 bytes
 .../main/webapp/images/toolboxIconProcessor.png |  Bin 0 -> 4426 bytes
 .../images/toolboxIconRemoteProcessGroup.png    |  Bin 0 -> 5653 bytes
 .../main/webapp/images/toolboxIconTemplate.png  |  Bin 0 -> 2913 bytes
 .../images/transmissionSwitchDisabled.png       |  Bin 0 -> 1240 bytes
 .../webapp/images/transmissionSwitchEnabled.png |  Bin 0 -> 1600 bytes
 .../src/main/webapp/images/ungroup.png          |  Bin 0 -> 3409 bytes
 .../src/main/webapp/js/codemirror/LICENSE       |   19 +
 .../js/codemirror/addon/edit/matchbrackets.js   |  125 +
 .../js/codemirror/addon/hint/show-hint.css      |   38 +
 .../js/codemirror/addon/hint/show-hint.js       |  411 +
 .../webapp/js/codemirror/lib/codemirror.css     |  270 +
 .../main/webapp/js/codemirror/lib/codemirror.js | 8488 +++++++++++++++++
 .../nifi-web-ui/src/main/webapp/js/d3/LICENSE   |   26 +
 .../nifi-web-ui/src/main/webapp/js/d3/d3.min.js | 5385 +++++++++++
 .../webapp/js/jquery/combo/jquery.combo.css     |   82 +
 .../main/webapp/js/jquery/combo/jquery.combo.js |  292 +
 .../main/webapp/js/jquery/combo/menuArrow.png   |  Bin 0 -> 251 bytes
 .../webapp/js/jquery/combo/menuArrowSmall.png   |  Bin 0 -> 233 bytes
 .../images/ui-bg_flat_0_aaaaaa_40x100.png       |  Bin 0 -> 180 bytes
 .../images/ui-bg_flat_75_ffffff_40x100.png      |  Bin 0 -> 178 bytes
 .../images/ui-bg_glass_55_fbf9ee_1x400.png      |  Bin 0 -> 120 bytes
 .../images/ui-bg_glass_65_ffffff_1x400.png      |  Bin 0 -> 105 bytes
 .../images/ui-bg_glass_75_dadada_1x400.png      |  Bin 0 -> 111 bytes
 .../images/ui-bg_glass_75_e6e6e6_1x400.png      |  Bin 0 -> 110 bytes
 .../images/ui-bg_glass_95_fef1ec_1x400.png      |  Bin 0 -> 119 bytes
 .../ui-bg_highlight-soft_75_cccccc_1x100.png    |  Bin 0 -> 101 bytes
 .../images/ui-icons_222222_256x240.png          |  Bin 0 -> 4369 bytes
 .../images/ui-icons_2e83ff_256x240.png          |  Bin 0 -> 4369 bytes
 .../images/ui-icons_454545_256x240.png          |  Bin 0 -> 8543 bytes
 .../images/ui-icons_888888_256x240.png          |  Bin 0 -> 4369 bytes
 .../images/ui-icons_cd0a0a_256x240.png          |  Bin 0 -> 4369 bytes
 .../images/ui-icons_ffffff_256x240.png          |  Bin 0 -> 8358 bytes
 .../css/smoothness/jquery-ui-1.8.10.custom.css  |  625 ++
 .../src/main/webapp/js/jquery/jquery-1.7.js     | 9017 ++++++++++++++++++
 .../src/main/webapp/js/jquery/jquery-1.7.min.js | 2934 ++++++
 .../js/jquery/jquery-ui-1.8.10.custom.min.js    | 6354 ++++++++++++
 .../src/main/webapp/js/jquery/jquery.center.js  |   27 +
 .../src/main/webapp/js/jquery/jquery.count.js   |   91 +
 .../src/main/webapp/js/jquery/jquery.each.js    |   31 +
 .../main/webapp/js/jquery/jquery.ellipsis.js    |  155 +
 .../js/jquery/jquery.event.drag-2.0.min.js      |  194 +
 .../src/main/webapp/js/jquery/jquery.form.js    | 1118 +++
 .../src/main/webapp/js/jquery/jquery.tab.js     |   69 +
 .../js/jquery/minicolors/jquery.minicolors.css  |  245 +
 .../jquery/minicolors/jquery.minicolors.min.js  |  420 +
 .../js/jquery/minicolors/jquery.minicolors.png  |  Bin 0 -> 77459 bytes
 .../webapp/js/jquery/modal/jquery.modal.css     |  110 +
 .../main/webapp/js/jquery/modal/jquery.modal.js |  266 +
 .../js/jquery/nfeditor/jquery.nfeditor.css      |   73 +
 .../js/jquery/nfeditor/jquery.nfeditor.js       |  306 +
 .../webapp/js/jquery/nfeditor/languages/nfel.js |  630 ++
 .../main/webapp/js/jquery/qtip2/jquery.qtip.css |  557 ++
 .../webapp/js/jquery/qtip2/jquery.qtip.min.js   |  706 ++
 .../js/jquery/slickgrid/css/images/sort-asc.gif |  Bin 0 -> 59 bytes
 .../jquery/slickgrid/css/images/sort-desc.gif   |  Bin 0 -> 59 bytes
 .../slickgrid/css/slick-default-theme.css       |  121 +
 .../js/jquery/slickgrid/css/slick.grid.css      |  158 +
 .../slickgrid/plugins/slick.autotooltips.js     |   48 +
 .../plugins/slick.cellrangedecorator.js         |   64 +
 .../plugins/slick.cellrangeselector.js          |  111 +
 .../plugins/slick.cellselectionmodel.js         |   90 +
 .../plugins/slick.rowselectionmodel.js          |  184 +
 .../webapp/js/jquery/slickgrid/slick.core.js    |  423 +
 .../js/jquery/slickgrid/slick.dataview.js       |  914 ++
 .../webapp/js/jquery/slickgrid/slick.editors.js |  512 +
 .../js/jquery/slickgrid/slick.formatters.js     |   55 +
 .../webapp/js/jquery/slickgrid/slick.grid.js    | 2832 ++++++
 .../webapp/js/jquery/tabbs/jquery.tabbs.css     |   48 +
 .../main/webapp/js/jquery/tabbs/jquery.tabbs.js |   96 +
 .../web/nifi-web-ui/src/main/webapp/js/json2.js |  475 +
 .../js/nf/bulletin-board/nf-bulletin-board.js   |  422 +
 .../src/main/webapp/js/nf/canvas/nf-actions.js  | 1119 +++
 .../src/main/webapp/js/nf/canvas/nf-birdseye.js |  347 +
 .../webapp/js/nf/canvas/nf-canvas-header.js     |  293 +
 .../webapp/js/nf/canvas/nf-canvas-toolbar.js    |  158 +
 .../webapp/js/nf/canvas/nf-canvas-toolbox.js    | 1203 +++
 .../main/webapp/js/nf/canvas/nf-canvas-utils.js | 1283 +++
 .../src/main/webapp/js/nf/canvas/nf-canvas.js   | 1462 +++
 .../main/webapp/js/nf/canvas/nf-clipboard.js    |   92 +
 .../main/webapp/js/nf/canvas/nf-connectable.js  |  209 +
 .../js/nf/canvas/nf-connection-configuration.js | 1375 +++
 .../main/webapp/js/nf/canvas/nf-connection.js   | 1456 +++
 .../main/webapp/js/nf/canvas/nf-context-menu.js |  442 +
 .../js/nf/canvas/nf-custom-processor-ui.js      |   43 +
 .../main/webapp/js/nf/canvas/nf-draggable.js    |  295 +
 .../src/main/webapp/js/nf/canvas/nf-funnel.js   |  271 +
 .../src/main/webapp/js/nf/canvas/nf-go-to.js    |  720 ++
 .../webapp/js/nf/canvas/nf-graph-control.js     |  113 +
 .../src/main/webapp/js/nf/canvas/nf-graph.js    |  188 +
 .../js/nf/canvas/nf-label-configuration.js      |  130 +
 .../src/main/webapp/js/nf/canvas/nf-label.js    |  549 ++
 .../js/nf/canvas/nf-port-configuration.js       |  166 +
 .../main/webapp/js/nf/canvas/nf-port-details.js |   59 +
 .../src/main/webapp/js/nf/canvas/nf-port.js     |  622 ++
 .../nf/canvas/nf-process-group-configuration.js |  103 +
 .../js/nf/canvas/nf-process-group-details.js    |   57 +
 .../webapp/js/nf/canvas/nf-process-group.js     | 1040 ++
 .../js/nf/canvas/nf-processor-configuration.js  |  703 ++
 .../nf-processor-property-combo-editor.js       |  170 +
 .../canvas/nf-processor-property-nfel-editor.js |  212 +
 .../js/nf/canvas/nf-processor-property-table.js |  547 ++
 .../canvas/nf-processor-property-text-editor.js |  216 +
 .../main/webapp/js/nf/canvas/nf-processor.js    |  820 ++
 .../main/webapp/js/nf/canvas/nf-registration.js |   68 +
 .../nf-remote-process-group-configuration.js    |  120 +
 .../canvas/nf-remote-process-group-details.js   |   63 +
 .../nf/canvas/nf-remote-process-group-ports.js  |  516 +
 .../js/nf/canvas/nf-remote-process-group.js     | 1050 ++
 .../src/main/webapp/js/nf/canvas/nf-search.js   |  180 +
 .../nf/canvas/nf-secure-port-configuration.js   |  384 +
 .../js/nf/canvas/nf-secure-port-details.js      |  114 +
 .../main/webapp/js/nf/canvas/nf-selectable.js   |   56 +
 .../src/main/webapp/js/nf/canvas/nf-settings.js |  145 +
 .../src/main/webapp/js/nf/canvas/nf-snippet.js  |  206 +
 .../src/main/webapp/js/nf/canvas/nf-storage.js  |  133 +
 .../webapp/js/nf/canvas/nf-toolbar-action.js    |   82 +
 .../webapp/js/nf/cluster/nf-cluster-table.js    |  589 ++
 .../src/main/webapp/js/nf/cluster/nf-cluster.js |  154 +
 .../webapp/js/nf/counters/nf-counters-table.js  |  291 +
 .../main/webapp/js/nf/counters/nf-counters.js   |  153 +
 .../webapp/js/nf/history/nf-history-model.js    |  218 +
 .../webapp/js/nf/history/nf-history-table.js    |  426 +
 .../src/main/webapp/js/nf/history/nf-history.js |  154 +
 .../src/main/webapp/js/nf/nf-client.js          |   56 +
 .../src/main/webapp/js/nf/nf-common.js          |  843 ++
 .../main/webapp/js/nf/nf-connection-details.js  |  459 +
 .../src/main/webapp/js/nf/nf-dialog.js          |  127 +
 .../src/main/webapp/js/nf/nf-namespace.js       |   20 +
 .../main/webapp/js/nf/nf-processor-details.js   |  560 ++
 .../src/main/webapp/js/nf/nf-shell.js           |  156 +
 .../src/main/webapp/js/nf/nf-status-history.js  | 1347 +++
 .../js/nf/provenance/nf-provenance-lineage.js   | 1412 +++
 .../js/nf/provenance/nf-provenance-table.js     | 1365 +++
 .../webapp/js/nf/provenance/nf-provenance.js    |  204 +
 .../webapp/js/nf/summary/nf-cluster-search.js   |  168 +
 .../webapp/js/nf/summary/nf-summary-table.js    | 2393 +++++
 .../src/main/webapp/js/nf/summary/nf-summary.js |  174 +
 .../js/nf/templates/nf-templates-table.js       |  328 +
 .../main/webapp/js/nf/templates/nf-templates.js |  235 +
 .../main/webapp/js/nf/users/nf-users-table.js   | 1080 +++
 .../src/main/webapp/js/nf/users/nf-users.js     |  149 +
 .../framework-bundle/framework/web/pom.xml      |   85 +
 .../web/web-optimistic-locking/.gitignore       |    1 +
 .../web/web-optimistic-locking/pom.xml          |   32 +
 .../apache/nifi/web/ConfigurationSnapshot.java  |   66 +
 .../nifi/web/OptimisticLockingManager.java      |   95 +
 .../web/StandardOptimisticLockingManager.java   |   77 +
 .../framework/web/web-security/.gitignore       |    1 +
 .../framework/web/web-security/pom.xml          |   81 +
 .../org/apache/nifi/web/security/DnUtils.java   |   87 +
 .../web/security/UntrustedProxyException.java   |   38 +
 .../anonymous/NiFiAnonymousUserFilter.java      |  101 +
 .../NiFiAuthenticationEntryPoint.java           |   68 +
 .../authorization/NiFiAuthorizationService.java |  150 +
 .../authorization/NodeAuthorizedUserFilter.java |  128 +
 .../nifi/web/security/user/NiFiUserDetails.java |  110 +
 .../nifi/web/security/user/NiFiUserUtils.java   |   82 +
 .../x509/SubjectDnX509PrincipalExtractor.java   |   38 +
 .../security/x509/X509AuthenticationFilter.java |  349 +
 .../security/x509/X509CertificateExtractor.java |   52 +
 .../x509/ocsp/CertificateStatusException.java   |   42 +
 .../x509/ocsp/OcspCertificateValidator.java     |  444 +
 .../web/security/x509/ocsp/OcspRequest.java     |   69 +
 .../nifi/web/security/x509/ocsp/OcspStatus.java |   82 +
 .../resources/nifi-web-security-context.xml     |   83 +
 nar-bundles/framework-bundle/nar/.gitignore     |    1 +
 nar-bundles/framework-bundle/nar/pom.xml        |  113 +
 nar-bundles/framework-bundle/pom.xml            |  477 +
 .../hadoop-bundle/hdfs-processors/pom.xml       |   77 +
 .../hadoop/AbstractHadoopProcessor.java         |  221 +
 .../hadoop/CreateHadoopSequenceFile.java        |  177 +
 ...lowFileStreamUnpackerSequenceFileWriter.java |  170 +
 .../apache/nifi/processors/hadoop/GetHDFS.java  |  562 ++
 .../processors/hadoop/GetHDFSSequenceFile.java  |  146 +
 .../nifi/processors/hadoop/KeyValueReader.java  |  132 +
 .../apache/nifi/processors/hadoop/PutHDFS.java  |  402 +
 .../hadoop/SequenceFileWriterImpl.java          |  119 +
 .../hadoop/TarUnpackerSequenceFileWriter.java   |   54 +
 .../nifi/processors/hadoop/ValueReader.java     |  116 +
 .../hadoop/ZipUnpackerSequenceFileWriter.java   |   57 +
 .../hadoop/util/ByteFilteringOutputStream.java  |  163 +
 .../hadoop/util/InputStreamWritable.java        |   61 +
 .../hadoop/util/OutputStreamWritable.java       |   85 +
 .../hadoop/util/SequenceFileReader.java         |   28 +
 .../hadoop/util/SequenceFileWriter.java         |   40 +
 .../org.apache.nifi.processor.Processor         |   18 +
 .../index.html                                  |   88 +
 .../index.html                                  |  162 +
 .../index.html                                  |  150 +
 .../index.html                                  |  159 +
 .../processors/hadoop/AbstractHadoopTest.java   |   90 +
 .../nifi/processors/hadoop/GetHDFSTest.java     |  125 +
 .../nifi/processors/hadoop/PutHDFSTest.java     |  158 +
 .../hadoop/SimpleHadoopProcessor.java           |   30 +
 .../hadoop/TestCreateHadoopSequenceFile.java    |  176 +
 .../src/test/resources/core-site-broken.xml     |   25 +
 .../src/test/resources/core-site.xml            |   25 +
 .../resources/testdata/13545312236534130.tar    |  Bin 0 -> 1505280 bytes
 .../resources/testdata/13545423550275052.zip    |  Bin 0 -> 1500841 bytes
 .../resources/testdata/13545479542069498.pkg    |  Bin 0 -> 1500429 bytes
 .../src/test/resources/testdata/randombytes-1   |  Bin 0 -> 500000 bytes
 .../src/test/resources/testdata/randombytes-2   |  Bin 0 -> 500000 bytes
 .../src/test/resources/testdata/randombytes-3   |  Bin 0 -> 500000 bytes
 nar-bundles/hadoop-bundle/nar/pom.xml           |   41 +
 nar-bundles/hadoop-bundle/pom.xml               |  106 +
 nar-bundles/hadoop-libraries-bundle/nar/pom.xml |   52 +
 nar-bundles/hadoop-libraries-bundle/pom.xml     |   60 +
 nar-bundles/jetty-bundle/pom.xml                |   82 +
 .../monitor-threshold-bundle/nar/pom.xml        |   40 +
 nar-bundles/monitor-threshold-bundle/pom.xml    |  111 +
 .../monitor-threshold-bundle/processor/pom.xml  |   53 +
 .../processors/monitor/MonitorThreshold.java    |  904 ++
 .../processors/monitor/ThresholdsParser.java    |  134 +
 .../org.apache.nifi.processor.Processor         |   15 +
 .../index.html                                  |  485 +
 .../monitor/TestMonitorThreshold.java           | 1560 +++
 .../processor/src/test/resources/testFile       |   23 +
 .../resources/threshold_settings_allow_0.xml    |   21 +
 .../resources/threshold_settings_allow_1.xml    |   21 +
 .../threshold_settings_allow_10_KB.xml          |   21 +
 .../threshold_settings_allow_10_KB_and_2_KB.xml |   26 +
 .../threshold_settings_allow_1669_bytes.xml     |   21 +
 .../resources/threshold_settings_allow_2.xml    |   21 +
 .../threshold_settings_allow_2_default.xml      |   21 +
 ...eshold_settings_allow_3336_bytes_default.xml |   21 +
 ...hold_settings_with_empty_attribute_value.xml |   21 +
 ...ettings_with_spaces_for_attribute_values.xml |   22 +
 .../ui/nb-configuration.xml                     |   18 +
 nar-bundles/monitor-threshold-bundle/ui/pom.xml |  134 +
 .../thresholds/ui/AttributeComparator.java      |   36 +
 .../thresholds/ui/AttributeResource.java        |  242 +
 .../monitor/thresholds/ui/RuleComparator.java   |   46 +
 .../thresholds/ui/ThresholdResource.java        |  227 +
 .../ui/ThresholdSettingsResource.java           |  191 +
 .../thresholds/ui/ThresholdsConfigFile.java     |  296 +
 .../ui/src/main/webapp/META-INF/nifi-processor  |    1 +
 .../webapp/WEB-INF/jsp/attribute-add-dialog.jsp |   43 +
 .../WEB-INF/jsp/attribute-confirm-dialog.jsp    |   21 +
 .../WEB-INF/jsp/attribute-edit-dialog.jsp       |   27 +
 .../WEB-INF/jsp/attribute-filter-dialog.jsp     |   26 +
 .../main/webapp/WEB-INF/jsp/error-dialog.jsp    |   21 +
 .../ui/src/main/webapp/WEB-INF/jsp/index.jsp    |  101 +
 .../webapp/WEB-INF/jsp/threshold-add-dialog.jsp |   45 +
 .../WEB-INF/jsp/threshold-confirm-dialog.jsp    |   21 +
 .../webapp/WEB-INF/jsp/threshold-dialog.jsp     |   48 +
 .../WEB-INF/jsp/threshold-edit-dialog.jsp       |   45 +
 .../WEB-INF/jsp/threshold-filter-dialog.jsp     |   40 +
 .../ui/src/main/webapp/WEB-INF/web.xml          |   48 +
 .../ui/src/main/webapp/css/threshold_styles.css |  422 +
 .../src/main/webapp/images/addWorksheetRow.png  |  Bin 0 -> 323 bytes
 .../ui/src/main/webapp/images/clear.png         |  Bin 0 -> 912 bytes
 .../ui/src/main/webapp/images/filter.gif        |  Bin 0 -> 623 bytes
 .../ui/src/main/webapp/images/firstPage.gif     |  Bin 0 -> 577 bytes
 .../main/webapp/images/firstPageDisabled.gif    |  Bin 0 -> 365 bytes
 .../ui/src/main/webapp/images/lastPage.gif      |  Bin 0 -> 579 bytes
 .../src/main/webapp/images/lastPageDisabled.gif |  Bin 0 -> 368 bytes
 .../ui/src/main/webapp/images/nextPage.gif      |  Bin 0 -> 570 bytes
 .../src/main/webapp/images/nextPageDisabled.gif |  Bin 0 -> 362 bytes
 .../ui/src/main/webapp/images/prevPage.gif      |  Bin 0 -> 567 bytes
 .../src/main/webapp/images/prevPageDisabled.gif |  Bin 0 -> 361 bytes
 .../main/webapp/images/removeWorksheetRow.png   |  Bin 0 -> 655 bytes
 .../ui/src/main/webapp/images/separator.gif     |  Bin 0 -> 63 bytes
 .../js/jquery/jqgrid/css/ellipsis-xbl.xml       |   29 +
 .../webapp/js/jquery/jqgrid/css/ui.jqgrid.css   |  212 +
 .../js/jquery/jqgrid/js/i18n/grid.locale-en.js  |    5 +
 .../js/jquery/jqgrid/js/jquery.jqGrid.min.js    |  416 +
 .../ui/src/main/webapp/js/nf-common.js          |  887 ++
 .../ui/src/main/xsd/threshold_settings.xsd      |   54 +
 nar-bundles/nar-container-common/pom.xml        |  121 +
 .../nar/pom.xml                                 |   36 +
 .../persistent-provenance-repository/pom.xml    |   67 +
 .../nifi/provenance/IndexConfiguration.java     |  398 +
 .../PersistentProvenanceRepository.java         | 1892 ++++
 .../provenance/RepositoryConfiguration.java     |  299 +
 .../nifi/provenance/StandardRecordReader.java   |  305 +
 .../nifi/provenance/StandardRecordWriter.java   |  237 +
 .../provenance/expiration/ExpirationAction.java |   35 +
 .../expiration/FileRemovalAction.java           |   49 +
 .../provenance/lucene/DeleteIndexAction.java    |  139 +
 .../nifi/provenance/lucene/DocsReader.java      |  133 +
 .../nifi/provenance/lucene/FieldNames.java      |   23 +
 .../nifi/provenance/lucene/IndexSearch.java     |   84 +
 .../nifi/provenance/lucene/IndexingAction.java  |  219 +
 .../nifi/provenance/lucene/LineageQuery.java    |  108 +
 .../nifi/provenance/lucene/LuceneUtil.java      |  141 +
 .../provenance/rollover/CompressionAction.java  |   59 +
 .../provenance/rollover/RolloverAction.java     |   35 +
 .../provenance/serialization/RecordReader.java  |   31 +
 .../provenance/serialization/RecordReaders.java |   70 +
 .../provenance/serialization/RecordWriter.java  |   85 +
 .../provenance/serialization/RecordWriters.java |   30 +
 ...he.nifi.provenance.ProvenanceEventRepository |   15 +
 .../TestPersistentProvenanceRepository.java     | 1129 +++
 .../pom.xml                                     |   82 +
 nar-bundles/ssl-context-bundle/nar/pom.xml      |   39 +
 nar-bundles/ssl-context-bundle/pom.xml          |   49 +
 .../ssl-context-service/pom.xml                 |   51 +
 .../nifi/ssl/StandardSSLContextService.java     |  354 +
 ...org.apache.nifi.controller.ControllerService |   15 +
 .../index.html                                  |   63 +
 .../apache/nifi/ssl/SSLContextServiceTest.java  |  197 +
 .../java/org/apache/nifi/ssl/TestProcessor.java |   47 +
 .../src/test/resources/localhost-ks.jks         |  Bin 0 -> 1298 bytes
 .../src/test/resources/localhost-ts.jks         |  Bin 0 -> 891 bytes
 .../standard-bundle/jms-processors/pom.xml      |   63 +
 .../apache/nifi/processors/jms/GetJMSQueue.java |   75 +
 .../apache/nifi/processors/jms/GetJMSTopic.java |  359 +
 .../apache/nifi/processors/jms/JmsConsumer.java |  208 +
 .../org/apache/nifi/processors/jms/PutJMS.java  |  374 +
 .../nifi/processors/jms/util/JmsFactory.java    |  463 +
 .../nifi/processors/jms/util/JmsProperties.java |  177 +
 .../jms/util/WrappedMessageConsumer.java        |   77 +
 .../jms/util/WrappedMessageProducer.java        |   77 +
 .../org.apache.nifi.processor.Processor         |   17 +
 .../index.html                                  |  119 +
 .../index.html                                  |  123 +
 .../index.html                                  |  153 +
 .../nifi/processors/jms/GetJMSQueueTest.java    |  141 +
 nar-bundles/standard-bundle/nar/pom.xml         |   61 +
 nar-bundles/standard-bundle/pom.xml             |  105 +
 .../standard-ganglia-reporter/pom.xml           |   53 +
 .../ganglia/StandardGangliaReporter.java        |  262 +
 .../org.apache.nifi.reporting.ReportingTask     |   15 +
 .../index.html                                  |   65 +
 .../standard-prioritizers/pom.xml               |   40 +
 .../prioritizer/FirstInFirstOutPrioritizer.java |   37 +
 .../NewestFlowFileFirstPrioritizer.java         |   37 +
 .../OldestFlowFileFirstPrioritizer.java         |   37 +
 .../PriorityAttributePrioritizer.java           |   87 +
 ...org.apache.nifi.flowfile.FlowFilePrioritizer |   18 +
 .../prioritizer/NewestFirstPrioritizerTest.java |   67 +
 .../prioritizer/OldestFirstPrioritizerTest.java |   67 +
 .../PriorityAttributePrioritizerTest.java       |  117 +
 .../standard-bundle/standard-processors/pom.xml |  192 +
 .../standard/Base64EncodeContent.java           |  142 +
 .../processors/standard/CompressContent.java    |  307 +
 .../nifi/processors/standard/ControlRate.java   |  381 +
 .../standard/ConvertCharacterSet.java           |  175 +
 .../processors/standard/DetectDuplicate.java    |  249 +
 .../processors/standard/DistributeLoad.java     |  498 +
 .../processors/standard/EncryptContent.java     |  263 +
 .../standard/EvaluateRegularExpression.java     |  294 +
 .../nifi/processors/standard/EvaluateXPath.java |  404 +
 .../processors/standard/EvaluateXQuery.java     |  463 +
 .../standard/ExecuteStreamCommand.java          |  358 +
 .../processors/standard/GenerateFlowFile.java   |  164 +
 .../apache/nifi/processors/standard/GetFTP.java |   72 +
 .../nifi/processors/standard/GetFile.java       |  443 +
 .../processors/standard/GetFileTransfer.java    |  300 +
 .../nifi/processors/standard/GetHTTP.java       |  447 +
 .../nifi/processors/standard/GetSFTP.java       |   92 +
 .../nifi/processors/standard/HashAttribute.java |  255 +
 .../nifi/processors/standard/HashContent.java   |  151 +
 .../processors/standard/IdentifyMimeType.java   |  474 +
 .../nifi/processors/standard/InvokeHTTP.java    |  758 ++
 .../nifi/processors/standard/ListenHTTP.java    |  310 +
 .../nifi/processors/standard/ListenUDP.java     |  627 ++
 .../nifi/processors/standard/LogAttribute.java  |  262 +
 .../nifi/processors/standard/MergeContent.java  |  974 ++
 .../nifi/processors/standard/ModifyBytes.java   |  134 +
 .../processors/standard/MonitorActivity.java    |  206 +
 .../nifi/processors/standard/PostHTTP.java      |  859 ++
 .../nifi/processors/standard/PutEmail.java      |  297 +
 .../apache/nifi/processors/standard/PutFTP.java |  141 +
 .../nifi/processors/standard/PutFile.java       |  366 +
 .../processors/standard/PutFileTransfer.java    |  293 +
 .../nifi/processors/standard/PutSFTP.java       |   85 +
 .../nifi/processors/standard/ReplaceText.java   |  289 +
 .../standard/ReplaceTextWithMapping.java        |  383 +
 .../processors/standard/RouteOnAttribute.java   |  261 +
 .../processors/standard/RouteOnContent.java     |  232 +
 .../nifi/processors/standard/ScanAttribute.java |  229 +
 .../nifi/processors/standard/ScanContent.java   |  292 +
 .../processors/standard/SegmentContent.java     |  163 +
 .../nifi/processors/standard/SplitContent.java  |  260 +
 .../nifi/processors/standard/SplitText.java     |  370 +
 .../nifi/processors/standard/SplitXml.java      |  300 +
 .../nifi/processors/standard/TransformXml.java  |  194 +
 .../nifi/processors/standard/UnpackContent.java |  427 +
 .../nifi/processors/standard/ValidateXml.java   |  147 +
 .../servlets/ContentAcknowledgmentServlet.java  |  136 +
 .../standard/servlets/ListenHTTPServlet.java    |  308 +
 .../nifi/processors/standard/util/Bin.java      |  168 +
 .../processors/standard/util/BinManager.java    |  241 +
 .../standard/util/DocumentReaderCallback.java   |   74 +
 .../processors/standard/util/FTPTransfer.java   |  541 ++
 .../nifi/processors/standard/util/FTPUtils.java |  322 +
 .../nifi/processors/standard/util/FileInfo.java |  167 +
 .../processors/standard/util/FileTransfer.java  |  244 +
 .../standard/util/FlowFileSessionWrapper.java   |   44 +
 .../standard/util/NLKBufferedReader.java        |  187 +
 .../standard/util/SFTPConnection.java           |   82 +
 .../processors/standard/util/SFTPTransfer.java  |  637 ++
 .../processors/standard/util/SFTPUtils.java     |  324 +
 .../standard/util/UDPStreamConsumer.java        |  214 +
 .../util/ValidatingBase64InputStream.java       |   76 +
 .../standard/util/XmlElementNotifier.java       |   22 +
 .../standard/util/XmlSplitterSaxParser.java     |  112 +
 .../org.apache.nifi.processor.Processor         |   58 +
 .../index.html                                  |   63 +
 .../index.html                                  |  166 +
 .../index.html                                  |  116 +
 .../index.html                                  |   65 +
 .../index.html                                  |  147 +
 .../index.html                                  |  106 +
 .../index.html                                  |   97 +
 .../index.html                                  |  160 +
 .../index.html                                  |  135 +
 .../index.html                                  |  311 +
 .../index.html                                  |  111 +
 .../index.html                                  |   64 +
 .../index.html                                  |  227 +
 .../index.html                                  |  184 +
 .../index.html                                  |  143 +
 .../index.html                                  |  250 +
 .../index.html                                  |   88 +
 .../index.html                                  |   89 +
 .../index.html                                  |  136 +
 .../index.html                                  |  181 +
 .../index.html                                  |   80 +
 .../index.html                                  |  144 +
 .../index.html                                  |   80 +
 .../index.html                                  |  347 +
 .../index.html                                  |   64 +
 .../index.html                                  |  143 +
 .../index.html                                  |  187 +
 .../index.html                                  |  114 +
 .../index.html                                  |  283 +
 .../index.html                                  |  109 +
 .../index.html                                  |  281 +
 .../index.html                                  |   91 +
 .../index.html                                  |  114 +
 .../index.html                                  |  110 +
 .../index.html                                  |   82 +
 .../index.html                                  |   85 +
 .../index.html                                  |  100 +
 .../index.html                                  |  123 +
 .../index.html                                  |  107 +
 .../index.html                                  |  121 +
 .../index.html                                  |   64 +
 .../index.html                                  |   63 +
 .../index.html                                  |  163 +
 .../index.html                                  |   56 +
 .../src/test/java/TestIngestAndUpdate.java      |   34 +
 .../src/test/java/TestSuccess.java              |   24 +
 .../standard/RESTServiceContentModified.java    |   77 +
 .../standard/TestBase64EncodeContent.java       |   83 +
 .../standard/TestCompressContent.java           |  111 +
 .../processors/standard/TestControlRate.java    |   68 +
 .../standard/TestConvertCharacterSet.java       |   47 +
 .../standard/TestDetectDuplicate.java           |  206 +
 .../processors/standard/TestDistributeLoad.java |  138 +
 .../processors/standard/TestEncryptContent.java |   65 +
 .../standard/TestEvaluateRegularExpression.java |  319 +
 .../processors/standard/TestEvaluateXPath.java  |  159 +
 .../processors/standard/TestEvaluateXQuery.java |  651 ++
 .../standard/TestExecuteStreamCommand.java      |  188 +
 .../nifi/processors/standard/TestGetFile.java   |  185 +
 .../nifi/processors/standard/TestGetHTTP.java   |  262 +
 .../processors/standard/TestHashAttribute.java  |   99 +
 .../processors/standard/TestHashContent.java    |   67 +
 .../standard/TestIdentifyMimeType.java          |  131 +
 .../processors/standard/TestInvokeHTTP.java     |  622 ++
 .../nifi/processors/standard/TestListenUDP.java |  214 +
 .../processors/standard/TestMergeContent.java   |  556 ++
 .../processors/standard/TestModifyBytes.java    |  190 +
 .../standard/TestMonitorActivity.java           |  193 +
 .../processors/standard/TestReplaceText.java    |  371 +
 .../standard/TestReplaceTextLineByLine.java     |  337 +
 .../standard/TestReplaceTextWithMapping.java    |  332 +
 .../standard/TestRouteOnAttribute.java          |  161 +
 .../processors/standard/TestRouteOnContent.java |   73 +
 .../processors/standard/TestScanAttribute.java  |  149 +
 .../processors/standard/TestScanContent.java    |   87 +
 .../processors/standard/TestSegmentContent.java |   65 +
 .../processors/standard/TestSplitContent.java   |  235 +
 .../nifi/processors/standard/TestSplitText.java |  173 +
 .../nifi/processors/standard/TestSplitXml.java  |  103 +
 .../processors/standard/TestTransformXml.java   |  120 +
 .../processors/standard/TestUnpackContent.java  |  226 +
 .../processors/standard/TestValidateXml.java    |   42 +
 .../standard/UserAgentTestingServlet.java       |   42 +
 .../CharacterSetConversionSamples/Converted.txt |    1 +
 .../Converted2.txt                              |  Bin 0 -> 134580 bytes
 .../CharacterSetConversionSamples/Original.txt  |  418 +
 .../resources/CompressedData/SampleFile.txt     |  418 +
 .../resources/CompressedData/SampleFile.txt.bz2 |  Bin 0 -> 388 bytes
 .../resources/CompressedData/SampleFile.txt.gz  |  Bin 0 -> 321 bytes
 .../CompressedData/SampleFile1.txt.bz2          |  Bin 0 -> 154 bytes
 .../resources/CompressedData/SampleFile1.txt.gz |  Bin 0 -> 321 bytes
 .../CompressedData/SampleFileConcat.txt         |  835 ++
 .../CompressedData/SampleFileConcat.txt.bz2     |  Bin 0 -> 542 bytes
 .../test/resources/ExecuteCommand/1000bytes.txt |    1 +
 .../ExecuteCommand/TestIngestAndUpdate.jar      |  Bin 0 -> 1170 bytes
 .../resources/ExecuteCommand/TestSuccess.jar    |  Bin 0 -> 827 bytes
 .../src/test/resources/ExecuteCommand/test.txt  |    2 +
 .../dictionary-with-empty-new-lines             |    5 +
 .../ScanAttribute/dictionary-with-extra-info    |    9 +
 .../test/resources/ScanAttribute/dictionary1    |    5 +
 .../test/resources/TestIdentifyMimeType/1.7z    |  Bin 0 -> 133 bytes
 .../test/resources/TestIdentifyMimeType/1.jar   |  Bin 0 -> 466 bytes
 .../test/resources/TestIdentifyMimeType/1.mdb   |  Bin 0 -> 237568 bytes
 .../test/resources/TestIdentifyMimeType/1.pdf   |  Bin 0 -> 277032 bytes
 .../test/resources/TestIdentifyMimeType/1.tar   |  Bin 0 -> 2048 bytes
 .../resources/TestIdentifyMimeType/1.txt.bz2    |  Bin 0 -> 59 bytes
 .../resources/TestIdentifyMimeType/1.txt.gz     |  Bin 0 -> 50 bytes
 .../test/resources/TestIdentifyMimeType/1.xml   |   20 +
 .../test/resources/TestIdentifyMimeType/1.zip   |  Bin 0 -> 165 bytes
 .../TestIdentifyMimeType/bgBannerFoot.png       |  Bin 0 -> 189 bytes
 .../TestIdentifyMimeType/blueBtnBg.jpg          |  Bin 0 -> 356 bytes
 .../TestIdentifyMimeType/flowfilev1.tar         |  Bin 0 -> 10240 bytes
 .../resources/TestIdentifyMimeType/flowfilev3   |  Bin 0 -> 40 bytes
 .../resources/TestIdentifyMimeType/grid.gif     |  Bin 0 -> 135 bytes
 .../test/resources/TestMergeContent/demarcate   |    1 +
 .../src/test/resources/TestMergeContent/foot    |    1 +
 .../src/test/resources/TestMergeContent/head    |    1 +
 .../test/resources/TestModifyBytes/noFooter.txt |   10 +
 .../TestModifyBytes/noFooter_noHeader.txt       |   10 +
 .../test/resources/TestModifyBytes/noHeader.txt |   11 +
 .../test/resources/TestModifyBytes/testFile.txt |   11 +
 .../TestReplaceTextLineByLine/$1$1.txt          |   11 +
 .../BRue_cRue_RiRey.txt                         |   11 +
 .../TestReplaceTextLineByLine/Blu$2e_clu$2e.txt |   11 +
 .../TestReplaceTextLineByLine/D$d_h$d.txt       |   11 +
 .../TestReplaceTextLineByLine/Good.txt          |    1 +
 .../TestReplaceTextLineByLine/Spider.txt        |   11 +
 .../TestReplaceTextLineByLine/[DODO].txt        |   11 +
 .../TestReplaceTextLineByLine/cu[$1]_Po[$1].txt |   11 +
 .../TestReplaceTextLineByLine/cu_Po.txt         |   11 +
 .../TestReplaceTextLineByLine/food.txt          |   11 +
 .../TestReplaceTextLineByLine/testFile.txt      |   11 +
 .../color-fruit-backreference-mapping.txt       |    7 +
 .../color-fruit-blank-mapping.txt               |    7 +
 .../color-fruit-escaped-dollar-mapping.txt      |    7 +
 ...t-excessive-backreference-mapping-simple.txt |    6 +
 ...or-fruit-excessive-backreference-mapping.txt |    6 +
 ...olor-fruit-invalid-backreference-mapping.txt |    7 +
 .../color-fruit-mapping.txt                     |    7 +
 .../color-fruit-no-match-mapping.txt            |    7 +
 .../color-fruit-space-mapping.txt               |    6 +
 .../colors-without-dashes.txt                   |    4 +
 .../TestReplaceTextWithMapping/colors.txt       |    4 +
 .../test/resources/TestScanContent/helloWorld   |    1 +
 .../resources/TestScanContent/wellthengood-bye  |    1 +
 .../src/test/resources/TestSplitText/1.txt      |    5 +
 .../src/test/resources/TestSplitText/2.txt      |    5 +
 .../src/test/resources/TestSplitText/3.txt      |    5 +
 .../src/test/resources/TestSplitText/4.txt      |    3 +
 .../src/test/resources/TestSplitText/5.txt      |    7 +
 .../src/test/resources/TestSplitText/6.txt      |    7 +
 .../test/resources/TestSplitText/original.txt   |   12 +
 .../test/resources/TestTransformXml/math.html   |    8 +
 .../test/resources/TestTransformXml/math.xml    |   21 +
 .../test/resources/TestTransformXml/math.xsl    |   36 +
 .../test/resources/TestTransformXml/tokens.csv  |    2 +
 .../test/resources/TestTransformXml/tokens.xml  |   17 +
 .../test/resources/TestTransformXml/tokens.xsl  |  103 +
 .../resources/TestUnpackContent/data.flowfilev2 |  Bin 0 -> 255 bytes
 .../resources/TestUnpackContent/data.flowfilev3 |  Bin 0 -> 357 bytes
 .../test/resources/TestUnpackContent/data.tar   |  Bin 0 -> 3584 bytes
 .../test/resources/TestUnpackContent/data.zip   |  Bin 0 -> 359 bytes
 .../resources/TestUnpackContent/folder/cal.txt  |    8 +
 .../resources/TestUnpackContent/folder/date.txt |    1 +
 .../src/test/resources/TestXml/XmlBundle.xsd    |   34 +
 .../src/test/resources/TestXml/fruit.xml        |   47 +
 .../src/test/resources/TestXml/subNode.xml      |   21 +
 .../src/test/resources/TestXml/xml-bundle-1     |   51 +
 .../src/test/resources/TestXml/xml-snippet.xml  |   25 +
 .../src/test/resources/hello.txt                |    1 +
 .../src/test/resources/localhost-ks.jks         |  Bin 0 -> 1298 bytes
 .../src/test/resources/localhost-ts.jks         |  Bin 0 -> 891 bytes
 .../src/test/resources/localhost.cer            |  Bin 0 -> 829 bytes
 .../src/test/resources/logback-test.xml         |   49 +
 .../standard-reporting-tasks/pom.xml            |   67 +
 .../ControllerStatusReportingTask.java          |  347 +
 .../nifi/controller/MonitorDiskUsage.java       |  113 +
 .../apache/nifi/controller/MonitorMemory.java   |  260 +
 .../org.apache.nifi.reporting.ReportingTask     |   17 +
 .../index.html                                  |   85 +
 .../index.html                                  |   58 +
 .../index.html                                  |   77 +
 .../nifi/controller/TestMonitorDiskUsage.java   |   61 +
 .../pom.xml                                     |   36 +
 .../distributed/cache/client/Deserializer.java  |   41 +
 .../cache/client/DistributedMapCacheClient.java |  114 +
 .../cache/client/DistributedSetCacheClient.java |   74 +
 .../distributed/cache/client/Serializer.java    |   40 +
 .../exception/DeserializationException.java     |   33 +
 .../exception/SerializationException.java       |   33 +
 .../load-distribution-service-api/pom.xml       |   36 +
 .../nifi/loading/LoadDistributionListener.java  |   24 +
 .../nifi/loading/LoadDistributionService.java   |   33 +
 .../standard-services-api-bundle/pom.xml        |   74 +
 .../ssl-context-service-api/pom.xml             |   36 +
 .../org/apache/nifi/ssl/SSLContextService.java  |   55 +
 .../standard-services-api-nar/pom.xml           |   44 +
 .../update-attribute-bundle/model/pom.xml       |   27 +
 .../apache/nifi/update/attributes/Action.java   |   55 +
 .../nifi/update/attributes/Condition.java       |   49 +
 .../apache/nifi/update/attributes/Criteria.java |  141 +
 .../nifi/update/attributes/FlowFilePolicy.java  |   34 +
 .../org/apache/nifi/update/attributes/Rule.java |   65 +
 .../update/attributes/serde/CriteriaSerDe.java  |  128 +
 nar-bundles/update-attribute-bundle/nar/pom.xml |   51 +
 nar-bundles/update-attribute-bundle/pom.xml     |   69 +
 .../update-attribute-bundle/processor/pom.xml   |   55 +
 .../processors/attributes/UpdateAttribute.java  |  508 +
 .../org.apache.nifi.processor.Processor         |   15 +
 .../index.html                                  |  253 +
 .../update/attributes/TestUpdateAttribute.java  |  425 +
 .../ui/nb-configuration.xml                     |   18 +
 nar-bundles/update-attribute-bundle/ui/pom.xml  |   97 +
 .../attributes/UpdateAttributeModelFactory.java |  127 +
 .../attributes/api/ObjectMapperResolver.java    |   51 +
 .../update/attributes/api/RuleResource.java     |  683 ++
 .../nifi/update/attributes/dto/ActionDTO.java   |   66 +
 .../update/attributes/dto/ConditionDTO.java     |   57 +
 .../nifi/update/attributes/dto/DtoFactory.java  |   68 +
 .../nifi/update/attributes/dto/RuleDTO.java     |   65 +
 .../update/attributes/entity/ActionEntity.java  |   65 +
 .../attributes/entity/ConditionEntity.java      |   65 +
 .../entity/EvaluationContextEntity.java         |   74 +
 .../update/attributes/entity/RuleEntity.java    |   65 +
 .../update/attributes/entity/RulesEntity.java   |   66 +
 .../ui/src/main/webapp/META-INF/nifi-processor  |    1 +
 .../src/main/webapp/WEB-INF/jsp/worksheet.jsp   |  189 +
 .../ui/src/main/webapp/WEB-INF/web.xml          |   46 +
 .../ui/src/main/webapp/css/main.css             |  411 +
 .../ui/src/main/webapp/css/reset.css            |   59 +
 .../ui/src/main/webapp/images/bgInputText.png   |  Bin 0 -> 139 bytes
 .../ui/src/main/webapp/images/buttonNew.png     |  Bin 0 -> 590 bytes
 .../ui/src/main/webapp/images/iconDelete.png    |  Bin 0 -> 670 bytes
 .../ui/src/main/webapp/images/iconInfo.png      |  Bin 0 -> 550 bytes
 .../ui/src/main/webapp/js/application.js        | 1886 ++++
 .../nar/pom.xml                                 |   36 +
 .../pom.xml                                     |   48 +
 .../volatile-provenance-repository/pom.xml      |   47 +
 .../VolatileProvenanceRepository.java           |  743 ++
 ...he.nifi.provenance.ProvenanceEventRepository |   15 +
 .../TestVolatileProvenanceRepository.java       |  178 +
 .../src/test/resources/nifi.properties          |   18 +
 nifi-api/.gitignore                             |    2 +
 nifi-api/pom.xml                                |   32 +
 .../apache/nifi/authorization/Authority.java    |   97 +
 .../nifi/authorization/AuthorityProvider.java   |  162 +
 .../AuthorityProviderConfigurationContext.java  |   52 +
 .../AuthorityProviderInitializationContext.java |   27 +
 .../authorization/AuthorityProviderLookup.java  |   25 +
 .../annotation/AuthorityProviderContext.java    |   36 +
 .../exception/AuthorityAccessException.java     |   33 +
 .../IdentityAlreadyExistsException.java         |   32 +
 .../exception/ProviderCreationException.java    |   40 +
 .../exception/ProviderDestructionException.java |   40 +
 .../exception/UnknownIdentityException.java     |   32 +
 .../AbstractConfigurableComponent.java          |  221 +
 .../apache/nifi/components/AllowableValue.java  |  136 +
 .../nifi/components/ConfigurableComponent.java  |   77 +
 .../nifi/components/PropertyDescriptor.java     |  552 ++
 .../apache/nifi/components/PropertyValue.java   |  189 +
 .../nifi/components/ValidationContext.java      |   82 +
 .../nifi/components/ValidationResult.java       |  173 +
 .../org/apache/nifi/components/Validator.java   |   55 +
 .../controller/AbstractControllerService.java   |   91 +
 .../nifi/controller/ConfigurationContext.java   |   46 +
 .../nifi/controller/ControllerService.java      |  182 +
 .../ControllerServiceInitializationContext.java |   36 +
 .../controller/ControllerServiceLookup.java     |   66 +
 .../apache/nifi/controller/FlowFileQueue.java   |  200 +
 .../apache/nifi/controller/ScheduledState.java  |   37 +
 .../org/apache/nifi/controller/Snippet.java     |  113 +
 .../org/apache/nifi/controller/Triggerable.java |  116 +
 .../controller/annotation/OnConfigured.java     |   41 +
 .../repository/ContentRepository.java           |  308 +
 .../controller/repository/FlowFileRecord.java   |   54 +
 .../repository/FlowFileRepository.java          |  128 +
 .../repository/FlowFileSwapManager.java         |   60 +
 .../controller/repository/QueueProvider.java    |   35 +
 .../controller/repository/RepositoryRecord.java |  100 +
 .../repository/RepositoryRecordType.java        |   26 +
 .../repository/claim/ContentClaim.java          |   55 +
 .../repository/claim/ContentClaimManager.java   |  143 +
 .../controller/status/ConnectionStatus.java     |  193 +
 .../nifi/controller/status/PortStatus.java      |  201 +
 .../controller/status/ProcessGroupStatus.java   |  547 ++
 .../nifi/controller/status/ProcessorStatus.java |  275 +
 .../status/RemoteProcessGroupStatus.java        |  217 +
 .../nifi/controller/status/RunStatus.java       |   28 +
 .../controller/status/TransmissionStatus.java   |   23 +
 .../history/ComponentStatusRepository.java      |  167 +
 .../status/history/MetricDescriptor.java        |   75 +
 .../status/history/StatusHistory.java           |   50 +
 .../status/history/StatusSnapshot.java          |   48 +
 .../controller/status/history/ValueMapper.java  |   23 +
 .../controller/status/history/ValueReducer.java |   25 +
 .../org/apache/nifi/events/EventReporter.java   |   27 +
 .../nifi/expression/AttributeExpression.java    |   79 +
 .../expression/AttributeValueDecorator.java     |   29 +
 .../expression/ExpressionLanguageCompiler.java  |   69 +
 .../java/org/apache/nifi/flowfile/FlowFile.java |  109 +
 .../nifi/flowfile/FlowFilePrioritizer.java      |   30 +
 .../java/org/apache/nifi/logging/LogLevel.java  |   27 +
 .../org/apache/nifi/logging/ProcessorLog.java   |   73 +
 .../nifi/processor/AbstractProcessor.java       |   37 +
 .../AbstractSessionFactoryProcessor.java        |  122 +
 .../org/apache/nifi/processor/DataUnit.java     |  248 +
 .../apache/nifi/processor/FlowFileFilter.java   |   91 +
 .../apache/nifi/processor/ProcessContext.java   |  124 +
 .../apache/nifi/processor/ProcessSession.java   |  719 ++
 .../nifi/processor/ProcessSessionFactory.java   |   30 +
 .../org/apache/nifi/processor/Processor.java    |   91 +
 .../ProcessorInitializationContext.java         |   53 +
 .../org/apache/nifi/processor/QueueSize.java    |   49 +
 .../org/apache/nifi/processor/Relationship.java |  127 +
 .../nifi/processor/SchedulingContext.java       |   70 +
 .../annotation/CapabilityDescription.java       |   39 +
 .../nifi/processor/annotation/EventDriven.java  |   49 +
 .../nifi/processor/annotation/OnAdded.java      |   41 +
 .../nifi/processor/annotation/OnRemoved.java    |   42 +
 .../nifi/processor/annotation/OnScheduled.java  |   44 +
 .../nifi/processor/annotation/OnShutdown.java   |   38 +
 .../nifi/processor/annotation/OnStopped.java    |   56 +
 .../processor/annotation/OnUnscheduled.java     |   46 +
 .../processor/annotation/SideEffectFree.java    |   45 +
 .../processor/annotation/SupportsBatching.java  |   51 +
 .../apache/nifi/processor/annotation/Tags.java  |   44 +
 .../processor/annotation/TriggerSerially.java   |   39 +
 .../TriggerWhenAnyDestinationAvailable.java     |   40 +
 .../processor/annotation/TriggerWhenEmpty.java  |   41 +
 .../exception/FlowFileAccessException.java      |   37 +
 .../exception/FlowFileHandlingException.java    |   39 +
 .../exception/MissingFlowFileException.java     |   37 +
 .../processor/exception/ProcessException.java   |   44 +
 .../nifi/processor/io/InputStreamCallback.java  |   38 +
 .../nifi/processor/io/OutputStreamCallback.java |   39 +
 .../nifi/processor/io/StreamCallback.java       |   41 +
 .../nifi/provenance/ProvenanceEventBuilder.java |  308 +
 .../nifi/provenance/ProvenanceEventRecord.java  |  296 +
 .../provenance/ProvenanceEventRepository.java   |  190 +
 .../nifi/provenance/ProvenanceEventType.java    |   92 +
 .../nifi/provenance/ProvenanceReporter.java     |  616 ++
 .../lineage/ComputeLineageResult.java           |   70 +
 .../lineage/ComputeLineageSubmission.java       |   82 +
 .../apache/nifi/provenance/lineage/Lineage.java |   41 +
 .../lineage/LineageComputationType.java         |   27 +
 .../nifi/provenance/lineage/LineageEdge.java    |   26 +
 .../nifi/provenance/lineage/LineageNode.java    |   61 +
 .../provenance/lineage/LineageNodeType.java     |   23 +
 .../lineage/ProvenanceEventLineageNode.java     |   32 +
 .../apache/nifi/provenance/search/Query.java    |   91 +
 .../nifi/provenance/search/QueryResult.java     |   77 +
 .../nifi/provenance/search/QuerySubmission.java |   63 +
 .../nifi/provenance/search/SearchTerm.java      |   24 +
 .../nifi/provenance/search/SearchTerms.java     |   39 +
 .../nifi/provenance/search/SearchableField.java |   62 +
 .../provenance/search/SearchableFieldType.java  |   28 +
 .../nifi/reporting/AbstractReportingTask.java   |   94 +
 .../org/apache/nifi/reporting/Bulletin.java     |  120 +
 .../apache/nifi/reporting/BulletinQuery.java    |  109 +
 .../nifi/reporting/BulletinRepository.java      |   88 +
 .../org/apache/nifi/reporting/EventAccess.java  |   53 +
 .../nifi/reporting/InitializationException.java |   32 +
 .../apache/nifi/reporting/ReportingContext.java |   99 +
 .../ReportingInitializationContext.java         |   80 +
 .../apache/nifi/reporting/ReportingTask.java    |   75 +
 .../org/apache/nifi/reporting/Severity.java     |   24 +
 .../nifi/scheduling/SchedulingStrategy.java     |   86 +
 .../org/apache/nifi/search/SearchContext.java   |   57 +
 .../org/apache/nifi/search/SearchResult.java    |   82 +
 .../java/org/apache/nifi/search/Searchable.java |   27 +
 .../nifi/web/ClusterRequestException.java       |   38 +
 .../nifi/web/InvalidRevisionException.java      |   33 +
 .../org/apache/nifi/web/NiFiWebContext.java     |  121 +
 .../apache/nifi/web/NiFiWebContextConfig.java   |   54 +
 .../nifi/web/ProcessorConfigurationAction.java  |  137 +
 .../java/org/apache/nifi/web/ProcessorInfo.java |  110 +
 .../nifi/web/ResourceNotFoundException.java     |   32 +
 .../main/java/org/apache/nifi/web/Revision.java |  110 +
 .../org/apache/nifi/processor/TestDataUnit.java |   44 +
 nifi-api/src/test/resources/logback-test.xml    |   27 +
 nifi-mock/pom.xml                               |   64 +
 .../MockProvenanceEventRepository.java          |  131 +
 .../apache/nifi/reporting/BulletinFactory.java  |   43 +
 .../org/apache/nifi/reporting/MockBulletin.java |   24 +
 .../util/ControllerServiceConfiguration.java    |   74 +
 .../nifi/util/MockBulletinRepository.java       |   74 +
 .../nifi/util/MockConfigurationContext.java     |   50 +
 ...kControllerServiceInitializationContext.java |   41 +
 .../nifi/util/MockControllerServiceLookup.java  |   76 +
 .../org/apache/nifi/util/MockEventAccess.java   |   70 +
 .../java/org/apache/nifi/util/MockFlowFile.java |  279 +
 .../org/apache/nifi/util/MockFlowFileQueue.java |   85 +
 .../apache/nifi/util/MockProcessContext.java    |  261 +
 .../apache/nifi/util/MockProcessSession.java    | 1010 ++
 .../MockProcessorInitializationContext.java     |   74 +
 .../org/apache/nifi/util/MockProcessorLog.java  |  402 +
 .../org/apache/nifi/util/MockPropertyValue.java |  185 +
 .../nifi/util/MockProvenanceReporter.java       |  202 +
 .../apache/nifi/util/MockReportingContext.java  |  117 +
 .../MockReportingInitializationContext.java     |   81 +
 .../apache/nifi/util/MockSessionFactory.java    |   46 +
 .../apache/nifi/util/MockValidationContext.java |   93 +
 .../org/apache/nifi/util/ReflectionUtils.java   |  149 +
 .../apache/nifi/util/SharedSessionState.java    |   91 +
 .../apache/nifi/util/SingleSessionFactory.java  |   35 +
 .../nifi/util/StandardProcessorTestRunner.java  |  485 +
 .../java/org/apache/nifi/util/TestRunner.java   |  531 ++
 .../java/org/apache/nifi/util/TestRunners.java  |   37 +
 2352 files changed, 350029 insertions(+)
----------------------------------------------------------------------



Mime
View raw message