nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joew...@apache.org
Subject [28/50] [abbrv] incubator-nifi git commit: Merge branch 'develop' of http://git-wip-us.apache.org/repos/asf/incubator-nifi into develop
Date Mon, 02 Mar 2015 04:04:07 GMT
Merge branch 'develop' of http://git-wip-us.apache.org/repos/asf/incubator-nifi into develop


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

Branch: refs/heads/NIFI-360
Commit: 4ac6dfd5e5121291f11e2180072eb3bd5ff6d0a7
Parents: c5f4dff d8954ab
Author: Jenn Barnabee <jennifer.barnabee@gmail.com>
Authored: Tue Feb 24 13:45:49 2015 -0500
Committer: Jenn Barnabee <jennifer.barnabee@gmail.com>
Committed: Tue Feb 24 13:45:49 2015 -0500

----------------------------------------------------------------------
 .../apache/nifi/remote/RemoteDestination.java   |  53 +
 .../nifi-site-to-site-client/pom.xml            |  45 +
 .../remote/AbstractCommunicationsSession.java   |  54 ++
 .../org/apache/nifi/remote/Communicant.java     |  47 +
 .../main/java/org/apache/nifi/remote/Peer.java  | 151 +++
 .../org/apache/nifi/remote/PeerDescription.java |  79 ++
 .../java/org/apache/nifi/remote/PeerStatus.java |  60 ++
 .../nifi/remote/RemoteResourceInitiator.java    |  73 ++
 .../org/apache/nifi/remote/Transaction.java     | 214 ++++
 .../nifi/remote/TransactionCompletion.java      |  63 ++
 .../apache/nifi/remote/TransferDirection.java   |  34 +
 .../nifi/remote/VersionedRemoteResource.java    |  24 +
 .../nifi/remote/client/SiteToSiteClient.java    | 519 ++++++++++
 .../remote/client/SiteToSiteClientConfig.java   | 124 +++
 .../client/socket/EndpointConnection.java       |  54 ++
 .../client/socket/EndpointConnectionPool.java   | 970 +++++++++++++++++++
 .../nifi/remote/client/socket/SocketClient.java | 218 +++++
 .../remote/cluster/AdaptedNodeInformation.java  |  66 ++
 .../remote/cluster/ClusterNodeInformation.java  |  67 ++
 .../nifi/remote/cluster/NodeInformation.java    |  98 ++
 .../remote/cluster/NodeInformationAdapter.java  |  41 +
 .../apache/nifi/remote/codec/FlowFileCodec.java |  71 ++
 .../remote/codec/StandardFlowFileCodec.java     | 129 +++
 .../remote/exception/HandshakeException.java    |  37 +
 .../exception/PortNotRunningException.java      |  30 +
 .../remote/exception/ProtocolException.java     |  40 +
 .../remote/exception/UnknownPortException.java  |  29 +
 .../SocketChannelCommunicationsSession.java     |  90 ++
 .../remote/io/socket/SocketChannelInput.java    |  71 ++
 .../remote/io/socket/SocketChannelOutput.java   |  58 ++
 .../SSLSocketChannelCommunicationsSession.java  |  93 ++
 .../io/socket/ssl/SSLSocketChannelInput.java    |  55 ++
 .../io/socket/ssl/SSLSocketChannelOutput.java   |  44 +
 .../nifi/remote/protocol/ClientProtocol.java    |  86 ++
 .../remote/protocol/CommunicationsInput.java    |  33 +
 .../remote/protocol/CommunicationsOutput.java   |  27 +
 .../remote/protocol/CommunicationsSession.java  |  64 ++
 .../apache/nifi/remote/protocol/DataPacket.java |  45 +
 .../nifi/remote/protocol/RequestType.java       |  43 +
 .../protocol/socket/HandshakeProperty.java      |  61 ++
 .../nifi/remote/protocol/socket/Response.java   |  51 +
 .../remote/protocol/socket/ResponseCode.java    | 153 +++
 .../protocol/socket/SocketClientProtocol.java   | 438 +++++++++
 .../socket/SocketClientTransaction.java         | 399 ++++++++
 .../SocketClientTransactionCompletion.java      |  57 ++
 .../nifi/remote/util/NiFiRestApiUtil.java       |  98 ++
 .../nifi/remote/util/PeerStatusCache.java       |  43 +
 .../nifi/remote/util/StandardDataPacket.java    |  50 +
 .../socket/TestEndpointConnectionStatePool.java |  95 ++
 .../client/socket/TestSiteToSiteClient.java     | 105 ++
 .../nifi/remote/io/CompressionInputStream.java  |   2 +-
 .../io/socket/SocketChannelInputStream.java     |  10 +
 .../remote/io/socket/ssl/SSLSocketChannel.java  |  10 +
 .../socket/ssl/SSLSocketChannelInputStream.java |   4 +
 .../nifi/stream/io/LimitingInputStream.java     | 111 +++
 .../stream/io/MinimumLengthInputStream.java     |  93 ++
 nifi/nifi-commons/pom.xml                       |   1 +
 nifi/nifi-external/README.md                    |  19 +
 nifi/nifi-external/nifi-spark-receiver/pom.xml  |  37 +
 .../org/apache/nifi/spark/NiFiDataPacket.java   |  40 +
 .../org/apache/nifi/spark/NiFiReceiver.java     | 198 ++++
 nifi/nifi-external/pom.xml                      |  29 +
 .../nifi-framework/nifi-cluster/pom.xml         |   4 +
 .../nifi/cluster/manager/ClusterManager.java    |  18 +-
 .../cluster/manager/impl/WebClusterManager.java |   9 +-
 .../nifi-framework-core-api/pom.xml             |   4 +
 .../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/controller/StandardFunnel.java  |   2 +-
 .../apache/nifi/groups/RemoteProcessGroup.java  |  39 +-
 .../main/java/org/apache/nifi/remote/Peer.java  | 107 --
 .../java/org/apache/nifi/remote/PeerStatus.java |  72 --
 .../org/apache/nifi/remote/RemoteGroupPort.java |  22 +-
 .../apache/nifi/remote/TransferDirection.java   |  23 -
 .../nifi/remote/VersionedRemoteResource.java    |  24 -
 .../nifi/remote/cluster/NodeInformant.java      |  22 +
 .../apache/nifi/remote/codec/FlowFileCodec.java |  79 --
 .../remote/exception/HandshakeException.java    |  30 -
 .../exception/PortNotRunningException.java      |  26 -
 .../remote/exception/ProtocolException.java     |  34 -
 .../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    |   2 +-
 .../nifi-framework/nifi-framework-core/pom.xml  |   4 +
 .../apache/nifi/controller/FlowController.java  |   5 +-
 .../scheduling/QuartzSchedulingAgent.java       |  21 +-
 .../controller/scheduling/ScheduleState.java    |  18 +-
 .../scheduling/TimerDrivenSchedulingAgent.java  | 115 ++-
 .../tasks/ContinuallyRunConnectableTask.java    |  32 +-
 .../tasks/ContinuallyRunProcessorTask.java      |  32 +-
 .../org/apache/nifi/remote/RemoteNiFiUtils.java | 216 +++++
 .../nifi/remote/StandardRemoteProcessGroup.java | 309 +-----
 .../nifi-framework/nifi-site-to-site/.gitignore |   1 +
 .../util/RemoteProcessGroupUtils.class          | Bin 0 -> 9526 bytes
 .../remote/AbstractCommunicationsSession.class  | Bin 0 -> 2308 bytes
 .../nifi/remote/RemoteResourceFactory.class     | Bin 0 -> 8707 bytes
 .../nifi/remote/RemoteResourceManager.class     | Bin 0 -> 6898 bytes
 .../apache/nifi/remote/RemoteSiteListener.class | Bin 0 -> 841 bytes
 .../nifi/remote/SocketRemoteSiteListener.class  | Bin 0 -> 8448 bytes
 ...emoteGroupPort$EndpointConnectionState.class | Bin 0 -> 5427 bytes
 .../nifi/remote/StandardRemoteGroupPort.class   | Bin 0 -> 10677 bytes
 .../StandardRootGroupPort$FlowFileRequest.class | Bin 0 -> 5836 bytes
 ...StandardRootGroupPort$ProcessingResult.class | Bin 0 -> 5032 bytes
 ...upPort$StandardPortAuthorizationResult.class | Bin 0 -> 5159 bytes
 .../nifi/remote/StandardRootGroupPort.class     | Bin 0 -> 9700 bytes
 .../remote/codec/StandardFlowFileCodec.class    | Bin 0 -> 8538 bytes
 .../exception/UnsupportedCodecException.class   | Bin 0 -> 1057 bytes
 .../SocketChannelCommunicationsSession.class    | Bin 0 -> 3735 bytes
 .../remote/io/socket/SocketChannelInput.class   | Bin 0 -> 4008 bytes
 .../remote/io/socket/SocketChannelOutput.class  | Bin 0 -> 3741 bytes
 .../SSLSocketChannelCommunicationsSession.class | Bin 0 -> 4611 bytes
 .../io/socket/ssl/SSLSocketChannelInput.class   | Bin 0 -> 3127 bytes
 .../io/socket/ssl/SSLSocketChannelOutput.class  | Bin 0 -> 2587 bytes
 .../socket/ClusterManagerServerProtocol.class   | Bin 0 -> 10540 bytes
 .../protocol/socket/HandshakeProperty.class     | Bin 0 -> 917 bytes
 .../nifi/remote/protocol/socket/Response.class  | Bin 0 -> 2674 bytes
 .../remote/protocol/socket/ResponseCode.class   | Bin 0 -> 6889 bytes
 .../protocol/socket/SocketClientProtocol.class  | Bin 0 -> 8965 bytes
 .../socket/SocketFlowFileServerProtocol.class   | Bin 0 -> 8806 bytes
 .../remote/TestStandardRemoteGroupPort.class    | Bin 0 -> 5974 bytes
 .../nifi-framework/nifi-site-to-site/pom.xml    |   4 +
 .../remote/AbstractCommunicationsSession.java   |  54 --
 .../nifi/remote/RemoteResourceFactory.java      |  50 +-
 .../nifi/remote/SocketRemoteSiteListener.java   |  16 +-
 .../nifi/remote/StandardRemoteGroupPort.java    | 685 ++++---------
 .../remote/codec/StandardFlowFileCodec.java     | 169 ----
 .../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    |   7 +-
 .../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    | 195 ++--
 .../remote/TestStandardRemoteGroupPort.java     |  97 --
 .../web/api/RemoteProcessGroupResource.java     |   8 +
 .../canvas/new-remote-process-group-dialog.jsp  |   2 +-
 .../src/main/webapp/js/nf/canvas/nf-actions.js  |  26 +-
 .../main/webapp/js/nf/canvas/nf-context-menu.js |   2 +-
 .../hadoop/CreateHadoopSequenceFile.java        |   4 +-
 .../standard/Base64EncodeContent.java           |  13 +-
 .../processors/standard/CompressContent.java    |  27 +-
 .../nifi/processors/standard/HashContent.java   |  14 +-
 .../nifi/processors/standard/PutEmail.java      |   5 +-
 .../processors/standard/SegmentContent.java     | 114 ++-
 .../nifi/processors/standard/TransformXml.java  |   3 +-
 .../standard/TestCompressContent.java           |  18 +
 .../nifi/processors/standard/TestPutEmail.java  |  45 +
 nifi/pom.xml                                    |   6 +
 160 files changed, 7186 insertions(+), 3545 deletions(-)
----------------------------------------------------------------------



Mime
View raw message