Class AbstractColumnSubsetStreamFilter

    • Constructor Detail

      • AbstractColumnSubsetStreamFilter

        public AbstractColumnSubsetStreamFilter()
    • Method Detail

      • doInitFilter

        protected abstract void doInitFilter​(Row data)
                                      throws Exception
        Filter-specific initialization.
        Parameters:
        data - the data to initialize with
        Throws:
        Exception - if initialization fails
      • initOutputFormat

        protected abstract Dataset initOutputFormat​(Row data)
                                             throws Exception
        Initializes the output format.
        Parameters:
        data - the output format
        Throws:
        Exception - if initialization fails
      • doFilter

        protected abstract Row doFilter​(Row data)
                                 throws Exception
        Filters the dataset row coming through.
        Parameters:
        data - the data to filter
        Returns:
        the filtered data
        Throws:
        Exception - if filtering fails
      • filter

        public Row filter​(Row data)
                   throws Exception
        Filters the dataset row coming through.
        Specified by:
        filter in interface StreamFilter
        Parameters:
        data - the data to filter
        Returns:
        the filtered data
        Throws:
        Exception - if filtering fails
      • filter

        public Dataset filter​(Dataset data)
                       throws Exception
        Filters the dataset coming through.
        Specified by:
        filter in interface BatchFilter
        Parameters:
        data - the data to filter
        Returns:
        the filtered data
        Throws:
        Exception - if filtering fails