public class SourceSink extends Object implements org.apache.flink.table.descriptors.TableDescriptor
Modifier | Constructor and Description |
---|---|
protected |
SourceSink(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
void |
addProperties(org.apache.flink.table.descriptors.DescriptorProperties properties) |
String |
getName() |
Map<String,String> |
getProperties() |
Sink |
toSink() |
Source |
toSource() |
public String getName()
public void addProperties(org.apache.flink.table.descriptors.DescriptorProperties properties)
addProperties
in interface org.apache.flink.table.descriptors.Descriptor
public Source toSource()
public Sink toSink()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.