org.apache.hadoop.hive.llap

Class LlapBaseRecordReader.ReaderEvent

java.lang.Object

org.apache.hadoop.hive.llap.LlapBaseRecordReader.ReaderEvent

Enclosing class:

LlapBaseRecordReader<V extends org.apache.hadoop.io.WritableComparable>

public static class LlapBaseRecordReader.ReaderEvent
extends Object

Define success/error events which are passed to the reader from a different thread. The reader will check for these events on end of input and interruption of the reader thread.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LlapBaseRecordReader.ReaderEvent.EventType

Field Summary

Fields

Modifier and Type	Field and Description
protected LlapBaseRecordReader.ReaderEvent.EventType	eventType
protected String	message

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ReaderEvent(LlapBaseRecordReader.ReaderEvent.EventType type, String message)

Method Summary

Modifier and Type	Method and Description
static LlapBaseRecordReader.ReaderEvent	doneEvent()
static LlapBaseRecordReader.ReaderEvent	errorEvent(String message)
LlapBaseRecordReader.ReaderEvent.EventType	getEventType()
String	getMessage()

Methods inherited from class java.lang.Object

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

Field Detail

eventType

protected final LlapBaseRecordReader.ReaderEvent.EventType eventType

message

protected final String message

Constructor Detail

ReaderEvent

protected ReaderEvent(LlapBaseRecordReader.ReaderEvent.EventType type,
                      String message)

Method Detail

doneEvent

public static LlapBaseRecordReader.ReaderEvent doneEvent()

errorEvent

public static LlapBaseRecordReader.ReaderEvent errorEvent(String message)

getEventType

public LlapBaseRecordReader.ReaderEvent.EventType getEventType()

getMessage

public String getMessage()