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 454fa07b0 STORM-4128 - Deprecate "storm-hive"
454fa07b0 is described below
commit 454fa07b037fefa26b60dda6629d26137a73f4fb
Author: Richard Zowalla <[email protected]>
AuthorDate: Mon Nov 18 09:23:23 2024 +0100
STORM-4128 - Deprecate "storm-hive"
---
.../src/main/java/org/apache/storm/hive/security/AutoHive.java | 1 +
.../src/main/java/org/apache/storm/hive/security/AutoHiveCommand.java | 1 +
.../src/main/java/org/apache/storm/hive/security/AutoHiveNimbus.java | 1 +
.../src/main/java/org/apache/storm/hive/security/HiveSecurityUtil.java | 1 +
.../storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java | 1 +
.../org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java | 1 +
.../src/main/java/org/apache/storm/hive/bolt/mapper/HiveMapper.java | 1 +
.../java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java | 1 +
.../src/main/java/org/apache/storm/hive/common/HiveOptions.java | 1 +
.../src/main/java/org/apache/storm/hive/common/HiveUtils.java | 1 +
.../src/main/java/org/apache/storm/hive/common/HiveWriter.java | 2 +-
.../src/main/java/org/apache/storm/hive/trident/HiveState.java | 1 +
.../src/main/java/org/apache/storm/hive/trident/HiveStateFactory.java | 2 +-
.../src/main/java/org/apache/storm/hive/trident/HiveUpdater.java | 1 +
.../src/test/java/org/apache/storm/hive/bolt/HiveSetupUtil.java | 1 +
.../src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java | 1 +
.../src/test/java/org/apache/storm/hive/common/TestHiveWriter.java | 1 +
17 files changed, 17 insertions(+), 2 deletions(-)
diff --git
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHive.java
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHive.java
index 94b38fac4..daf3c6a2e 100644
---
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHive.java
+++
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHive.java
@@ -29,6 +29,7 @@ import org.apache.storm.common.AbstractHadoopAutoCreds;
* Auto credentials plugin for Hive implementation. This class provides a way
to automatically
* push credentials to a topology and to retrieve them in the worker.
*/
+@Deprecated(since = "2.7.1", forRemoval = true)
public class AutoHive extends AbstractHadoopAutoCreds {
@Override
public void doPrepare(Map<String, Object> conf) {
diff --git
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveCommand.java
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveCommand.java
index f5c139b06..662053f7d 100644
---
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveCommand.java
+++
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveCommand.java
@@ -33,6 +33,7 @@ import org.slf4j.LoggerFactory;
/**
* Command tool of Hive credential renewer.
*/
+@Deprecated(since = "2.7.1", forRemoval = true)
public final class AutoHiveCommand {
private static final Logger LOG =
LoggerFactory.getLogger(AutoHiveCommand.class);
diff --git
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveNimbus.java
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveNimbus.java
index e3b0ca7ef..947034edf 100644
---
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveNimbus.java
+++
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/AutoHiveNimbus.java
@@ -51,6 +51,7 @@ import org.slf4j.LoggerFactory;
* Auto credentials nimbus plugin for Hive implementation. This class
automatically
* gets Hive delegation tokens and push it to user's topology.
*/
+@Deprecated(since = "2.7.1", forRemoval = true)
public class AutoHiveNimbus extends AbstractHadoopNimbusPluginAutoCreds {
private static final Logger LOG =
LoggerFactory.getLogger(AutoHiveNimbus.class);
diff --git
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/HiveSecurityUtil.java
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/HiveSecurityUtil.java
index de67f2cde..c3424e106 100644
---
a/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/HiveSecurityUtil.java
+++
b/external/storm-autocreds/src/main/java/org/apache/storm/hive/security/HiveSecurityUtil.java
@@ -22,6 +22,7 @@ package org.apache.storm.hive.security;
* This class provides util methods for storm-hdfs connector communicating
* with secured Hive.
*/
+@Deprecated(since = "2.7.1", forRemoval = true)
public final class HiveSecurityUtil {
public static final String HIVE_KEYTAB_FILE_KEY = "hive.keytab.file";
public static final String HIVE_PRINCIPAL_KEY = "hive.kerberos.principal";
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
index db373e574..14c6195cb 100644
--- a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
+++ b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
@@ -43,6 +43,7 @@ import org.apache.storm.utils.TupleUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveBolt extends BaseRichBolt {
private static final Logger LOG = LoggerFactory.getLogger(HiveBolt.class);
@VisibleForTesting
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java
index fbbc4cc31..0e3af0463 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java
@@ -29,6 +29,7 @@ import org.apache.storm.tuple.Tuple;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class DelimitedRecordHiveMapper implements HiveMapper {
private static final Logger LOG =
LoggerFactory.getLogger(DelimitedRecordHiveMapper.class);
private static final String DEFAULT_FIELD_DELIMITER = ",";
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/HiveMapper.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/HiveMapper.java
index dd6794126..bb9e5f0f0 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/HiveMapper.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/HiveMapper.java
@@ -26,6 +26,7 @@ import org.apache.storm.tuple.Tuple;
* Maps a <code>org.apache.storm.tuple.Tupe</code> object
* to a row in an Hive table.
*/
+@Deprecated(since = "2.7.1", forRemoval = true)
public interface HiveMapper extends Serializable {
/**
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java
index 62a28afa1..a380704f3 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java
@@ -28,6 +28,7 @@ import org.apache.storm.tuple.Tuple;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class JsonRecordHiveMapper implements HiveMapper {
private static final Logger LOG =
LoggerFactory.getLogger(JsonRecordHiveMapper.class);
private Fields columnFields;
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveOptions.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveOptions.java
index ea973965c..1d4f042d2 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveOptions.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveOptions.java
@@ -15,6 +15,7 @@ package org.apache.storm.hive.common;
import java.io.Serializable;
import org.apache.storm.hive.bolt.mapper.HiveMapper;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveOptions implements Serializable {
/**
* Half of the default Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveUtils.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveUtils.java
index 328794fd2..0265ad769 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveUtils.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveUtils.java
@@ -27,6 +27,7 @@ import org.apache.storm.hive.security.AutoHive;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveUtils {
private static final Logger LOG = LoggerFactory.getLogger(HiveUtils.class);
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveWriter.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveWriter.java
index c0ea26f45..dde370a69 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveWriter.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/common/HiveWriter.java
@@ -35,7 +35,7 @@ import org.apache.storm.tuple.Tuple;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveWriter {
private static final Logger LOG = LoggerFactory
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveState.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveState.java
index a6614470b..60d1a937e 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveState.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveState.java
@@ -39,6 +39,7 @@ import org.apache.storm.trident.tuple.TridentTuple;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveState implements State {
private static final Logger LOG = LoggerFactory.getLogger(HiveState.class);
private HiveOptions options;
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveStateFactory.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveStateFactory.java
index e6a7d8477..d587bfb56 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveStateFactory.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveStateFactory.java
@@ -20,7 +20,7 @@ import org.apache.storm.trident.state.StateFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveStateFactory implements StateFactory {
private static final Logger LOG =
LoggerFactory.getLogger(HiveStateFactory.class);
private HiveOptions options;
diff --git
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveUpdater.java
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveUpdater.java
index 36479d9f4..47beda81c 100644
---
a/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveUpdater.java
+++
b/external/storm-hive/src/main/java/org/apache/storm/hive/trident/HiveUpdater.java
@@ -17,6 +17,7 @@ import org.apache.storm.trident.operation.TridentCollector;
import org.apache.storm.trident.state.BaseStateUpdater;
import org.apache.storm.trident.tuple.TridentTuple;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveUpdater extends BaseStateUpdater<HiveState> {
@Override
public void updateState(HiveState state, List<TridentTuple> tuples,
TridentCollector collector) {
diff --git
a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveSetupUtil.java
b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveSetupUtil.java
index 66463902a..39a87b914 100644
---
a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveSetupUtil.java
+++
b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveSetupUtil.java
@@ -45,6 +45,7 @@ import org.apache.hadoop.hive.serde.serdeConstants;
import org.apache.hadoop.hive.shims.ShimLoader;
import org.apache.thrift.TException;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class HiveSetupUtil {
private final static String txnMgr =
"org.apache.hadoop.hive.ql.lockmgr.DbTxnManager";
diff --git
a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
index 7a3970b99..9997ba141 100644
---
a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
+++
b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
@@ -57,6 +57,7 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class TestHiveBolt {
final static String dbName = "testdb";
final static String tblName = "test_table";
diff --git
a/external/storm-hive/src/test/java/org/apache/storm/hive/common/TestHiveWriter.java
b/external/storm-hive/src/test/java/org/apache/storm/hive/common/TestHiveWriter.java
index 30a2ab5f1..f5be324b3 100644
---
a/external/storm-hive/src/test/java/org/apache/storm/hive/common/TestHiveWriter.java
+++
b/external/storm-hive/src/test/java/org/apache/storm/hive/common/TestHiveWriter.java
@@ -44,6 +44,7 @@ import org.mockito.Mockito;
import static org.junit.jupiter.api.Assertions.assertEquals;
+@Deprecated(since = "2.7.1", forRemoval = true)
public class TestHiveWriter {
public static final String PART1_NAME = "city";
public static final String PART2_NAME = "state";
