org.apache.hive.hcatalog.streaming

Class AbstractRecordWriter

java.lang.Object

org.apache.hive.hcatalog.streaming.AbstractRecordWriter

All Implemented Interfaces:

RecordWriter

Direct Known Subclasses:

DelimitedInputWriter, StrictJsonWriter, StrictRegexWriter

Deprecated.

as of Hive 3.0.0, replaced by AbstractRecordWriter

@Deprecated
public abstract class AbstractRecordWriter
extends Object
implements RecordWriter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRecordWriter(HiveEndPoint endPoint, HiveConf conf) Deprecated. As of release 1.3/2.1. Replaced by AbstractRecordWriter(HiveEndPoint, HiveConf, StreamingConnection)
protected	AbstractRecordWriter(HiveEndPoint endPoint2, HiveConf conf, StreamingConnection conn) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	clear() Deprecated. Clear bufferred writes.
void	closeBatch() Deprecated. Close the RecordUpdater.
abstract Object	encode(byte[] record) Deprecated. Encode a record as an Object that Hive can read with the ObjectInspector associated with the serde returned by getSerde().
void	flush() Deprecated. Flush records from buffer.
protected int	getBucket(Object row) Deprecated.
protected abstract ObjectInspector[]	getBucketObjectInspectors() Deprecated.
protected abstract StructField[]	getBucketStructFields() Deprecated.
protected static ObjectInspector[]	getObjectInspectorsForBucketedCols(List<Integer> bucketIds, StructObjectInspector recordObjInspector) Deprecated.
protected abstract StructObjectInspector	getRecordObjectInspector() Deprecated.
abstract AbstractSerDe	getSerde() Deprecated. Get the SerDe for the Objects created by encode(byte[]).
void	newBatch(Long minWriteId, Long maxWriteID) Deprecated. Creates a new record updater for the new batch

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hive.hcatalog.streaming.RecordWriter

write

Constructor Detail

AbstractRecordWriter

protected AbstractRecordWriter(HiveEndPoint endPoint,
                               HiveConf conf)
                        throws ConnectionError,
                               StreamingException

Deprecated. As of release 1.3/2.1. Replaced by AbstractRecordWriter(HiveEndPoint, HiveConf, StreamingConnection)

Throws:

ConnectionError

StreamingException

AbstractRecordWriter

protected AbstractRecordWriter(HiveEndPoint endPoint2,
                               HiveConf conf,
                               StreamingConnection conn)
                        throws StreamingException

Deprecated.

Throws:

StreamingException

Method Detail

getSerde

public abstract AbstractSerDe getSerde()
                                throws SerializationError

Deprecated.

Get the SerDe for the Objects created by encode(byte[]). This is public so that test frameworks can use it.

Returns:

serde

Throws:

SerializationError

encode

public abstract Object encode(byte[] record)
                       throws SerializationError

Deprecated.

Encode a record as an Object that Hive can read with the ObjectInspector associated with the serde returned by getSerde(). This is public so that test frameworks can use it.

Parameters:

record - record to be deserialized

Returns:

deserialized record as an Object

Throws:

SerializationError

getBucketObjectInspectors

protected abstract ObjectInspector[] getBucketObjectInspectors()

Deprecated.

getRecordObjectInspector

protected abstract StructObjectInspector getRecordObjectInspector()

Deprecated.

getBucketStructFields

protected abstract StructField[] getBucketStructFields()

Deprecated.

getBucket

protected int getBucket(Object row)
                 throws SerializationError

Deprecated.

Throws:

SerializationError

flush

public void flush()
           throws StreamingIOFailure

Deprecated.

Description copied from interface: RecordWriter

Flush records from buffer. Invoked by TransactionBatch.commit()

Specified by:

flush in interface RecordWriter

Throws:

StreamingIOFailure

clear

public void clear()
           throws StreamingIOFailure

Deprecated.

Description copied from interface: RecordWriter

Clear bufferred writes. Invoked by TransactionBatch.abort()

Specified by:

clear in interface RecordWriter

Throws:

StreamingIOFailure

newBatch

public void newBatch(Long minWriteId,
                     Long maxWriteID)
              throws StreamingIOFailure,
                     SerializationError

Deprecated.

Creates a new record updater for the new batch

Specified by:

newBatch in interface RecordWriter

Parameters:

minWriteId - smallest writeid in the batch

maxWriteID - largest writeid in the batch

Throws:

StreamingIOFailure - if failed to create record updater

SerializationError

closeBatch

public void closeBatch()
                throws StreamingIOFailure

Deprecated.

Description copied from interface: RecordWriter

Close the RecordUpdater. Invoked by TransactionBatch.close()

Specified by:

closeBatch in interface RecordWriter

Throws:

StreamingIOFailure

getObjectInspectorsForBucketedCols

protected static ObjectInspector[] getObjectInspectorsForBucketedCols(List<Integer> bucketIds,
                                                                      StructObjectInspector recordObjInspector)
                                                               throws SerializationError

Deprecated.

Throws:

SerializationError