Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12470 FLIP39: Flink ML pipeline and ML libs
  3. FLINK-13668

Add abstract classes for three typical scenarios of (Flat)Mapper.

    XMLWordPrintableJSON

Details

    Description

      FlatMapper transforms one Row type data into zero, one, or more Row type result data, and Mapper transforms one Row type data into one Row type result data. For most of practical scenarios, the outputs are single column. Using these extend classes, we can be more focus on the algorithm development.

      • Add SISOFlatMapper for the Single Input column and Single Output column scenario.
      • Add SISOMapper for the Single Input column and Single Output column scenario.
      • Add MISOMapper for the Multi Input column and Single Output column scenario.
      • Add Param definition for SISOFlatMapper
      • Add Param definition for SISOMapper
      • Add Param definition for MISOMapper

      Attachments

        Issue Links

          Dependent

          Sub-task - The sub-task of the issue FLINK-13513 Add the Mapper and related classes for later algorithm implementations.

          • Major - Major loss of function.
          • Resolved

          Sub-task - The sub-task of the issue FLINK-13577 Add an util class to build result row and generate result schema.

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13667 Add the utility class for the Table

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13669 Add class for BinarizerMapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13670 Add class for VectorAssemblerMapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13671 Add class for VectorEleWiseProductMapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13672 Add class for VectorInteractionMapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13673 Add class of Vector Normalize Mapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13674 Add class of Vector Size Hint Mapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13675 Add class of Vector Slice Mapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13676 Add class of Vector to Columns mapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13834 Add class for PolynomialExpansionMapper

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13914 Add class for DocHashTFVectorizerMapper.

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13916 Add class for NGramMapper.

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13917 Add class for RegexTokenizerMapper.

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-13918 Add class for TokenizerMapper.

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #9405

          Activity

            People

              Unassigned Unassigned
              xuyang1706 Xu Yang
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m