Package org.apache.kafka.streams.mapr
Class Utils
- java.lang.Object
-
- org.apache.kafka.streams.mapr.Utils
-
public class Utils extends java.lang.Object
Deprecated.- use mapr-eco-tools utils instead
-
-
Constructor Summary
Constructors Constructor Description Utils()
Deprecated.
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static void
createAppDirAndInternalStreamsForKafkaStreams(StreamsConfig config)
Deprecated.static void
createStream(java.lang.String streamName)
Deprecated.static void
createStreamWithPublicPerms(java.lang.String streamName)
Deprecated.static void
enableLogCompactionForStreamIfNotEnabled(java.lang.String streamName)
Deprecated.static java.lang.String
getShortTopicNameFromFullTopicName(java.lang.String fullTopicName)
Deprecated.static void
maprFSpathCreate(org.apache.hadoop.fs.FileSystem fs, java.lang.String pathStr, java.util.ArrayList<com.mapr.fs.MapRFileAce> aces, java.lang.String currentUser, java.lang.String errorMsg)
Deprecated.static boolean
maprFSpathExists(org.apache.hadoop.fs.FileSystem fs, java.lang.String path)
Deprecated.static boolean
streamExists(java.lang.String streamName)
Deprecated.static void
validateDirectoryPerms(org.apache.hadoop.fs.FileSystem fs, java.lang.String path, java.lang.String user, java.lang.String errorMsg)
Deprecated.
-
-
-
Method Detail
-
createAppDirAndInternalStreamsForKafkaStreams
public static void createAppDirAndInternalStreamsForKafkaStreams(StreamsConfig config)
Deprecated.
-
enableLogCompactionForStreamIfNotEnabled
@Deprecated public static void enableLogCompactionForStreamIfNotEnabled(java.lang.String streamName)
Deprecated.
-
validateDirectoryPerms
@Deprecated public static void validateDirectoryPerms(org.apache.hadoop.fs.FileSystem fs, java.lang.String path, java.lang.String user, java.lang.String errorMsg)
Deprecated.
-
streamExists
@Deprecated public static boolean streamExists(java.lang.String streamName)
Deprecated.
-
getShortTopicNameFromFullTopicName
@Deprecated public static java.lang.String getShortTopicNameFromFullTopicName(java.lang.String fullTopicName)
Deprecated.
-
createStream
@Deprecated public static void createStream(java.lang.String streamName)
Deprecated.
-
createStreamWithPublicPerms
@Deprecated public static void createStreamWithPublicPerms(java.lang.String streamName)
Deprecated.
-
maprFSpathExists
@Deprecated public static boolean maprFSpathExists(org.apache.hadoop.fs.FileSystem fs, java.lang.String path) throws java.io.IOException
Deprecated.- Throws:
java.io.IOException
-
maprFSpathCreate
@Deprecated public static void maprFSpathCreate(org.apache.hadoop.fs.FileSystem fs, java.lang.String pathStr, java.util.ArrayList<com.mapr.fs.MapRFileAce> aces, java.lang.String currentUser, java.lang.String errorMsg) throws java.io.IOException
Deprecated.- Throws:
java.io.IOException
-
-