StrictDelimitedInputWriter
@Deprecated public class DelimitedInputWriter extends AbstractRecordWriter
Constructor and Description |
---|
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint)
Deprecated.
As of release 1.3/2.1. Replaced by
DelimitedInputWriter(String[], String, HiveEndPoint, StreamingConnection) |
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint,
HiveConf conf)
Deprecated.
As of release 1.3/2.1. Replaced by
DelimitedInputWriter(String[], String, HiveEndPoint, HiveConf, StreamingConnection) |
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint,
HiveConf conf,
char serdeSeparator)
Deprecated.
As of release 1.3/2.1. Replaced by
DelimitedInputWriter(String[], String, HiveEndPoint, HiveConf, char, StreamingConnection) |
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint,
HiveConf conf,
char serdeSeparator,
StreamingConnection conn)
Deprecated.
Constructor.
|
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint,
HiveConf conf,
StreamingConnection conn)
Deprecated.
Constructor.
|
DelimitedInputWriter(String[] colNamesForFields,
String delimiter,
HiveEndPoint endPoint,
StreamingConnection conn)
Deprecated.
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected static LazySimpleSerDe |
createSerde(Table tbl,
HiveConf conf,
char serdeSeparator)
Deprecated.
Creates LazySimpleSerde
|
Object |
encode(byte[] record)
Deprecated.
Encode a record as an Object that Hive can read with the ObjectInspector associated with the
serde returned by
AbstractRecordWriter.getSerde() . |
protected ObjectInspector[] |
getBucketObjectInspectors()
Deprecated.
|
protected StructField[] |
getBucketStructFields()
Deprecated.
|
protected LazySimpleStructObjectInspector |
getRecordObjectInspector()
Deprecated.
|
AbstractSerDe |
getSerde()
Deprecated.
Get the SerDe for the Objects created by
AbstractRecordWriter.encode(byte[]) . |
char |
getSerdeSeparator()
Deprecated.
|
protected ArrayList<String> |
getTableColumns()
Deprecated.
|
protected byte[] |
reorderFields(byte[] record)
Deprecated.
|
void |
write(long writeId,
byte[] record)
Deprecated.
Writes using a hive RecordUpdater
|
clear, closeBatch, flush, getBucket, getObjectInspectorsForBucketedCols, newBatch
public DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, StreamingConnection conn) throws ClassNotFoundException, ConnectionError, SerializationError, InvalidColumn, StreamingException
colNamesForFields
- Column name assignment for input fields. nulls or empty
strings in the array indicates the fields to be skippeddelimiter
- input field delimiterendPoint
- Hive endpointConnectionError
- Problem talking to HiveClassNotFoundException
- Serde class not foundSerializationError
- Serde initialization/interaction failedStreamingException
- Problem acquiring file system path for partitionInvalidColumn
- any element in colNamesForFields refers to a non existing columnpublic DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf, StreamingConnection conn) throws ClassNotFoundException, ConnectionError, SerializationError, InvalidColumn, StreamingException
colNamesForFields
- Column name assignment for input fields. nulls or empty
strings in the array indicates the fields to be skippeddelimiter
- input field delimiterendPoint
- Hive endpointconf
- a Hive conf object. Can be null if not using advanced hive settings.ConnectionError
- Problem talking to HiveClassNotFoundException
- Serde class not foundSerializationError
- Serde initialization/interaction failedStreamingException
- Problem acquiring file system path for partitionInvalidColumn
- any element in colNamesForFields refers to a non existing columnpublic DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf, char serdeSeparator, StreamingConnection conn) throws ClassNotFoundException, ConnectionError, SerializationError, InvalidColumn, StreamingException
colNamesForFields
- Column name assignment for input fieldsdelimiter
- input field delimiterendPoint
- Hive endpointconf
- a Hive conf object. Set to null if not using advanced hive settings.serdeSeparator
- separator used when encoding data that is fed into the
LazySimpleSerde. Ensure this separator does not occur
in the field dataconn
- connection this Writer is to be used withConnectionError
- Problem talking to HiveClassNotFoundException
- Serde class not foundSerializationError
- Serde initialization/interaction failedStreamingException
- Problem acquiring file system path for partitionInvalidColumn
- any element in colNamesForFields refers to a non existing columnpublic DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint) throws ClassNotFoundException, ConnectionError, SerializationError, InvalidColumn, StreamingException
DelimitedInputWriter(String[], String, HiveEndPoint, StreamingConnection)
public DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf) throws ClassNotFoundException, ConnectionError, SerializationError, InvalidColumn, StreamingException
DelimitedInputWriter(String[], String, HiveEndPoint, HiveConf, StreamingConnection)
public DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf, char serdeSeparator) throws ClassNotFoundException, StreamingException
DelimitedInputWriter(String[], String, HiveEndPoint, HiveConf, char, StreamingConnection)
protected byte[] reorderFields(byte[] record) throws UnsupportedEncodingException
UnsupportedEncodingException
public void write(long writeId, byte[] record) throws SerializationError, StreamingIOFailure
RecordWriter
writeId
- the write ID of the table mapping to Txn in which the write occursrecord
- the record to be writtenSerializationError
StreamingIOFailure
public AbstractSerDe getSerde()
AbstractRecordWriter
AbstractRecordWriter.encode(byte[])
. This is public so that test
frameworks can use it.getSerde
in class AbstractRecordWriter
protected LazySimpleStructObjectInspector getRecordObjectInspector()
getRecordObjectInspector
in class AbstractRecordWriter
protected StructField[] getBucketStructFields()
getBucketStructFields
in class AbstractRecordWriter
protected ObjectInspector[] getBucketObjectInspectors()
getBucketObjectInspectors
in class AbstractRecordWriter
public Object encode(byte[] record) throws SerializationError
AbstractRecordWriter
AbstractRecordWriter.getSerde()
. This is public so that test frameworks can use it.encode
in class AbstractRecordWriter
record
- record to be deserializedSerializationError
protected static LazySimpleSerDe createSerde(Table tbl, HiveConf conf, char serdeSeparator) throws SerializationError
tbl
- SerializationError
- if serde could not be initializedpublic char getSerdeSeparator()
Copyright © 2022 The Apache Software Foundation. All rights reserved.