Merge branch 'add-blob-api' of https://github.com/danny0405/storm into STORM-3036
STORM-3036: Add isRemoteBlobExists RPC interface Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/64af629a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/64af629a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/64af629a Branch: refs/heads/master Commit: 64af629a19a82591dbf3428f7fd6b02f39e0723f Parents: 9861f9a 26c4bec Author: Robert Evans <[email protected]> Authored: Fri May 25 07:34:16 2018 -0500 Committer: Robert Evans <[email protected]> Committed: Fri May 25 07:34:16 2018 -0500 ---------------------------------------------------------------------- .../hdfs/blobstore/HdfsClientBlobStore.java | 10 + .../apache/storm/blobstore/ClientBlobStore.java | 6 + .../blobstore/LocalModeClientBlobStore.java | 10 + .../apache/storm/blobstore/NimbusBlobStore.java | 11 + .../jvm/org/apache/storm/generated/Nimbus.java | 986 +++++++++++++++++++ storm-client/src/py/storm/Nimbus-remote | 7 + storm-client/src/py/storm/Nimbus.py | 205 ++++ storm-client/src/storm.thrift | 4 + .../storm/blobstore/ClientBlobStoreTest.java | 5 + .../java/org/apache/storm/LocalCluster.java | 5 + .../org/apache/storm/daemon/nimbus/Nimbus.java | 10 + .../LocalizedResourceRetentionSet.java | 18 +- .../storm/localizer/AsyncLocalizerTest.java | 1 + 13 files changed, 1269 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
