Class BinRDF

    • Constructor Detail

      • BinRDF

        public BinRDF()
    • Method Detail

      • streamToFile

        public static StreamRDF streamToFile​(java.lang.String filename)
        Create an StreamRDF for output. A filename ending .gz will have a gzip compressor added to the output path. A filename of "-" is System.out. The file is closed when StreamRDF.finish() is called unless it is System.out. Call StreamRDF.start()...StreamRDF.finish().
        Parameters:
        filename - The file
        Returns:
        StreamRDF A stream to send to.
      • streamToFile

        public static StreamRDF streamToFile​(java.lang.String filename,
                                             boolean withValues)
        Create an StreamRDF for output. A filenames ending .gz or .bz2 will have the respective compressor added to the output path. A filename of "-" is System.out. The file is closed when StreamRDF.finish() is called unless it is System.out. Call StreamRDF.start()...StreamRDF.finish().
        Parameters:
        filename - The file
        withValues - - whether to encode numeric values as values.
        Returns:
        StreamRDF A stream to send to.
      • streamToOutputStream

        public static StreamRDF streamToOutputStream​(java.io.OutputStream out,
                                                     boolean withValues)
        Create an StreamRDF for output. The OutputStream is closed when StreamRDF.finish() is called unless it is System.out. Call StreamRDF.start()...StreamRDF.finish().
        Parameters:
        out - OutputStream
        withValues - - whether to encode numeric values as values.
        Returns:
        StreamRDF A stream to send to.
      • streamToTProtocol

        public static StreamRDF streamToTProtocol​(org.apache.thrift.protocol.TProtocol protocol)
        Create an StreamRDF for output. The OutputStream is closed when StreamRDF.finish() is called unless it is System.out. Call StreamRDF.start()...StreamRDF.finish().
        Parameters:
        protocol - Output and encoding.
        Returns:
        StreamRDF A stream to send to.
      • streamToTProtocol

        public static StreamRDF streamToTProtocol​(org.apache.thrift.protocol.TProtocol protocol,
                                                  boolean withValues)
        Create an StreamRDF for output. The OutputStream is closed when StreamRDF.finish() is called unless it is System.out. Call StreamRDF.start()...StreamRDF.finish().
        Parameters:
        protocol - Output and encoding.
        withValues - - whether to encode numeric values as values.
        Returns:
        StreamRDF A stream to send to.
      • fileToStream

        public static void fileToStream​(java.lang.String filename,
                                        StreamRDF dest)
        Decode the contents of the file and send to the StreamRDF. A filename ending .gz will have a gzip decompressor added. A filename of "-" is System.in.
        Parameters:
        filename - The file.
        dest - Sink
      • inputStreamToStream

        public static void inputStreamToStream​(java.io.InputStream in,
                                               StreamRDF dest)
        Decode the contents of the input stream and send to the StreamRDF.
        Parameters:
        in - InputStream
        dest - StreamRDF
      • protocolToStream

        public static void protocolToStream​(org.apache.thrift.protocol.TProtocol protocol,
                                            StreamRDF dest)
        Decode the contents of the TProtocol and send to the StreamRDF.
        Parameters:
        protocol - TProtocol
        dest - Sink
      • apply

        public static void apply​(org.apache.thrift.protocol.TProtocol protocol,
                                 java.util.function.Consumer<RDF_StreamRow> action)
        Send the contents of a RDF-encoded Thrift file to an "action"
        Parameters:
        protocol - TProtocol
        action - Code to act on the row.
      • dump

        public static void dump​(java.io.OutputStream out,
                                java.io.InputStream in)
        Debug help - print details of a Thrift stream. Destructive on the InputStream.
        Parameters:
        out - OutputStream
        in - InputStream
      • readResultSet

        public static ResultSet readResultSet​(java.io.InputStream in)
      • readResultSet

        public static ResultSet readResultSet​(org.apache.thrift.protocol.TProtocol protocol)
      • writeResultSet

        public static void writeResultSet​(java.io.OutputStream out,
                                          ResultSet resultSet)
      • writeResultSet

        public static void writeResultSet​(java.io.OutputStream out,
                                          ResultSet resultSet,
                                          boolean withValues)
      • writeResultSet

        public static void writeResultSet​(org.apache.thrift.protocol.TProtocol protocol,
                                          ResultSet resultSet)
      • writeResultSet

        public static void writeResultSet​(org.apache.thrift.protocol.TProtocol protocol,
                                          ResultSet resultSet,
                                          boolean encodeValues)