public abstract class KafkaTableSource extends Object implements StreamTableSource<Row>
StreamTableSource
.
The version-specific Kafka consumers need to extend this class and
override getKafkaConsumer(String, Properties, DeserializationSchema)
}.
Modifier and Type | Method and Description |
---|---|
String |
explainSource()
Describes the table source
|
DataStream<Row> |
getDataStream(StreamExecutionEnvironment env)
NOTE: This method is for internal use only for defining a TableSource.
|
protected DeserializationSchema<Row> |
getDeserializationSchema()
Returns the deserialization schema.
|
TypeInformation<Row> |
getReturnType()
Returns the
TypeInformation for the return type of the TableSource . |
public DataStream<Row> getDataStream(StreamExecutionEnvironment env)
getDataStream
in interface StreamTableSource<Row>
env
- (undocumented)public TypeInformation<Row> getReturnType()
TableSource
TypeInformation
for the return type of the TableSource
.getReturnType
in interface TableSource<Row>
protected DeserializationSchema<Row> getDeserializationSchema()
public String explainSource()
TableSource
explainSource
in interface TableSource<Row>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.