Overview

HBase Sink is a sink component aimed at writing content to an Apache HBase storage.

FQCN

com.datumize.ddc.component.hbase.HBaseRestSink

Properties


Common properties that apply to all sink components of a pipeline.

PROPERTYIDDESCRIPTION

REQUIRED

TYPE

DEFAULT

EXAMPLES

Common
IdentifierIDComponent unique Identifier within the pipeline, read only, only useful for advanced mode.YesStringAuto

MyComponent_23423

This Identifier is automatically generated by the system and you can't change it. Might be helpful for advanced pipeline configuration.

DescriptiondescriptionA short description for the component, to be visualized inside the component representation, aimed at providing additional information to understand the pipeline at a glance.NoString

Extract customer id and loyalty number.

Short and sweet description.

PROPERTYIDDESCRIPTIONREQUIREDTYPEDEFAULT
Default
URLhbase-rest-urlHBase connection URL, including protocol, host and port.YesURL
Advanced
Kerberos userkerberos-principal

Name of Kerberos principal to use, if any. Kerberos is used in Amazon EMR secured instances.

YesString
Kerberos passwordkerberos-password

Password of the Kerberos principal to use. Only required if kerberos-principal is used.

NoString
Maximum retries

max-retries

Maximum number of retries to connect before fail.

No

Integer1
Content format

content-format

Data format to send to HBase.

No

XML

JSON

JSON
Converter

converter

Converter to convert input data into supported HBase row objects.

See Converters section.




Converters

Following are compatible converters that convert input record into an acceptable row supported by HBase.

Map to Row Converter

It converts a map to a HBase row putting each key-value tuple into an HBase cell. This converter only supports the following types as map values: String, Integer, Long, byte[]. Any other types will be discarded.

FQCNcom.datumize.ddc.component.hbase.converter.MapHBaseRowConverter

Supported properties:

PROPERTYIDDESCRIPTIONTYPEREQUIREDDEFAULT
Row namerowHBase row nameStringYes