public class StrictDelimitedInputWriter extends AbstractRecordWriter
Modifier and Type | Class and Description |
---|---|
static class |
StrictDelimitedInputWriter.Builder |
AbstractRecordWriter.OrcMemoryPressureMonitor
acidOutputFormat, autoFlush, bucketFieldData, bucketIds, bucketObjInspectors, bucketStructFields, conf, conn, curBatchMaxWriteId, curBatchMinWriteId, defaultPartitionName, fs, fullyQualifiedTableName, heapMemoryMonitor, ingestSizeBytes, ingestSizeThreshold, inputColumns, inputRowObjectInspector, inputTypes, isBucketed, lineDelimiter, lowMemoryCanary, memoryUsageThreshold, outputRowObjectInspector, partitionColumns, partitionFieldData, partitionObjInspectors, partitionPaths, partitionStructFields, table, totalBuckets, updatedPartitions, updaters
Modifier and Type | Method and Description |
---|---|
LazySimpleSerDe |
createSerde()
Create SerDe for the record writer.
|
Object |
encode(byte[] record)
Encode a record as an Object that Hive can read with the ObjectInspector associated with the
serde returned by
AbstractRecordWriter.createSerde() . |
static StrictDelimitedInputWriter.Builder |
newBuilder() |
checkAutoFlush, close, createRecordUpdater, flush, getBucket, getBucketColIDs, getBucketFields, getDeltaFileLocation, getObjectInspectorsForBucketedCols, getPartitionFields, getPartitions, getPartitionValues, getRecordUpdater, getWatermark, init, init, initializeBuckets, logStats, prepareBucketingFields, preparePartitioningFields, setupMemoryMonitoring, write, write
public static StrictDelimitedInputWriter.Builder newBuilder()
public Object encode(byte[] record) throws SerializationError
AbstractRecordWriter
AbstractRecordWriter.createSerde()
. This is public so that test frameworks can use it.encode
in class AbstractRecordWriter
record
- record to be deserializedSerializationError
- - any error during serialization or deserialization of recordpublic LazySimpleSerDe createSerde() throws SerializationError
AbstractRecordWriter
createSerde
in class AbstractRecordWriter
SerializationError
- - if serde cannot be created.Copyright © 2022 The Apache Software Foundation. All rights reserved.