[oracle] Updated package naming to com.ververica in oracle connector

This commit does not contain secrets
This closes #2
pull/512/head
Marton Balassi 4 years ago committed by Leonard Xu
parent 1fbd429314
commit 3ed4d9480c

@ -20,7 +20,7 @@ under the License.
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<artifactId>flink-cdc-connectors</artifactId> <artifactId>flink-cdc-connectors</artifactId>
<groupId>com.alibaba.ververica</groupId> <groupId>com.ververica</groupId>
<version>2.0-SNAPSHOT</version> <version>2.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
@ -33,7 +33,7 @@ under the License.
<!-- Debezium dependencies --> <!-- Debezium dependencies -->
<dependency> <dependency>
<groupId>com.alibaba.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-debezium</artifactId> <artifactId>flink-connector-debezium</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
<exclusions> <exclusions>
@ -53,7 +53,7 @@ under the License.
<!-- test dependencies on Debezium --> <!-- test dependencies on Debezium -->
<dependency> <dependency>
<groupId>com.alibaba.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-test-util</artifactId> <artifactId>flink-connector-test-util</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
<scope>test</scope> <scope>test</scope>

@ -16,12 +16,12 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle; package com.ververica.cdc.connectors.oracle;
import com.alibaba.ververica.cdc.connectors.oracle.table.StartupOptions; import com.ververica.cdc.connectors.oracle.table.StartupOptions;
import com.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema; import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction; import com.ververica.cdc.debezium.DebeziumSourceFunction;
import com.alibaba.ververica.cdc.debezium.internal.DebeziumOffset; import com.ververica.cdc.debezium.internal.DebeziumOffset;
import io.debezium.connector.oracle.OracleConnector; import io.debezium.connector.oracle.OracleConnector;
import java.util.Properties; import java.util.Properties;

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.table.api.TableSchema; import org.apache.flink.table.api.TableSchema;
@ -28,10 +28,10 @@ import org.apache.flink.table.data.RowData;
import org.apache.flink.table.types.logical.RowType; import org.apache.flink.table.types.logical.RowType;
import org.apache.flink.types.RowKind; import org.apache.flink.types.RowKind;
import com.alibaba.ververica.cdc.connectors.oracle.OracleSource; import com.ververica.cdc.connectors.oracle.OracleSource;
import com.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema; import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction; import com.ververica.cdc.debezium.DebeziumSourceFunction;
import com.alibaba.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema; import com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema;
import java.util.Objects; import java.util.Objects;
import java.util.Properties; import java.util.Properties;

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.ConfigOptions; import org.apache.flink.configuration.ConfigOptions;
@ -28,16 +28,16 @@ import org.apache.flink.table.factories.DynamicTableSourceFactory;
import org.apache.flink.table.factories.FactoryUtil; import org.apache.flink.table.factories.FactoryUtil;
import org.apache.flink.table.utils.TableSchemaUtils; import org.apache.flink.table.utils.TableSchemaUtils;
import com.alibaba.ververica.cdc.debezium.table.DebeziumOptions; import com.ververica.cdc.debezium.table.DebeziumOptions;
import java.util.HashSet; import java.util.HashSet;
import java.util.Set; import java.util.Set;
import static com.alibaba.ververica.cdc.debezium.table.DebeziumOptions.getDebeziumProperties; import static com.ververica.cdc.debezium.table.DebeziumOptions.getDebeziumProperties;
/** /**
* Factory for creating configured instance of {@link * Factory for creating configured instance of {@link
* com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSource}. * com.ververica.cdc.connectors.oracle.table.OracleTableSource}.
*/ */
public class OracleTableSourceFactory implements DynamicTableSourceFactory { public class OracleTableSourceFactory implements DynamicTableSourceFactory {

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
/** /**
* Startup modes for the Oracle CDC Consumer. * Startup modes for the Oracle CDC Consumer.

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
import java.util.Objects; import java.util.Objects;

@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory com.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle; package com.ververica.cdc.connectors.oracle;
import org.apache.flink.api.common.state.BroadcastState; import org.apache.flink.api.common.state.BroadcastState;
import org.apache.flink.api.common.state.KeyedStateStore; import org.apache.flink.api.common.state.KeyedStateStore;
@ -35,11 +35,11 @@ import org.apache.flink.test.util.AbstractTestBase;
import org.apache.flink.util.Collector; import org.apache.flink.util.Collector;
import org.apache.flink.util.Preconditions; import org.apache.flink.util.Preconditions;
import com.alibaba.ververica.cdc.connectors.oracle.utils.OracleTestUtils;
import com.alibaba.ververica.cdc.connectors.utils.TestSourceContext;
import com.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction;
import com.jayway.jsonpath.JsonPath; import com.jayway.jsonpath.JsonPath;
import com.ververica.cdc.connectors.oracle.utils.OracleTestUtils;
import com.ververica.cdc.connectors.utils.TestSourceContext;
import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.ververica.cdc.debezium.DebeziumSourceFunction;
import org.apache.kafka.connect.source.SourceRecord; import org.apache.kafka.connect.source.SourceRecord;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -67,10 +67,10 @@ import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.Stream; import java.util.stream.Stream;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertDelete; import static com.ververica.cdc.connectors.utils.AssertUtils.assertDelete;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertInsert; import static com.ververica.cdc.connectors.utils.AssertUtils.assertInsert;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertRead; import static com.ververica.cdc.connectors.utils.AssertUtils.assertRead;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertUpdate; import static com.ververica.cdc.connectors.utils.AssertUtils.assertUpdate;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.EnvironmentSettings;

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.table; package com.ververica.cdc.connectors.oracle.table;
import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.Configuration;
@ -47,8 +47,8 @@ import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail; import static org.junit.Assert.fail;
/** /**
* Test for {@link com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSource} created by * Test for {@link com.ververica.cdc.connectors.oracle.table.OracleTableSource} created by {@link
* {@link com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory}. * com.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory}.
*/ */
public class OracleTableSourceFactoryTest { public class OracleTableSourceFactoryTest {
private static final ResolvedSchema SCHEMA = private static final ResolvedSchema SCHEMA =

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle.utils; package com.ververica.cdc.connectors.oracle.utils;
import org.testcontainers.containers.OracleContainer; import org.testcontainers.containers.OracleContainer;

@ -20,7 +20,7 @@ under the License.
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<artifactId>flink-cdc-connectors</artifactId> <artifactId>flink-cdc-connectors</artifactId>
<groupId>com.alibaba.ververica</groupId> <groupId>com.ververica</groupId>
<version>2.0-SNAPSHOT</version> <version>2.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
@ -29,7 +29,7 @@ under the License.
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.alibaba.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-oracle-cdc</artifactId> <artifactId>flink-connector-oracle-cdc</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package com.alibaba.ververica.cdc.connectors.oracle; package com.ververica.cdc.connectors.oracle;
/** This is used to generate a dummy docs jar for this module to pass OSS repository rule. */ /** This is used to generate a dummy docs jar for this module to pass OSS repository rule. */
public class DummyDocs {} public class DummyDocs {}
Loading…
Cancel
Save