Package org.apache.beam.sdk.io.hcatalog

Class HCatToRow

java.lang.Object

org.apache.beam.sdk.io.hcatalog.HCatToRow

public class HCatToRow
extends Object

Utilities to convert HCatRecords to Rows.

Constructor Summary

Constructors

Constructor	Description
HCatToRow()

Method Summary

Modifier and Type	Method	Description
static PTransform<PBegin,PCollection<Row>>	fromSpec(HCatalogIO.Read readSpec)	Wraps the HCatalogIO.read() to convert HCatRecords to Rows.

Methods inherited from class java.lang.Object

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

Constructor Details

HCatToRow

public HCatToRow()

Method Details

fromSpec

public static PTransform<PBegin,PCollection<Row>> fromSpec(HCatalogIO.Read readSpec)

Wraps the HCatalogIO.read() to convert HCatRecords to Rows.

Eventually this should become part of the IO, e.g. HCatalogIO.readRows().