Class Utils


  • public class Utils
    extends java.lang.Object
    Deprecated.
    - use mapr-eco-tools utils instead
    • Constructor Detail

      • Utils

        public Utils()
        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