@Experimental public abstract class HCatalogTable extends BaseBeamTable
HCatalogIO
.
Reads HCatRecords
and converts them to Rows
.
Constructor and Description |
---|
HCatalogTable() |
Modifier and Type | Method and Description |
---|---|
PCollection<Row> |
buildIOReader(PBegin begin)
create a
PCollection<Row> from source. |
POutput |
buildIOWriter(PCollection<Row> input)
create a
IO.write() instance to write to target. |
abstract java.util.Map<java.lang.String,java.lang.String> |
config() |
abstract java.lang.String |
database() |
Schema |
getSchema()
Get the schema info of the table.
|
PCollection.IsBounded |
isBounded()
Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).
|
abstract Schema |
schema() |
abstract java.lang.String |
table() |
buildIOReader, constructFilter, getTableStatistics, supportsProjects
public abstract Schema schema()
public abstract java.util.Map<java.lang.String,java.lang.String> config()
public abstract java.lang.String database()
public abstract java.lang.String table()
public PCollection<Row> buildIOReader(PBegin begin)
BeamSqlTable
PCollection<Row>
from source.public POutput buildIOWriter(PCollection<Row> input)
BeamSqlTable
IO.write()
instance to write to target.public PCollection.IsBounded isBounded()
BeamSqlTable
public Schema getSchema()
BeamSqlTable