org.apache.hive.hcatalog.streaming

Class StrictRegexWriter

java.lang.Object

org.apache.hive.hcatalog.streaming.AbstractRecordWriter

org.apache.hive.hcatalog.streaming.StrictRegexWriter

All Implemented Interfaces:

RecordWriter

Deprecated.

as of Hive 3.0.0, replaced by StrictRegexWriter

@Deprecated
public class StrictRegexWriter
extends AbstractRecordWriter

Streaming Writer handles text input data with regex. Uses org.apache.hadoop.hive.serde2.RegexSerDe

Constructor Summary

Constructors

Constructor and Description
StrictRegexWriter(HiveEndPoint endPoint, HiveConf conf, StreamingConnection conn) Deprecated.
StrictRegexWriter(HiveEndPoint endPoint, StreamingConnection conn) Deprecated.
StrictRegexWriter(String regex, HiveEndPoint endPoint, HiveConf conf, StreamingConnection conn) Deprecated.

Method Summary

Modifier and Type	Method and Description
Object	encode(byte[] utf8StrRecord) Deprecated. Encode Utf8 encoded string bytes using RegexSerDe
protected ObjectInspector[]	getBucketObjectInspectors() Deprecated.
protected StructField[]	getBucketStructFields() Deprecated.
protected StructObjectInspector	getRecordObjectInspector() Deprecated.
AbstractSerDe	getSerde() Deprecated. Get the SerDe for the Objects created by AbstractRecordWriter.encode(byte[]).
void	write(long writeId, byte[] record) Deprecated. Writes using a hive RecordUpdater

Methods inherited from class org.apache.hive.hcatalog.streaming.AbstractRecordWriter

clear, closeBatch, flush, getBucket, getObjectInspectorsForBucketedCols, newBatch

Methods inherited from class java.lang.Object

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

Constructor Detail

StrictRegexWriter

public StrictRegexWriter(HiveEndPoint endPoint,
                         StreamingConnection conn)
                  throws ConnectionError,
                         SerializationError,
                         StreamingException

Deprecated.

Parameters:

endPoint - the end point to write to

conn - connection this Writer is to be used with

Throws:

ConnectionError

SerializationError

StreamingException

StrictRegexWriter

public StrictRegexWriter(HiveEndPoint endPoint,
                         HiveConf conf,
                         StreamingConnection conn)
                  throws ConnectionError,
                         SerializationError,
                         StreamingException

Deprecated.

Parameters:

endPoint - the end point to write to

conf - a Hive conf object. Should be null if not using advanced Hive settings.

conn - connection this Writer is to be used with

Throws:

ConnectionError

SerializationError

StreamingException

StrictRegexWriter

public StrictRegexWriter(String regex,
                         HiveEndPoint endPoint,
                         HiveConf conf,
                         StreamingConnection conn)
                  throws ConnectionError,
                         SerializationError,
                         StreamingException

Deprecated.

Parameters:

regex - to parse the data

endPoint - the end point to write to

conf - a Hive conf object. Should be null if not using advanced Hive settings.

conn - connection this Writer is to be used with

Throws:

ConnectionError

SerializationError

StreamingException

Method Detail

getSerde

public AbstractSerDe getSerde()

Deprecated.

Description copied from class: AbstractRecordWriter

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

Specified by:

getSerde in class AbstractRecordWriter

Returns:

serde

getRecordObjectInspector

protected StructObjectInspector getRecordObjectInspector()

Deprecated.

Specified by:

getRecordObjectInspector in class AbstractRecordWriter

getBucketStructFields

protected StructField[] getBucketStructFields()

Deprecated.

Specified by:

getBucketStructFields in class AbstractRecordWriter

getBucketObjectInspectors

protected ObjectInspector[] getBucketObjectInspectors()

Deprecated.

Specified by:

getBucketObjectInspectors in class AbstractRecordWriter

write

public void write(long writeId,
                  byte[] record)
           throws StreamingIOFailure,
                  SerializationError

Deprecated.

Description copied from interface: RecordWriter

Writes using a hive RecordUpdater

Parameters:

writeId - the write ID of the table mapping to Txn in which the write occurs

record - the record to be written

Throws:

StreamingIOFailure

SerializationError

encode

public Object encode(byte[] utf8StrRecord)
              throws SerializationError

Deprecated.

Encode Utf8 encoded string bytes using RegexSerDe

Specified by:

encode in class AbstractRecordWriter

Parameters:

utf8StrRecord -

Returns:

The encoded object

Throws:

SerializationError