This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new abf9a3a [Chore] remove unuse comment (#352)
abf9a3a is described below
commit abf9a3a2a4932503c2eae0a6627dd3a97316c6b6
Author: wudi <[email protected]>
AuthorDate: Fri Mar 22 16:41:42 2024 +0800
[Chore] remove unuse comment (#352)
---
.../apache/doris/flink/table/DorisDynamicTableSource.java | 12 +-----------
1 file changed, 1 insertion(+), 11 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
index 6b09735..b6cd1a7 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
@@ -17,8 +17,6 @@
package org.apache.doris.flink.table;
-import org.apache.flink.api.common.serialization.DeserializationSchema;
-import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.connector.ChangelogMode;
import org.apache.flink.table.connector.Projection;
@@ -53,15 +51,7 @@ import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
-/**
- * The {@link DorisDynamicTableSource} is used during planning.
- *
- * <p>In our example, we don't implement any of the available ability
interfaces such as {@link
- * SupportsFilterPushDown} or {@link SupportsProjectionPushDown}. Therefore,
the main logic can be
- * found in {@link #getScanRuntimeProvider(ScanContext)} where we instantiate
the required {@link
- * SourceFunction} and its {@link DeserializationSchema} for runtime. Both
instances are
- * parameterized to return internal data structures (i.e. {@link RowData}).
- */
+/** The {@link DorisDynamicTableSource} is used during planning. */
public final class DorisDynamicTableSource
implements ScanTableSource,
LookupTableSource,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
