THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@Internal
public class ClickHouseDynamicTableSource implements ScanTableSource, LookupTableSource, SupportsLimitPushDown {
private final Scheme tableSchema;
private final ClickHouseOptions options;
@Override
public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext lookupContext) {
return null;
}
@Override
public ChangelogMode getChangelogMode() {
return null;
}
@Override
public ScanRuntimeProvider getScanRuntimeProvider(ScanContext scanContext){
}
@Override
public DynamicTableSource copy() {
}
@Override
public String asSummaryString() {
return null;
}
@Override
public void applyLimit(long limit) {
...
}
} |
...
Flink-ClickHouse Metaspace Mapping
Flink Catalog Metaspace Structure | ClickHouse Metaspace Structure |
catalog name (defined in Flink only) | n/a |
database name | database name |
table name | table name |
Flink-ClickHouse Data Type Mapping
...