public class StrictJsonWriter extends AbstractRecordWriter
Modifier and Type | Class and Description |
---|---|
static class |
StrictJsonWriter.Builder |
AbstractRecordWriter.OrcMemoryPressureMonitor
acidOutputFormat, addedPartitions, 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, updaters
Constructor and Description |
---|
StrictJsonWriter(StrictJsonWriter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
JsonSerDe |
createSerde()
Creates JsonSerDe
|
Object |
encode(byte[] utf8StrRecord)
Encode a record as an Object that Hive can read with the ObjectInspector associated with the
serde returned by
AbstractRecordWriter.createSerde() . |
static StrictJsonWriter.Builder |
newBuilder() |
checkAutoFlush, close, createRecordUpdater, flush, getBucket, getBucketColIDs, getBucketFields, getObjectInspectorsForBucketedCols, getPartitionFields, getPartitions, getPartitionValues, getRecordUpdater, getWatermark, init, initializeBuckets, logStats, prepareBucketingFields, preparePartitioningFields, setupMemoryMonitoring, write, write
public StrictJsonWriter(StrictJsonWriter.Builder builder)
public static StrictJsonWriter.Builder newBuilder()
public JsonSerDe createSerde() throws SerializationError
createSerde
in class AbstractRecordWriter
SerializationError
- if serde could not be initializedpublic Object encode(byte[] utf8StrRecord) throws SerializationError
AbstractRecordWriter
AbstractRecordWriter.createSerde()
. This is public so that test frameworks can use it.encode
in class AbstractRecordWriter
utf8StrRecord
- record to be deserializedSerializationError
- - any error during serialization or deserialization of recordCopyright © 2022 The Apache Software Foundation. All rights reserved.