Class TfMetaUtils


  • public class TfMetaUtils
    extends Object
    • Constructor Detail

      • TfMetaUtils

        public TfMetaUtils()
    • Method Detail

      • isIDSpec

        public static boolean isIDSpec​(String spec)
      • isIDSpec

        public static boolean isIDSpec​(org.apache.wink.json4j.JSONObject spec)
                                throws org.apache.wink.json4j.JSONException
        Throws:
        org.apache.wink.json4j.JSONException
      • containsOmitSpec

        public static boolean containsOmitSpec​(String spec,
                                               String[] colnames)
      • parseJsonIDList

        public static int[] parseJsonIDList​(String spec,
                                            String[] colnames,
                                            String group)
      • parseJsonIDList

        public static int[] parseJsonIDList​(org.apache.wink.json4j.JSONObject spec,
                                            String[] colnames,
                                            String group)
                                     throws org.apache.wink.json4j.JSONException
        TODO consolidate external and internal json spec definitions
        Parameters:
        spec - transform specification as json string
        colnames - column names
        group - attribute name in json class
        Returns:
        list of column ids
        Throws:
        org.apache.wink.json4j.JSONException - if JSONException occurs
      • parseJsonIDList

        public static int[] parseJsonIDList​(org.apache.wink.json4j.JSONObject spec,
                                            String[] colnames,
                                            String group,
                                            int minCol,
                                            int maxCol)
                                     throws org.apache.wink.json4j.JSONException
        Parameters:
        spec - transform specification as json string
        colnames - column names
        group - attribute name in json class
        minCol - start of columns to ignore (1-based, inclusive, if -1 not used)
        maxCol - end of columns to ignore (1-based, exclusive, if -1 not used)
        Returns:
        list of column ids
        Throws:
        org.apache.wink.json4j.JSONException - if JSONException occurs
      • parseJsonObjectID

        public static int parseJsonObjectID​(org.apache.wink.json4j.JSONObject colspec,
                                            String[] colnames,
                                            int minCol,
                                            int maxCol,
                                            boolean ids)
                                     throws org.apache.wink.json4j.JSONException
        Throws:
        org.apache.wink.json4j.JSONException
      • parseJsonObjectIDList

        public static int[] parseJsonObjectIDList​(org.apache.wink.json4j.JSONObject spec,
                                                  String[] colnames,
                                                  String group,
                                                  int minCol,
                                                  int maxCol)
                                           throws org.apache.wink.json4j.JSONException
        Throws:
        org.apache.wink.json4j.JSONException
      • parseJsonArrayIDList

        public static int[] parseJsonArrayIDList​(org.apache.wink.json4j.JSONArray arr,
                                                 String[] colnames,
                                                 int minCol,
                                                 int maxCol,
                                                 boolean ids)
                                          throws org.apache.wink.json4j.JSONException
        Throws:
        org.apache.wink.json4j.JSONException
      • parseJsonPlainArrayIDList

        public static int[] parseJsonPlainArrayIDList​(org.apache.wink.json4j.JSONArray arr,
                                                      String[] colnames,
                                                      int minCol,
                                                      int maxCol,
                                                      boolean ids)
      • getK

        public static long getK​(org.apache.wink.json4j.JSONObject parsedSpec)
                         throws org.apache.wink.json4j.JSONException
        Get K value used for calculation during feature hashing from parsed specifications.
        Parameters:
        parsedSpec - parsed specifications
        Returns:
        K value
        Throws:
        org.apache.wink.json4j.JSONException - if JSONException occurs
      • readTransformMetaDataFromFile

        public static FrameBlock readTransformMetaDataFromFile​(String spec,
                                                               String metapath,
                                                               String colDelim)
                                                        throws IOException
        Reads transform meta data from an HDFS file path and converts it into an in-memory FrameBlock object.
        Parameters:
        spec - transform specification as json string
        metapath - hdfs file path to meta data directory
        colDelim - separator for processing column names in the meta data file 'column.names'
        Returns:
        frame block
        Throws:
        IOException - if IOException occurs
      • readTransformMetaDataFromPath

        public static FrameBlock readTransformMetaDataFromPath​(String spec,
                                                               String metapath,
                                                               String colDelim)
                                                        throws IOException
        Reads transform meta data from the class path and converts it into an in-memory FrameBlock object.
        Parameters:
        spec - transform specification as json string
        metapath - resource path to meta data directory
        colDelim - separator for processing column names in the meta data file 'column.names'
        Returns:
        frame block
        Throws:
        IOException - if IOException occurs
      • parseBinningColIDs

        public static List<Integer> parseBinningColIDs​(org.apache.wink.json4j.JSONObject jSpec,
                                                       String[] colnames,
                                                       int minCol,
                                                       int maxCol)
                                                throws IOException
        Throws:
        IOException
      • checkValidEncoders

        public static void checkValidEncoders​(org.apache.wink.json4j.JSONObject jSpec)