Package | Description |
---|---|
org.apache.hive.hcatalog.streaming |
HCatalog Streaming API -- high level description
|
Modifier and Type | Method and Description |
---|---|
protected static LazySimpleSerDe |
DelimitedInputWriter.createSerde(Table tbl,
HiveConf conf,
char serdeSeparator)
Creates LazySimpleSerde
|
Object |
StrictRegexWriter.encode(byte[] utf8StrRecord)
Encode Utf8 encoded string bytes using RegexSerDe
|
abstract Object |
AbstractRecordWriter.encode(byte[] record)
Encode a record as an Object that Hive can read with the ObjectInspector associated with the
serde returned by
AbstractRecordWriter.getSerde() . |
Object |
StrictJsonWriter.encode(byte[] utf8StrRecord) |
Object |
DelimitedInputWriter.encode(byte[] record) |
protected int |
AbstractRecordWriter.getBucket(Object row) |
protected static ObjectInspector[] |
AbstractRecordWriter.getObjectInspectorsForBucketedCols(List<Integer> bucketIds,
StructObjectInspector recordObjInspector) |
abstract AbstractSerDe |
AbstractRecordWriter.getSerde()
Get the SerDe for the Objects created by
AbstractRecordWriter.encode(byte[]) . |
void |
AbstractRecordWriter.newBatch(Long minTxnId,
Long maxTxnID)
Creates a new record updater for the new batch
|
void |
StrictRegexWriter.write(long transactionId,
byte[] record) |
void |
StrictJsonWriter.write(long transactionId,
byte[] record) |
void |
DelimitedInputWriter.write(long transactionId,
byte[] record) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.