Index: UIDs =================================================================== --- UIDs +++ UIDs @@ -75,7 +75,7 @@ synapse:*:126:65534::0:0:Synapse Daemon:/nonexistent:/usr/sbin/nologin navcron:*:127:127::0:0:Network Administration Visualized:/usr/local/nav:/usr/sbin/nologin sd-agent:*:128:128::0:0:ServerDensity Agent:/nonexistent:/usr/sbin/nologin -# free: 129 +storm:*:129:65534::0:0:Storm Daemon:/nonexistent:/usr/sbin/nologin _bgpd:*:130:130::0:0:BGP Daemon:/var/empty:/usr/sbin/nologin _ospfd:*:131:131::0:0:OSPF Daemon:/var/empty:/usr/sbin/nologin _spamd:*:132:132::0:0:Spam Daemon:/var/empty:/usr/sbin/nologin Index: devel/storm/Makefile =================================================================== --- devel/storm/Makefile +++ devel/storm/Makefile @@ -2,44 +2,46 @@ # $FreeBSD$ PORTNAME= storm -DISTVERSION= 0.9.2-incubating +PORTVERSION= 1.0.2 +MASTER_SITES= APACHE/${PORTNAME}/apache-${PORTNAME}-${PORTVERSION} CATEGORIES= devel java -MASTER_SITES= APACHE/incubator/${PORTNAME}/apache-${PORTNAME}-${DISTVERSION} -DISTNAME= apache-storm-${DISTVERSION} +DISTNAME= apache-${PORTNAME}-${PORTVERSION} MAINTAINER= hsn@sendmail.cz COMMENT= Distributed realtime computation system LICENSE= APACHE20 -USES= python:2.7 +USERS= storm + +USES= python:2.7,run shebangfix +SHEBANG_FILES= bin/storm.py USE_JAVA= yes JAVA_VERSION= 1.7 JAVA_VENDOR= openjdk NO_ARCH= yes -USE_RC_SUBR= storm-nimbus storm-supervisor +USE_RC_SUBR= storm-logviewer storm-nimbus storm-supervisor storm-ui +SUB_LIST= JAVA="${JAVA}" NO_BUILD= yes -STORM_DIRS= bin examples external lib public -STORM_CFG_DIRS= conf logback -STORM_CFG_FILES= conf/storm.yaml conf/storm_env.ini logback/cluster.xml - -post-extract: - ${RM} ${WRKSRC}/bin/*.cmd +STORM_DIRS= examples external lib public +STORM_CFG_DIRS= conf log4j2 +STORM_CFG_FILES= conf/storm.yaml conf/storm_env.ini conf/storm-env.sh log4j2/cluster.xml log4j2/worker.xml post-patch: - ${REINPLACE_CMD} -e "s|/usr/bin/python|${LOCALBASE}/bin/python2.7|" ${WRKSRC}/bin/storm - ${RM} ${WRKSRC}/bin/*.bak + ${REINPLACE_CMD} 's|$${sys:storm.log.dir}|/var/log/storm|g' ${WRKSRC}/log4j2/cluster.xml .for i in ${STORM_CFG_FILES} ${MV} ${WRKSRC}/${i} ${WRKSRC}/${i}.sample .endfor do-install: - ${MKDIR} ${STAGEDIR}${DATADIR} - cd ${WRKSRC} && ${FIND} ${STORM_DIRS} ${STORM_CFG_DIRS} | \ + ${MKDIR} ${STAGEDIR}${DATADIR}/bin ${STAGEDIR}${ETCDIR} + cd ${WRKSRC} && ${FIND} ${STORM_DIRS} | \ ${CPIO} --quiet -pdmu ${STAGEDIR}${DATADIR} - ${INSTALL_DATA} ${WRKSRC}/RELEASE ${STAGEDIR}${DATADIR} - ${LN} -sf ${DATADIR}/bin/storm ${STAGEDIR}${PREFIX}/bin/storm + (cd ${WRKSRC}/conf && ${COPYTREE_SHARE} . ${STAGEDIR}/${ETCDIR}) + (cd ${WRKSRC} && ${COPYTREE_SHARE} log4j2 ${STAGEDIR}/${ETCDIR}) + ${INSTALL_SCRIPT} ${WRKSRC}/bin/storm.py ${STAGEDIR}${DATADIR}/bin + ${LN} -sf ${DATADIR}/bin/storm.py ${STAGEDIR}${LOCALBASE}/bin/storm .include Index: devel/storm/distinfo =================================================================== --- devel/storm/distinfo +++ devel/storm/distinfo @@ -1,2 +1,3 @@ -SHA256 (apache-storm-0.9.2-incubating.tar.gz) = 8881e8e95bc8bc258dcba7b8be0b7ded942795f69f4aa6c682c9f3c4d927c492 -SIZE (apache-storm-0.9.2-incubating.tar.gz) = 20077564 +TIMESTAMP = 1485463470 +SHA256 (apache-storm-1.0.2.tar.gz) = b3fd2475e88e4b5e30f0e47eab70363419d67c15ddc7fe1f3c423ac0499eb76e +SIZE (apache-storm-1.0.2.tar.gz) = 179161400 Index: devel/storm/files/patch-bin_storm.py =================================================================== --- /dev/null +++ devel/storm/files/patch-bin_storm.py @@ -0,0 +1,11 @@ +--- bin/storm.py.orig 2017-01-26 21:54:56 UTC ++++ bin/storm.py +@@ -81,7 +81,7 @@ if (not os.path.isfile(os.path.join(USER + + STORM_LIB_DIR = os.path.join(STORM_DIR, "lib") + STORM_BIN_DIR = os.path.join(STORM_DIR, "bin") +-STORM_LOG4J2_CONF_DIR = os.path.join(STORM_DIR, "log4j2") ++STORM_LOG4J2_CONF_DIR = os.path.join(STORM_CONF_DIR, "log4j2") + STORM_SUPERVISOR_LOG_FILE = os.getenv('STORM_SUPERVISOR_LOG_FILE', "supervisor.log") + + init_storm_env() Index: devel/storm/files/storm-logviewer.in =================================================================== --- devel/storm/files/storm-logviewer.in +++ devel/storm/files/storm-logviewer.in @@ -23,38 +23,51 @@ # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH # DAMAGE. - -# PROVIDE: storm-nimbus +# +# $FreeBSD: head/devel/storm/files/storm-logviewer.in 366824 2014-08-31 19:55:55Z riggs $ +# +# PROVIDE: storm-logviewer # REQUIRE: LOGIN # KEYWORD: shutdown -# -# $FreeBSD: head/devel/storm/files/storm-nimbus.in 366824 2014-08-31 19:55:55Z riggs $ . /etc/rc.subr -name="storm_nimbus" -rcvar=storm_nimbus_enable +name=storm_logviewer +rcvar=storm_logviewer_enable load_rc_config $name -: ${storm_nimbus_enable:="NO"} -: ${storm_nimbus_wrkdir:="/var/cache/storm"} +: ${storm_logviewer_enable:=NO} +: ${storm_wrkdir:=/var/cache/storm} +: ${storm_config:="%%ETCDIR%%/storm.yaml"} +: ${storm_user:=storm} +: ${storm_logviewer_user:=${storm_user}} -required_files="%%DATADIR%%/bin/storm %%DATADIR%%/conf/storm.yaml" -pidfile=/var/run/storm-nimbus.pid +required_files="%%LOCALBASE%%/bin/storm ${storm_config}" +pidfile=/var/run/storm/storm-logviewer.pid command=/usr/sbin/daemon -command_args="-f -p ${pidfile} %%DATADIR%%/bin/storm nimbus" +command_args="-p ${pidfile} %%LOCALBASE%%/bin/storm --config ${storm_config} logviewer 2>&1 | /usr/bin/logger -t storm-logviewer &" start_precmd="${name}_prestart" -procname="%%LOCALBASE%%/openjdk7/bin/java" +procname="%%JAVA%%" -export PATH=$PATH:%%LOCALBASE%%/bin -export JAVA_VENDOR=openjdk -export JAVA_VERSION=1.7 - -storm_nimbus_prestart() { - mkdir -p ${storm_nimbus_wrkdir} - chmod 740 ${storm_nimbus_wrkdir} - cd ${storm_nimbus_wrkdir} - return 0 +storm_logviewer_prestart() +{ + export PATH=$PATH:%%LOCALBASE%%/bin + export JAVA_VENDOR=%%JAVA_VENDOR%% + export JAVA_VERSION=%%JAVA_VERSION%% + export STORM_CONF_FILE="${storm_config}" + export STORM_CONF_DIR="${storm_config%/*}" + + if ! [ -d ${storm_wrkdir} ]; then + install -d -o ${storm_logviewer_user} -g wheel ${storm_wrkdir} + fi + + if ! [ -d ${pidfile%/*} ]; then + install -d -o ${storm_logviewer_user} -g wheel ${pidfile%/*} + fi + + if ! [ -d /var/log/storm ]; then + install -d -o ${storm_logviewer_user} -g wheel /var/log/storm + fi } run_rc_command "$1" Index: devel/storm/files/storm-nimbus.in =================================================================== --- devel/storm/files/storm-nimbus.in +++ devel/storm/files/storm-nimbus.in @@ -23,38 +23,51 @@ # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH # DAMAGE. - +# +# $FreeBSD$ +# # PROVIDE: storm-nimbus # REQUIRE: LOGIN # KEYWORD: shutdown -# -# $FreeBSD$ . /etc/rc.subr -name="storm_nimbus" +name=storm_nimbus rcvar=storm_nimbus_enable load_rc_config $name -: ${storm_nimbus_enable:="NO"} -: ${storm_nimbus_wrkdir:="/var/cache/storm"} +: ${storm_nimbus_enable:=NO} +: ${storm_wrkdir:=/var/cache/storm} +: ${storm_config:="%%ETCDIR%%/storm.yaml"} +: ${storm_user:=storm} +: ${storm_nimbus_user:=${storm_user}} -required_files="%%DATADIR%%/bin/storm %%DATADIR%%/conf/storm.yaml" -pidfile=/var/run/storm-nimbus.pid +required_files="%%LOCALBASE%%/bin/storm ${storm_config}" +pidfile=/var/run/storm/storm-nimbus.pid command=/usr/sbin/daemon -command_args="-f -p ${pidfile} %%DATADIR%%/bin/storm nimbus" +command_args="-p ${pidfile} %%LOCALBASE%%/bin/storm --config ${storm_config} nimbus 2>&1 | /usr/bin/logger -t storm-nimbus &" start_precmd="${name}_prestart" -procname="%%LOCALBASE%%/openjdk7/bin/java" +procname="%%JAVA%%" -export PATH=$PATH:%%LOCALBASE%%/bin -export JAVA_VENDOR=openjdk -export JAVA_VERSION=1.7 - -storm_nimbus_prestart() { - mkdir -p ${storm_nimbus_wrkdir} - chmod 740 ${storm_nimbus_wrkdir} - cd ${storm_nimbus_wrkdir} - return 0 +storm_nimbus_prestart() +{ + export PATH=$PATH:%%LOCALBASE%%/bin + export JAVA_VENDOR=%%JAVA_VENDOR%% + export JAVA_VERSION=%%JAVA_VERSION%% + export STORM_CONF_FILE="${storm_config}" + export STORM_CONF_DIR="${storm_config%/*}" + + if ! [ -d ${storm_wrkdir} ]; then + install -d -o ${storm_nimbus_user} -g wheel ${storm_wrkdir} + fi + + if ! [ -d ${pidfile%/*} ]; then + install -d -o ${storm_nimbus_user} -g wheel ${pidfile%/*} + fi + + if ! [ -d /var/log/storm ]; then + install -d -o ${storm_nimbus_user} -g wheel /var/log/storm + fi } run_rc_command "$1" Index: devel/storm/files/storm-supervisor.in =================================================================== --- devel/storm/files/storm-supervisor.in +++ devel/storm/files/storm-supervisor.in @@ -23,38 +23,50 @@ # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH # DAMAGE. - +# +# $FreeBSD$ +# # PROVIDE: storm-supervisor # REQUIRE: LOGIN # KEYWORD: shutdown -# -# $FreeBSD$ . /etc/rc.subr -name="storm_supervisor" +name=storm_supervisor rcvar=storm_supervisor_enable load_rc_config $name -: ${storm_supervisor_enable:="NO"} -: ${storm_supervisor_wrkdir:="/var/db/storm-supervisor"} +: ${storm_supervisor_enable:=NO} +: ${storm_wrkdir:=/var/db/storm-supervisor} +: ${storm_config:="%%ETCDIR%%/storm.yaml"} +: ${storm_user:=storm} +: ${storm_supervisor_user:=${storm_user}} -required_files="%%DATADIR%%/bin/storm %%DATADIR%%/conf/storm.yaml" -pidfile=/var/run/storm-supervisor.pid +required_files="%%LOCALBASE%%/bin/storm ${storm_config}" +pidfile=/var/run/storm/storm-supervisor.pid command=/usr/sbin/daemon -command_args="-f -r -P ${pidfile} %%DATADIR%%/bin/storm supervisor" +command_args="-r -P ${pidfile} %%LOCALBASE%%/bin/storm --config ${storm_config} supervisor 2>&1 | /usr/bin/logger -t storm-supervisor &" start_precmd="${name}_prestart" -#procname="%%LOCALBASE%%/openjdk7/bin/java" -export PATH=$PATH:%%LOCALBASE%%/bin -export JAVA_VENDOR=openjdk -export JAVA_VERSION=1.7 - -storm_supervisor_prestart() { - mkdir -p ${storm_supervisor_wrkdir} - chmod 740 ${storm_supervisor_wrkdir} - cd ${storm_supervisor_wrkdir} - return 0 +storm_supervisor_prestart() +{ + export PATH=$PATH:%%LOCALBASE%%/bin + export JAVA_VENDOR=%%JAVA_VENDOR%% + export JAVA_VERSION=%%JAVA_VERSION%% + export STORM_CONF_FILE="${storm_config}" + export STORM_CONF_DIR="${storm_config%/*}" + + if ! [ -d ${storm_wrkdir} ]; then + install -d -o ${storm_supervisor_user} -g wheel ${storm_wrkdir} + fi + + if ! [ -d ${pidfile%/*} ]; then + install -d -o ${storm_supervisor_user} -g wheel ${pidfile%/*} + fi + + if ! [ -d /var/log/storm ]; then + install -d -o ${storm_supervisor_user} -g wheel /var/log/storm + fi } run_rc_command "$1" Index: devel/storm/files/storm-ui.in =================================================================== --- devel/storm/files/storm-ui.in +++ devel/storm/files/storm-ui.in @@ -23,38 +23,51 @@ # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH # DAMAGE. - -# PROVIDE: storm-nimbus +# +# $FreeBSD: head/devel/storm/files/storm-ui.in 366824 2014-08-31 19:55:55Z riggs $ +# +# PROVIDE: storm-ui # REQUIRE: LOGIN # KEYWORD: shutdown -# -# $FreeBSD: head/devel/storm/files/storm-nimbus.in 366824 2014-08-31 19:55:55Z riggs $ . /etc/rc.subr -name="storm_nimbus" -rcvar=storm_nimbus_enable +name=storm_ui +rcvar=storm_ui_enable load_rc_config $name -: ${storm_nimbus_enable:="NO"} -: ${storm_nimbus_wrkdir:="/var/cache/storm"} +: ${storm_ui_enable:=NO} +: ${storm_wrkdir:=/var/cache/storm} +: ${storm_config:="%%ETCDIR%%/storm.yaml"} +: ${storm_user:=storm} +: ${storm_ui_user:=${storm_user}} + -required_files="%%DATADIR%%/bin/storm %%DATADIR%%/conf/storm.yaml" -pidfile=/var/run/storm-nimbus.pid +required_files="%%LOCALBASE%%/bin/storm ${storm_config}" +pidfile=/var/run/storm/storm-ui.pid command=/usr/sbin/daemon -command_args="-f -p ${pidfile} %%DATADIR%%/bin/storm nimbus" +command_args="-p ${pidfile} %%LOCALBASE%%/bin/storm --config ${storm_config} ui 2>&1 | /usr/bin/logger -t storm-ui &" start_precmd="${name}_prestart" -procname="%%LOCALBASE%%/openjdk7/bin/java" +procname="%%JAVA%%" -export PATH=$PATH:%%LOCALBASE%%/bin -export JAVA_VENDOR=openjdk -export JAVA_VERSION=1.7 - -storm_nimbus_prestart() { - mkdir -p ${storm_nimbus_wrkdir} - chmod 740 ${storm_nimbus_wrkdir} - cd ${storm_nimbus_wrkdir} - return 0 +storm_ui_prestart() { + export PATH=$PATH:%%LOCALBASE%%/bin + export JAVA_VENDOR=%%JAVA_VENDOR%% + export JAVA_VERSION=%%JAVA_VERSION%% + export STORM_CONF_FILE="${storm_config}" + export STORM_CONF_DIR="${storm_config%/*}" + + if ! [ -d ${storm_wrkdir} ]; then + install -d -o ${storm_ui_user} -g wheel ${storm_wrkdir} + fi + + if ! [ -d ${pidfile%/*} ]; then + install -d -o ${storm_ui_user} -g wheel ${pidfile%/*} + fi + + if ! [ -d /var/log/storm ]; then + install -d -o ${storm_ui_user} -g wheel /var/log/storm + fi } run_rc_command "$1" Index: devel/storm/pkg-plist =================================================================== --- devel/storm/pkg-plist +++ devel/storm/pkg-plist @@ -1,126 +1,239 @@ bin/storm -%%DATADIR%%/RELEASE -@mode 0555 -%%DATADIR%%/bin/storm -@mode -%%DATADIR%%/examples/storm-starter/storm-starter-topologies-0.9.2-incubating.jar +@sample %%ETCDIR%%/storm-env.sh.sample +@sample %%ETCDIR%%/storm.yaml.sample +@sample %%ETCDIR%%/storm_env.ini.sample +@sample %%ETCDIR%%/log4j2/cluster.xml.sample +@sample %%ETCDIR%%/log4j2/worker.xml.sample +%%DATADIR%%/bin/storm.py +%%DATADIR%%/examples/storm-starter/README.markdown +%%DATADIR%%/examples/storm-starter/dependency-reduced-pom.xml +%%DATADIR%%/examples/storm-starter/multilang/resources/asyncSplitsentence.js +%%DATADIR%%/examples/storm-starter/multilang/resources/randomsentence.js +%%DATADIR%%/examples/storm-starter/multilang/resources/splitsentence.js %%DATADIR%%/examples/storm-starter/multilang/resources/splitsentence.py %%DATADIR%%/examples/storm-starter/multilang/resources/splitsentence.rb -%%DATADIR%%/examples/storm-starter/multilang/resources/storm.py -%%DATADIR%%/examples/storm-starter/multilang/resources/storm.rb -%%DATADIR%%/examples/storm-starter/src/clj/storm/starter/clj/word_count.clj -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/AbstractRankerBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/IntermediateRankingsBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/PrinterBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/RollingCountBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/SingleJoinBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/bolt/TotalRankingsBolt.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/spout/RandomSentenceSpout.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/spout/TwitterSampleSpout.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/NthLastModifiedTimeTracker.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/Rankable.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/RankableObjectWithFields.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/Rankings.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/SlidingWindowCounter.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/tools/SlotBasedCounter.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/trident/TridentReach.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/trident/TridentWordCount.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/util/StormRunner.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/util/TupleHelpers.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/ExclamationTopology.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/ManualDRPC.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/ReachTopology.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/RollingTopWords.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/SingleJoinExample.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/TransactionalGlobalCount.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/TransactionalWords.java -%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/WordCountTopology.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/bolt/IntermediateRankingsBoltTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/bolt/RollingCountBoltTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/bolt/TotalRankingsBoltTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/NthLastModifiedTimeTrackerTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/RankableObjectWithFieldsTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/RankingsTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/SlidingWindowCounterTest.java -%%DATADIR%%/examples/storm-starter/test/jvm/storm/starter/tools/SlotBasedCounterTest.java %%DATADIR%%/examples/storm-starter/pom.xml -%%DATADIR%%/examples/storm-starter/README.markdown -%%DATADIR%%/external/storm-kafka/storm-kafka-0.9.2-incubating.jar +%%DATADIR%%/examples/storm-starter/src/clj/org/apache/storm/starter/clj/word_count.clj +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/BasicDRPCTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/FastWordCountTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/InOrderDeliveryTest.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/MultipleLoggerTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/PrintSampleStream.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/ReachTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/ResourceAwareExampleTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/RollingTopWords.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/SingleJoinExample.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/SkewedRollingTopWords.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/SlidingTupleTsTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/SlidingWindowTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/ThroughputVsLatency.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/TransactionalGlobalCount.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/TransactionalWords.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopologyNode.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/AbstractRankerBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/IntermediateRankingsBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/PrinterBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SingleJoinBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SlidingWindowSumBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/TotalRankingsBolt.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomIntegerSpout.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomNumberGeneratorSpout.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomSentenceSpout.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTracker.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankable.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankings.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlidingWindowCounter.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentHBaseWindowingStoreTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentKafkaWordCount.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMapExample.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfDevicesTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfVehiclesTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentReach.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentWindowingInmemoryStoreTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentWordCount.java +%%DATADIR%%/examples/storm-starter/src/jvm/org/apache/storm/starter/util/StormRunner.java +%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/HdfsSpoutTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/StatefulTopology.java +%%DATADIR%%/examples/storm-starter/src/jvm/storm/starter/StatefulWindowingTopology.java +%%DATADIR%%/examples/storm-starter/storm-starter-topologies-1.0.2.jar +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/IntermediateRankingsBoltTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/RollingCountBoltTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/TotalRankingsBoltTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTrackerTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankableObjectWithFieldsTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankingsTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/tools/SlidingWindowCounterTest.java +%%DATADIR%%/examples/storm-starter/test/jvm/org/apache/storm/starter/tools/SlotBasedCounterTest.java +%%DATADIR%%/external/flux/README.md +%%DATADIR%%/external/flux/examples/README.md +%%DATADIR%%/external/flux/examples/hbase_bolt.properties +%%DATADIR%%/external/flux/examples/hdfs_bolt.properties +%%DATADIR%%/external/flux/examples/kafka_spout.yaml +%%DATADIR%%/external/flux/examples/multilang.yaml +%%DATADIR%%/external/flux/examples/simple_hbase.yaml +%%DATADIR%%/external/flux/examples/simple_hdfs.yaml +%%DATADIR%%/external/flux/examples/simple_stateful_wordcount.yaml +%%DATADIR%%/external/flux/examples/simple_windowing.yaml +%%DATADIR%%/external/flux/examples/simple_wordcount.yaml +%%DATADIR%%/external/flux/flux-core-1.0.2-javadoc.jar +%%DATADIR%%/external/flux/flux-core-1.0.2-sources.jar +%%DATADIR%%/external/flux/flux-core-1.0.2.jar +%%DATADIR%%/external/flux/flux-examples-1.0.2-javadoc.jar +%%DATADIR%%/external/flux/flux-examples-1.0.2-sources.jar +%%DATADIR%%/external/flux/flux-examples-1.0.2.jar +%%DATADIR%%/external/flux/flux-wrappers-1.0.2-javadoc.jar +%%DATADIR%%/external/flux/flux-wrappers-1.0.2-sources.jar +%%DATADIR%%/external/flux/flux-wrappers-1.0.2.jar +%%DATADIR%%/external/sql/README.md +%%DATADIR%%/external/sql/storm-sql-core/calcite-avatica-1.4.0-incubating.jar +%%DATADIR%%/external/sql/storm-sql-core/calcite-core-1.4.0-incubating.jar +%%DATADIR%%/external/sql/storm-sql-core/calcite-linq4j-1.4.0-incubating.jar +%%DATADIR%%/external/sql/storm-sql-core/commons-lang-2.5.jar +%%DATADIR%%/external/sql/storm-sql-core/eigenbase-properties-1.1.5.jar +%%DATADIR%%/external/sql/storm-sql-core/guava-16.0.1.jar +%%DATADIR%%/external/sql/storm-sql-core/jackson-annotations-2.6.3.jar +%%DATADIR%%/external/sql/storm-sql-core/jackson-core-2.6.3.jar +%%DATADIR%%/external/sql/storm-sql-core/jackson-databind-2.6.3.jar +%%DATADIR%%/external/sql/storm-sql-core/storm-sql-core-1.0.2.jar +%%DATADIR%%/external/sql/storm-sql-kafka/storm-sql-kafka-1.0.2-javadoc.jar +%%DATADIR%%/external/sql/storm-sql-kafka/storm-sql-kafka-1.0.2-sources.jar +%%DATADIR%%/external/sql/storm-sql-kafka/storm-sql-kafka-1.0.2.jar +%%DATADIR%%/external/sql/storm-sql-runtime/storm-sql-runtime-1.0.2-javadoc.jar +%%DATADIR%%/external/sql/storm-sql-runtime/storm-sql-runtime-1.0.2-sources.jar +%%DATADIR%%/external/sql/storm-sql-runtime/storm-sql-runtime-1.0.2-tests.jar +%%DATADIR%%/external/sql/storm-sql-runtime/storm-sql-runtime-1.0.2.jar +%%DATADIR%%/external/storm-cassandra/storm-cassandra-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-cassandra/storm-cassandra-1.0.2-sources.jar +%%DATADIR%%/external/storm-cassandra/storm-cassandra-1.0.2.jar +%%DATADIR%%/external/storm-elasticsearch/README.md +%%DATADIR%%/external/storm-elasticsearch/storm-elasticsearch-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-elasticsearch/storm-elasticsearch-1.0.2-sources.jar +%%DATADIR%%/external/storm-elasticsearch/storm-elasticsearch-1.0.2.jar +%%DATADIR%%/external/storm-eventhubs/README.md +%%DATADIR%%/external/storm-eventhubs/storm-eventhubs-1.0.2-jar-with-dependencies.jar +%%DATADIR%%/external/storm-eventhubs/storm-eventhubs-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-eventhubs/storm-eventhubs-1.0.2-sources.jar +%%DATADIR%%/external/storm-eventhubs/storm-eventhubs-1.0.2.jar +%%DATADIR%%/external/storm-hbase/README.md +%%DATADIR%%/external/storm-hbase/storm-hbase-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-hbase/storm-hbase-1.0.2-sources.jar +%%DATADIR%%/external/storm-hbase/storm-hbase-1.0.2.jar +%%DATADIR%%/external/storm-hdfs/README.md +%%DATADIR%%/external/storm-hdfs/storm-hdfs-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-hdfs/storm-hdfs-1.0.2-sources.jar +%%DATADIR%%/external/storm-hdfs/storm-hdfs-1.0.2-tests.jar +%%DATADIR%%/external/storm-hdfs/storm-hdfs-1.0.2.jar +%%DATADIR%%/external/storm-hive/README.md +%%DATADIR%%/external/storm-hive/storm-hive-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-hive/storm-hive-1.0.2-sources.jar +%%DATADIR%%/external/storm-hive/storm-hive-1.0.2-tests.jar +%%DATADIR%%/external/storm-hive/storm-hive-1.0.2.jar +%%DATADIR%%/external/storm-jdbc/README.md +%%DATADIR%%/external/storm-jdbc/storm-jdbc-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-jdbc/storm-jdbc-1.0.2-sources.jar +%%DATADIR%%/external/storm-jdbc/storm-jdbc-1.0.2-tests.jar +%%DATADIR%%/external/storm-jdbc/storm-jdbc-1.0.2.jar +%%DATADIR%%/external/storm-kafka-client/README.md +%%DATADIR%%/external/storm-kafka-client/storm-kafka-client-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-kafka-client/storm-kafka-client-1.0.2-sources.jar +%%DATADIR%%/external/storm-kafka-client/storm-kafka-client-1.0.2-tests.jar +%%DATADIR%%/external/storm-kafka-client/storm-kafka-client-1.0.2.jar %%DATADIR%%/external/storm-kafka/README.md -%%DATADIR%%/lib/storm-core-0.9.2-incubating.jar -%%DATADIR%%/lib/clojure-1.5.1.jar -%%DATADIR%%/lib/clj-time-0.4.1.jar -%%DATADIR%%/lib/joda-time-2.0.jar -%%DATADIR%%/lib/compojure-1.1.3.jar -%%DATADIR%%/lib/core.incubator-0.1.0.jar -%%DATADIR%%/lib/tools.macro-0.1.0.jar -%%DATADIR%%/lib/clout-1.0.1.jar -%%DATADIR%%/lib/ring-core-1.1.5.jar -%%DATADIR%%/lib/commons-codec-1.6.jar -%%DATADIR%%/lib/commons-io-2.4.jar -%%DATADIR%%/lib/commons-fileupload-1.2.1.jar -%%DATADIR%%/lib/servlet-api-2.5.jar -%%DATADIR%%/lib/hiccup-0.3.6.jar -%%DATADIR%%/lib/ring-devel-0.3.11.jar -%%DATADIR%%/lib/jetty-6.1.26.jar -%%DATADIR%%/lib/clj-stacktrace-0.2.4.jar -%%DATADIR%%/lib/ring-jetty-adapter-0.3.11.jar -%%DATADIR%%/lib/ring-servlet-0.3.11.jar -%%DATADIR%%/lib/jetty-util-6.1.26.jar -%%DATADIR%%/lib/servlet-api-2.5-20081211.jar -%%DATADIR%%/lib/tools.logging-0.2.3.jar -%%DATADIR%%/lib/math.numeric-tower-0.0.1.jar -%%DATADIR%%/lib/tools.cli-0.2.4.jar -%%DATADIR%%/lib/commons-exec-1.1.jar -%%DATADIR%%/lib/commons-lang-2.5.jar -%%DATADIR%%/lib/curator-framework-2.4.0.jar -%%DATADIR%%/lib/curator-client-2.4.0.jar -%%DATADIR%%/lib/slf4j-api-1.6.5.jar -%%DATADIR%%/lib/zookeeper-3.4.5.jar -%%DATADIR%%/lib/jline-2.11.jar -%%DATADIR%%/lib/netty-3.2.2.Final.jar -%%DATADIR%%/lib/guava-13.0.jar -%%DATADIR%%/lib/json-simple-1.1.jar -%%DATADIR%%/lib/carbonite-1.4.0.jar -%%DATADIR%%/lib/kryo-2.21.jar -%%DATADIR%%/lib/reflectasm-1.07-shaded.jar -%%DATADIR%%/lib/asm-4.0.jar -%%DATADIR%%/lib/minlog-1.2.jar -%%DATADIR%%/lib/objenesis-1.2.jar -%%DATADIR%%/lib/chill-java-0.3.5.jar -%%DATADIR%%/lib/snakeyaml-1.11.jar -%%DATADIR%%/lib/httpclient-4.3.3.jar -%%DATADIR%%/lib/httpcore-4.3.2.jar -%%DATADIR%%/lib/commons-logging-1.1.3.jar -%%DATADIR%%/lib/disruptor-2.10.1.jar -%%DATADIR%%/lib/jgrapht-core-0.9.0.jar -%%DATADIR%%/lib/logback-classic-1.0.6.jar -%%DATADIR%%/lib/logback-core-1.0.6.jar +%%DATADIR%%/external/storm-kafka/storm-kafka-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-kafka/storm-kafka-1.0.2-sources.jar +%%DATADIR%%/external/storm-kafka/storm-kafka-1.0.2.jar +%%DATADIR%%/external/storm-mongodb/README.md +%%DATADIR%%/external/storm-mongodb/storm-mongodb-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-mongodb/storm-mongodb-1.0.2-sources.jar +%%DATADIR%%/external/storm-mongodb/storm-mongodb-1.0.2.jar +%%DATADIR%%/external/storm-mqtt/README.md +%%DATADIR%%/external/storm-mqtt/storm-mqtt-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-mqtt/storm-mqtt-1.0.2-sources.jar +%%DATADIR%%/external/storm-mqtt/storm-mqtt-1.0.2.jar +%%DATADIR%%/external/storm-mqtt/storm-mqtt-examples-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-mqtt/storm-mqtt-examples-1.0.2-sources.jar +%%DATADIR%%/external/storm-mqtt/storm-mqtt-examples-1.0.2.jar +%%DATADIR%%/external/storm-redis/README.md +%%DATADIR%%/external/storm-redis/storm-redis-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-redis/storm-redis-1.0.2-sources.jar +%%DATADIR%%/external/storm-redis/storm-redis-1.0.2.jar +%%DATADIR%%/external/storm-solr/README.md +%%DATADIR%%/external/storm-solr/storm-solr-1.0.2-javadoc.jar +%%DATADIR%%/external/storm-solr/storm-solr-1.0.2-sources.jar +%%DATADIR%%/external/storm-solr/storm-solr-1.0.2-tests.jar +%%DATADIR%%/external/storm-solr/storm-solr-1.0.2.jar +%%DATADIR%%/lib/asm-5.0.3.jar +%%DATADIR%%/lib/clojure-1.7.0.jar +%%DATADIR%%/lib/disruptor-3.3.2.jar +%%DATADIR%%/lib/kryo-3.0.3.jar +%%DATADIR%%/lib/log4j-api-2.1.jar +%%DATADIR%%/lib/log4j-core-2.1.jar %%DATADIR%%/lib/log4j-over-slf4j-1.6.6.jar -%%DATADIR%%/lib/netty-3.6.3.Final.jar -%%DATADIR%%/public/css/bootstrap-1.4.0.css +%%DATADIR%%/lib/log4j-slf4j-impl-2.1.jar +%%DATADIR%%/lib/minlog-1.3.0.jar +%%DATADIR%%/lib/objenesis-2.1.jar +%%DATADIR%%/lib/reflectasm-1.10.1.jar +%%DATADIR%%/lib/servlet-api-2.5.jar +%%DATADIR%%/lib/slf4j-api-1.7.7.jar +%%DATADIR%%/lib/storm-core-1.0.2.jar +%%DATADIR%%/lib/storm-rename-hack-1.0.2.jar +%%DATADIR%%/public/component.html +%%DATADIR%%/public/css/bootstrap-3.3.1.min.css +%%DATADIR%%/public/css/dataTables.bootstrap.css +%%DATADIR%%/public/css/jquery.dataTables.1.10.4.min.css +%%DATADIR%%/public/css/jsonFormatter.min.css %%DATADIR%%/public/css/style.css +%%DATADIR%%/public/deep_search_result.html +%%DATADIR%%/public/favicon.ico +%%DATADIR%%/public/images/back_disabled.png +%%DATADIR%%/public/images/back_enabled.png +%%DATADIR%%/public/images/back_enabled_hover.png +%%DATADIR%%/public/images/bug.png +%%DATADIR%%/public/images/forward_disabled.png +%%DATADIR%%/public/images/forward_enabled.png +%%DATADIR%%/public/images/forward_enabled_hover.png +%%DATADIR%%/public/images/search.png +%%DATADIR%%/public/images/sort_asc.png +%%DATADIR%%/public/images/sort_asc_disabled.png +%%DATADIR%%/public/images/sort_both.png +%%DATADIR%%/public/images/sort_desc.png +%%DATADIR%%/public/images/sort_desc_disabled.png +%%DATADIR%%/public/images/spinner.gif +%%DATADIR%%/public/images/statistic.png +%%DATADIR%%/public/index.html %%DATADIR%%/public/js/arbor-graphics.js %%DATADIR%%/public/js/arbor-tween.js %%DATADIR%%/public/js/arbor.js -%%DATADIR%%/public/js/bootstrap-twipsy.js -%%DATADIR%%/public/js/jquery-1.6.2.min.js +%%DATADIR%%/public/js/bootstrap-3.3.1.min.js +%%DATADIR%%/public/js/dataTables.bootstrap.min.js +%%DATADIR%%/public/js/jquery-1.11.1.min.js +%%DATADIR%%/public/js/jquery.blockUI.min.js %%DATADIR%%/public/js/jquery.cookies.2.2.0.min.js +%%DATADIR%%/public/js/jquery.dataTables.1.10.4.min.js %%DATADIR%%/public/js/jquery.mustache.js -%%DATADIR%%/public/js/jquery.tablesorter.min.js -%%DATADIR%%/public/js/purl.js +%%DATADIR%%/public/js/jsonFormatter.min.js +%%DATADIR%%/public/js/moment.min.js %%DATADIR%%/public/js/script.js +%%DATADIR%%/public/js/typeahead.jquery.min.js +%%DATADIR%%/public/js/url.min.js %%DATADIR%%/public/js/visualization.js +%%DATADIR%%/public/logviewer_search.html +%%DATADIR%%/public/search_result.html %%DATADIR%%/public/templates/component-page-template.html +%%DATADIR%%/public/templates/deep-search-result-page-template.html %%DATADIR%%/public/templates/index-page-template.html %%DATADIR%%/public/templates/json-error-template.html +%%DATADIR%%/public/templates/logviewer-search-page-template.html +%%DATADIR%%/public/templates/search-result-page-template.html %%DATADIR%%/public/templates/topology-page-template.html -%%DATADIR%%/public/component.html -%%DATADIR%%/public/index.html +%%DATADIR%%/public/templates/user-template.html %%DATADIR%%/public/topology.html -@sample %%DATADIR%%/conf/storm.yaml.sample -@sample %%DATADIR%%/conf/storm_env.ini.sample -@sample %%DATADIR%%/logback/cluster.xml.sample