BeamPCollectionTable (sql 2.71.0 API)

java.lang.Object
- org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
- - org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable
  - - org.apache.beam.sdk.extensions.sql.impl.schema.BeamPCollectionTable<InputT>

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable
```
public class BeamPCollectionTable<InputT>
extends SchemaBaseBeamTable
```
BeamPCollectionTable converts a PCollection<Row> as a virtual table, then a downstream query can query directly.

See Also:

Serialized Form

Field Summary
- Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable
  schema

Constructor Summary

Constructors
Constructor Description

BeamPCollectionTable(org.apache.beam.sdk.values.PCollection<InputT> upstream)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>`	`buildIOReader(org.apache.beam.sdk.values.PBegin begin)`	create a `PCollection<Row>` from source.
`org.apache.beam.sdk.values.POutput`	`buildIOWriter(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> input)`	create a `IO.write()` instance to write to target.
`org.apache.beam.sdk.values.PCollection.IsBounded`	`isBounded()`	Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable
getSchema

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
buildIOReader, constructFilter, getTableStatistics, supportsProjects

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BeamPCollectionTable

public BeamPCollectionTable(org.apache.beam.sdk.values.PCollection<InputT> upstream)

Method Detail
- isBounded
```
public org.apache.beam.sdk.values.PCollection.IsBounded isBounded()
```
  Description copied from interface: BeamSqlTable
  
  Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).
- buildIOReader
```
public org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> buildIOReader(org.apache.beam.sdk.values.PBegin begin)
```
  Description copied from interface: BeamSqlTable
  
  create a PCollection<Row> from source.
- buildIOWriter
```
public org.apache.beam.sdk.values.POutput buildIOWriter(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> input)
```
  Description copied from interface: BeamSqlTable
  
  create a IO.write() instance to write to target.