This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new d5a90a33e Removes test dependency towards removed /external module
hbase
d5a90a33e is described below
commit d5a90a33eb997b6b9e709bd581c5811131894817
Author: Richard Zowalla <[email protected]>
AuthorDate: Thu Nov 16 08:12:28 2023 +0100
Removes test dependency towards removed /external module hbase
---
.../test/java/org/apache/storm/flux/TCKTest.java | 11 --
.../src/test/resources/configs/simple_hbase.yaml | 120 ---------------------
2 files changed, 131 deletions(-)
diff --git a/flux/flux-core/src/test/java/org/apache/storm/flux/TCKTest.java
b/flux/flux-core/src/test/java/org/apache/storm/flux/TCKTest.java
index 951678573..2fd755e5e 100644
--- a/flux/flux-core/src/test/java/org/apache/storm/flux/TCKTest.java
+++ b/flux/flux-core/src/test/java/org/apache/storm/flux/TCKTest.java
@@ -103,17 +103,6 @@ public class TCKTest {
topology.validate();
}
-
- @Test
- public void testHbase() throws Exception {
- TopologyDef topologyDef =
FluxParser.parseResource("/configs/simple_hbase.yaml", false, true, null,
false);
- Config conf = FluxBuilder.buildConfig(topologyDef);
- ExecutionContext context = new ExecutionContext(topologyDef, conf);
- StormTopology topology = FluxBuilder.buildTopology(context);
- assertNotNull(topology);
- topology.validate();
- }
-
@Test
public void testBadHbase() throws Exception {
TopologyDef topologyDef =
FluxParser.parseResource("/configs/bad_hbase.yaml", false, true, null, false);
diff --git a/flux/flux-core/src/test/resources/configs/simple_hbase.yaml
b/flux/flux-core/src/test/resources/configs/simple_hbase.yaml
deleted file mode 100644
index b841b5360..000000000
--- a/flux/flux-core/src/test/resources/configs/simple_hbase.yaml
+++ /dev/null
@@ -1,120 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-# Test ability to wire together shell spouts/bolts
----
-
-# topology definition
-# name to be used when submitting
-name: "hbase-wordcount"
-
-# Components
-# Components are analagous to Spring beans. They are meant to be used as
constructor,
-# property(setter), and builder arguments.
-#
-# for the time being, components must be declared in the order they are
referenced
-
-# WordSpout spout = new WordSpout();
-# WordCounter bolt = new WordCounter();
-#
-# SimpleHBaseMapper mapper = new SimpleHBaseMapper()
-# .withRowKeyField("word")
-# .withColumnFields(new Fields("word"))
-# .withCounterFields(new Fields("count"))
-# .withColumnFamily("cf");
-#
-# HBaseBolt hbase = new HBaseBolt("WordCount", mapper)
-# .withConfigKey("hbase.conf");
-#
-#
-# // wordSpout ==> countBolt ==> HBaseBolt
-# TopologyBuilder builder = new TopologyBuilder();
-#
-# builder.setSpout(WORD_SPOUT, spout, 1);
-# builder.setBolt(COUNT_BOLT, bolt, 1).shuffleGrouping(WORD_SPOUT);
-# builder.setBolt(HBASE_BOLT, hbase, 1).fieldsGrouping(COUNT_BOLT, new
Fields("word"));
-
-
-
-
-components:
- - id: "columnFields"
- className: "org.apache.storm.tuple.Fields"
- constructorArgs:
- - ["word"]
-
- - id: "counterFields"
- className: "org.apache.storm.tuple.Fields"
- constructorArgs:
- - ["count"]
-
- - id: "mapper"
- className: "org.apache.storm.hbase.bolt.mapper.SimpleHBaseMapper"
- configMethods:
- - name: "withRowKeyField"
- args: ["word"]
- - name: "withColumnFields"
- args: [ref: "columnFields"]
- - name: "withCounterFields"
- args: [ref: "counterFields"]
- - name: "withColumnFamily"
- args: ["cf"]
-
-# topology configuration
-# this will be passed to the submitter as a map of config options
-#
-config:
- topology.workers: 1
- hbase.conf:
- hbase.rootdir: "hdfs://hadoop:54310/hbase"
- hbase.zookeeper.quorum: "hadoop"
-
-# spout definitions
-spouts:
- - id: "word-spout"
- className: "org.apache.storm.testing.TestWordSpout"
- parallelism: 1
-
-# bolt definitions
-
-bolts:
- - id: "count-bolt"
- className: "org.apache.storm.testing.TestWordCounter"
-
- - id: "hbase-bolt"
- className: "org.apache.storm.hbase.bolt.HBaseBolt"
- constructorArgs:
- - "WordCount" # HBase table name
- - ref: "mapper"
- configMethods:
- - name: "withConfigKey"
- args: ["hbase.conf"]
- parallelism: 1
-
-
-streams:
- - name: "" # name isn't used (placeholder for logging, UI, etc.)
- from: "word-spout"
- to: "count-bolt"
- grouping:
- type: SHUFFLE
-
- - name: "" # name isn't used (placeholder for logging, UI, etc.)
- from: "count-bolt"
- to: "hbase-bolt"
- grouping:
- type: FIELDS
- args: ["word"]
