@Internal public abstract class AbstractArrowTableSource<T> extends Object implements StreamTableSource<T>
StreamTableSource
for serialized arrow record batch data.Modifier and Type | Method and Description |
---|---|
DataType |
getProducedDataType()
Returns the
DataType for the produced data of the TableSource . |
TableSchema |
getTableSchema()
Returns the schema of the produced table.
|
boolean |
isBounded()
Returns true if this is a bounded source, false if this is an unbounded source.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDataStream
explainSource, getReturnType
public boolean isBounded()
StreamTableSource
isBounded
in interface StreamTableSource<T>
public TableSchema getTableSchema()
TableSource
getTableSchema
in interface TableSource<T>
TableSchema
of the produced table.public DataType getProducedDataType()
TableSource
DataType
for the produced data of the TableSource
.getProducedDataType
in interface TableSource<T>
DataSet
or DataStream
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.