public class StrictRegexWriter extends AbstractRecordWriter
Modifier and Type | Class and Description |
---|---|
static class |
StrictRegexWriter.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
Modifier and Type | Method and Description |
---|---|
RegexSerDe |
createSerde()
Creates RegexSerDe
|
Object |
encode(byte[] utf8StrRecord)
Encode Utf8 encoded string bytes using RegexSerDe
|
static StrictRegexWriter.Builder |
newBuilder() |
checkAutoFlush, close, createRecordUpdater, flush, getBucket, getBucketColIDs, getBucketFields, getObjectInspectorsForBucketedCols, getPartitionFields, getPartitions, getPartitionValues, getRecordUpdater, getWatermark, init, initializeBuckets, logStats, prepareBucketingFields, preparePartitioningFields, setupMemoryMonitoring, write, write
public static StrictRegexWriter.Builder newBuilder()
public RegexSerDe createSerde() throws SerializationError
createSerde
in class AbstractRecordWriter
SerializationError
- if serde could not be initializedpublic Object encode(byte[] utf8StrRecord) throws SerializationError
encode
in class AbstractRecordWriter
utf8StrRecord
- - serialized recordSerializationError
- - in case of any deserialization errorCopyright © 2022 The Apache Software Foundation. All rights reserved.