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 <joew...@apache.org> Authored: Mon Dec 8 15:22:14 2014 -0500 Committer: joewitt <joew...@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(+) ----------------------------------------------------------------------