StrictRegexWriter
@Deprecated public class StrictRegexWriter extends AbstractRecordWriter
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.
|
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
|
clear, closeBatch, flush, getBucket, getObjectInspectorsForBucketedCols, newBatch
public StrictRegexWriter(HiveEndPoint endPoint, StreamingConnection conn) throws ConnectionError, SerializationError, StreamingException
endPoint
- the end point to write toconn
- connection this Writer is to be used withConnectionError
SerializationError
StreamingException
public StrictRegexWriter(HiveEndPoint endPoint, HiveConf conf, StreamingConnection conn) throws ConnectionError, SerializationError, StreamingException
endPoint
- the end point to write toconf
- a Hive conf object. Should be null if not using advanced Hive settings.conn
- connection this Writer is to be used withConnectionError
SerializationError
StreamingException
public StrictRegexWriter(String regex, HiveEndPoint endPoint, HiveConf conf, StreamingConnection conn) throws ConnectionError, SerializationError, StreamingException
regex
- to parse the dataendPoint
- the end point to write toconf
- a Hive conf object. Should be null if not using advanced Hive settings.conn
- connection this Writer is to be used withConnectionError
SerializationError
StreamingException
public AbstractSerDe getSerde()
AbstractRecordWriter
AbstractRecordWriter.encode(byte[])
. This is public so that test
frameworks can use it.getSerde
in class AbstractRecordWriter
protected StructObjectInspector getRecordObjectInspector()
getRecordObjectInspector
in class AbstractRecordWriter
protected StructField[] getBucketStructFields()
getBucketStructFields
in class AbstractRecordWriter
protected ObjectInspector[] getBucketObjectInspectors()
getBucketObjectInspectors
in class AbstractRecordWriter
public void write(long writeId, byte[] record) throws StreamingIOFailure, SerializationError
RecordWriter
writeId
- the write ID of the table mapping to Txn in which the write occursrecord
- the record to be writtenStreamingIOFailure
SerializationError
public Object encode(byte[] utf8StrRecord) throws SerializationError
encode
in class AbstractRecordWriter
utf8StrRecord
- SerializationError
Copyright © 2022 The Apache Software Foundation. All rights reserved.