public class HBaseSerde extends Object
Constructor and Description |
---|
HBaseSerde(HBaseTableSchema hbaseSchema,
String nullStringLiteral) |
Modifier and Type | Method and Description |
---|---|
RowData |
convertToRow(org.apache.hadoop.hbase.client.Result result)
Converts HBase
Result into RowData . |
org.apache.hadoop.hbase.client.Delete |
createDeleteMutation(RowData row)
Returns an instance of Delete that remove record from HBase table.
|
org.apache.hadoop.hbase.client.Get |
createGet(Object rowKey)
Returns an instance of Get that retrieves the matches records from the HBase table.
|
org.apache.hadoop.hbase.client.Put |
createPutMutation(RowData row)
Returns an instance of Put that writes record to HBase table.
|
org.apache.hadoop.hbase.client.Scan |
createScan()
Returns an instance of Scan that retrieves the required subset of records from the HBase
table.
|
public HBaseSerde(HBaseTableSchema hbaseSchema, String nullStringLiteral)
@Nullable public org.apache.hadoop.hbase.client.Put createPutMutation(RowData row)
@Nullable public org.apache.hadoop.hbase.client.Delete createDeleteMutation(RowData row)
public org.apache.hadoop.hbase.client.Scan createScan()
public org.apache.hadoop.hbase.client.Get createGet(Object rowKey)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.