public class ScriptTransformationWriterThread extends Thread implements HiveInspectors, org.apache.spark.internal.Logging
HiveInspectors.typeInfoConversions
Constructor and Description |
---|
ScriptTransformationWriterThread(scala.collection.Iterator<org.apache.spark.sql.catalyst.InternalRow> iter,
scala.collection.Seq<DataType> inputSchema,
org.apache.hadoop.hive.serde2.AbstractSerDe inputSerde,
org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector inputSoi,
HiveScriptIOSchema ioschema,
java.io.OutputStream outputStream,
Process proc,
org.apache.spark.util.CircularBuffer stderrBuffer,
TaskContext taskContext,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
scala.Option<Throwable> |
exception()
Contains the exception thrown while writing the parent iterator to the external process.
|
void |
run() |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
decimalTypeInfoToCatalyst, getBinaryWritable, getBinaryWritableConstantObjectInspector, getBooleanWritable, getBooleanWritableConstantObjectInspector, getByteWritable, getByteWritableConstantObjectInspector, getDateWritable, getDateWritableConstantObjectInspector, getDecimalWritable, getDecimalWritableConstantObjectInspector, getDoubleWritable, getDoubleWritableConstantObjectInspector, getFloatWritable, getFloatWritableConstantObjectInspector, getIntWritable, getIntWritableConstantObjectInspector, getLongWritable, getLongWritableConstantObjectInspector, getPrimitiveNullWritableConstantObjectInspector, getShortWritable, getShortWritableConstantObjectInspector, getStringWritable, getStringWritableConstantObjectInspector, getTimestampWritable, getTimestampWritableConstantObjectInspector, inspectorToDataType, isSubClassOf, javaTypeToDataType, toInspector, toInspector, unwrapperFor, unwrapperFor, withNullSafe, wrap, wrap, wrap, wrapperFor
$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitialize
public ScriptTransformationWriterThread(scala.collection.Iterator<org.apache.spark.sql.catalyst.InternalRow> iter, scala.collection.Seq<DataType> inputSchema, org.apache.hadoop.hive.serde2.AbstractSerDe inputSerde, org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector inputSoi, HiveScriptIOSchema ioschema, java.io.OutputStream outputStream, Process proc, org.apache.spark.util.CircularBuffer stderrBuffer, TaskContext taskContext, org.apache.hadoop.conf.Configuration conf)