org.apache.hadoop.hive.common.io

Class FetchConverter

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

java.io.PrintStream

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

All Implemented Interfaces:

Closeable, Flushable, Appendable, AutoCloseable

Direct Known Subclasses:

DigestPrintStream, SortPrintStream

public abstract class FetchConverter
extends PrintStream

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	fetchStarted
protected boolean	queryfound

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor and Description
FetchConverter(OutputStream out, boolean autoFlush, String encoding)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	byPass()
void	fetchFinished()
void	fetchStarted()
void	flush()
void	foundQuery(boolean queryfound)
protected void	printDirect(String out)
void	println(String out)
protected abstract void	process(String out)
protected abstract void	processFinal()

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

queryfound

protected volatile boolean queryfound

fetchStarted

protected volatile boolean fetchStarted

Constructor Detail

FetchConverter

public FetchConverter(OutputStream out,
              boolean autoFlush,
              String encoding)
               throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

Method Detail

foundQuery

public void foundQuery(boolean queryfound)

fetchStarted

public void fetchStarted()

println

public void println(String out)

Overrides:

println in class PrintStream

printDirect

protected final void printDirect(String out)

byPass

protected final boolean byPass()

process

protected abstract void process(String out)

processFinal

protected abstract void processFinal()

flush

public void flush()

Specified by:

flush in interface Flushable

Overrides:

flush in class PrintStream

fetchFinished

public void fetchFinished()