org.apache.nifi.hbase.io

Class JsonRowSerializer

java.lang.Object

org.apache.nifi.hbase.io.JsonRowSerializer

All Implemented Interfaces:

RowSerializer

public class JsonRowSerializer
extends java.lang.Object
implements RowSerializer

Serializes a row from HBase to a JSON document of the form: { "row" : "row1", "cells": { "fam1:qual1" : "val1", "fam1:qual2" : "val2" } }

Constructor Summary

Constructors

Constructor and Description
JsonRowSerializer(java.nio.charset.Charset charset)

Method Summary

Modifier and Type	Method and Description
java.lang.String	serialize(byte[] rowKey, ResultCell[] cells)
void	serialize(byte[] rowKey, ResultCell[] cells, java.io.OutputStream out) Serializes the given row and cells to the provided OutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonRowSerializer

public JsonRowSerializer(java.nio.charset.Charset charset)

Method Detail

serialize

public java.lang.String serialize(byte[] rowKey,
                                  ResultCell[] cells)

Specified by:

serialize in interface RowSerializer

Parameters:

rowKey - the row key of the row being serialized

cells - the cells of the row being serialized

Returns:

the serialized string representing the row

serialize

public void serialize(byte[] rowKey,
                      ResultCell[] cells,
                      java.io.OutputStream out)
               throws java.io.IOException

Description copied from interface: RowSerializer

Serializes the given row and cells to the provided OutputStream

Specified by:

serialize in interface RowSerializer

Parameters:

rowKey - the row's key

cells - the cells to serialize

out - the OutputStream to serialize to

Throws:

java.io.IOException - if unable to serialize the row