org.apache.hadoop.hive.common.io

Class SortPrintStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

java.io.PrintStream

org.apache.hadoop.hive.common.io.FetchConverter

org.apache.hadoop.hive.common.io.SortPrintStream

All Implemented Interfaces:

Closeable, Flushable, Appendable, AutoCloseable

Direct Known Subclasses:

SortAndDigestPrintStream

public class SortPrintStream
extends FetchConverter

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.common.collect.MinMaxPriorityQueue<String>	outputs

Fields inherited from class org.apache.hadoop.hive.common.io.FetchConverter

fetchStarted, queryfound

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor and Description
SortPrintStream(OutputStream out, String encoding)

Method Summary

Methods

Modifier and Type	Method and Description
void	process(String out)
void	processFinal()

Methods inherited from class org.apache.hadoop.hive.common.io.FetchConverter

byPass, fetchFinished, fetchStarted, flush, foundQuery, printDirect, println

Methods inherited from class java.io.PrintStream

append, append, append, checkError, clearError, close, format, format, print, print, print, print, print, print, print, print, print, printf, printf, println, println, println, println, println, println, println, println, println, setError, write, write

Methods inherited from class java.io.FilterOutputStream

write

Methods inherited from class java.lang.Object

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

Field Detail

outputs

protected final com.google.common.collect.MinMaxPriorityQueue<String> outputs

Constructor Detail

SortPrintStream

public SortPrintStream(OutputStream out,
               String encoding)
                throws Exception

Throws:

Exception

Method Detail

process

public void process(String out)

Specified by:

process in class FetchConverter

processFinal

public void processFinal()

Specified by:

processFinal in class FetchConverter