public class Utils
extends java.lang.Object
Constructor and Description |
---|
Utils()
Deprecated.
|
Modifier and Type | Method and 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.
|
public static void createAppDirAndInternalStreamsForKafkaStreams(StreamsConfig config)
@Deprecated public static void enableLogCompactionForStreamIfNotEnabled(java.lang.String streamName)
@Deprecated public static void validateDirectoryPerms(org.apache.hadoop.fs.FileSystem fs, java.lang.String path, java.lang.String user, java.lang.String errorMsg)
@Deprecated public static boolean streamExists(java.lang.String streamName)
@Deprecated public static java.lang.String getShortTopicNameFromFullTopicName(java.lang.String fullTopicName)
@Deprecated public static void createStream(java.lang.String streamName)
@Deprecated public static void createStreamWithPublicPerms(java.lang.String streamName)
@Deprecated public static boolean maprFSpathExists(org.apache.hadoop.fs.FileSystem fs, java.lang.String path) throws java.io.IOException
java.io.IOException
@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
java.io.IOException