Package org.biojava.spark.mappers

Class StringByteToTextByteWriter

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.spark.api.java.function.PairFunction<scala.Tuple2<java.lang.String,​byte[]>,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.BytesWritable>
    public class StringByteToTextByteWriter
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFunction<scala.Tuple2<java.lang.String,​byte[]>,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.BytesWritable>
    Converts a tuple of string and byte array, to a Text and Bytes writeable. This is required for writing hadoop sequence files of data in this format.
    Author:
    Anthony Bradley
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      scala.Tuple2<org.apache.hadoop.io.Text,​org.apache.hadoop.io.BytesWritable> call​(scala.Tuple2<java.lang.String,​byte[]> t)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • StringByteToTextByteWriter

        public StringByteToTextByteWriter()

    • Method Detail

      • call

        public scala.Tuple2<org.apache.hadoop.io.Text,​org.apache.hadoop.io.BytesWritable> call​(scala.Tuple2<java.lang.String,​byte[]> t)
                                                                                      throws java.lang.Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.PairFunction<scala.Tuple2<java.lang.String,​byte[]>,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.BytesWritable>
        Throws:
        java.lang.Exception