Uploaded image for project: 'HBase'
  1. HBase
  2. HBASE-16804

JavaHBaseContext.streamBulkGet is void but should be JavaDStream

    XMLWordPrintableJSON

    Details

    • Hadoop Flags:
      Reviewed

      Description

      This is current implementation in JavaHBaseContext.scala:

      def streamBulkGet[T, U](tableName: TableName,
                                batchSize: Integer,
                                javaDStream: JavaDStream[T],
                                makeGet: Function[T, Get],
                                convertResult: Function[Result, U])
      

      Should be:

      def streamBulkGet[T, U](tableName: TableName,
                                batchSize: Integer,
                                javaDStream: JavaDStream[T],
                                makeGet: Function[T, Get],
                                convertResult: Function[Result, U]): JavaDStream[U]
      

        Attachments

        1. HBASE-16804.patch
          0.9 kB
          Igor Yurinok

          Activity

            People

            • Assignee:
              iyurinok Igor Yurinok
              Reporter:
              iyurinok Igor Yurinok
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: