public class LegacyMutationConverter extends Object implements HBaseMutationConverter<Tuple2<Boolean,Row>>
HBaseTableSource
.Constructor and Description |
---|
LegacyMutationConverter(HBaseTableSchema schema) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.client.Mutation |
convertToMutation(Tuple2<Boolean,Row> record)
Converts the input record into HBase
Mutation . |
void |
open()
Initialization method for the function.
|
public LegacyMutationConverter(HBaseTableSchema schema)
public void open()
HBaseMutationConverter
open
in interface HBaseMutationConverter<Tuple2<Boolean,Row>>
public org.apache.hadoop.hbase.client.Mutation convertToMutation(Tuple2<Boolean,Row> record)
HBaseMutationConverter
Mutation
. A mutation can be a Put
or
Delete
.convertToMutation
in interface HBaseMutationConverter<Tuple2<Boolean,Row>>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.