Skip to content

Commit

Permalink
[oracle] Updated package naming to com.ververica in oracle connector
Browse files Browse the repository at this point in the history
This commit does not contain secrets
This closes #2
  • Loading branch information
mbalassi authored and leonardBang committed Oct 21, 2021
1 parent b225da1 commit 12ce0f0
Show file tree
Hide file tree
Showing 13 changed files with 37 additions and 37 deletions.
6 changes: 3 additions & 3 deletions flink-connector-oracle-cdc/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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">
<parent>
<artifactId>flink-cdc-connectors</artifactId>
<groupId>com.alibaba.ververica</groupId>
<groupId>com.ververica</groupId>
<version>2.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
Expand All @@ -33,7 +33,7 @@ under the License.

<!-- Debezium dependencies -->
<dependency>
<groupId>com.alibaba.ververica</groupId>
<groupId>com.ververica</groupId>
<artifactId>flink-connector-debezium</artifactId>
<version>${project.version}</version>
<exclusions>
Expand All @@ -53,7 +53,7 @@ under the License.
<!-- test dependencies on Debezium -->

<dependency>
<groupId>com.alibaba.ververica</groupId>
<groupId>com.ververica</groupId>
<artifactId>flink-connector-test-util</artifactId>
<version>${project.version}</version>
<scope>test</scope>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,12 @@
* 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.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction;
import com.alibaba.ververica.cdc.debezium.internal.DebeziumOffset;
import com.ververica.cdc.connectors.oracle.table.StartupOptions;
import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.ververica.cdc.debezium.DebeziumSourceFunction;
import com.ververica.cdc.debezium.internal.DebeziumOffset;
import io.debezium.connector.oracle.OracleConnector;

import java.util.Properties;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.table.api.TableSchema;
Expand All @@ -28,10 +28,10 @@
import org.apache.flink.table.types.logical.RowType;
import org.apache.flink.types.RowKind;

import com.alibaba.ververica.cdc.connectors.oracle.OracleSource;
import com.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction;
import com.alibaba.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema;
import com.ververica.cdc.connectors.oracle.OracleSource;
import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
import com.ververica.cdc.debezium.DebeziumSourceFunction;
import com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema;

import java.util.Objects;
import java.util.Properties;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.ConfigOptions;
Expand All @@ -28,16 +28,16 @@
import org.apache.flink.table.factories.FactoryUtil;
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.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
* com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSource}.
* com.ververica.cdc.connectors.oracle.table.OracleTableSource}.
*/
public class OracleTableSourceFactory implements DynamicTableSourceFactory {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* limitations under the License.
*/

package com.alibaba.ververica.cdc.connectors.oracle.table;
package com.ververica.cdc.connectors.oracle.table;

import java.util.Objects;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.

com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory
com.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.KeyedStateStore;
Expand All @@ -35,11 +35,11 @@
import org.apache.flink.util.Collector;
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.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.junit.Before;
import org.junit.Test;
Expand Down Expand Up @@ -67,10 +67,10 @@
import java.util.concurrent.TimeUnit;
import java.util.stream.Stream;

import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertDelete;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertInsert;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertRead;
import static com.alibaba.ververica.cdc.connectors.utils.AssertUtils.assertUpdate;
import static com.ververica.cdc.connectors.utils.AssertUtils.assertDelete;
import static com.ververica.cdc.connectors.utils.AssertUtils.assertInsert;
import static com.ververica.cdc.connectors.utils.AssertUtils.assertRead;
import static com.ververica.cdc.connectors.utils.AssertUtils.assertUpdate;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.table.api.EnvironmentSettings;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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.Configuration;
Expand Down Expand Up @@ -47,8 +47,8 @@
import static org.junit.Assert.fail;

/**
* Test for {@link com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSource} created by
* {@link com.alibaba.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory}.
* Test for {@link com.ververica.cdc.connectors.oracle.table.OracleTableSource} created by {@link
* com.ververica.cdc.connectors.oracle.table.OracleTableSourceFactory}.
*/
public class OracleTableSourceFactoryTest {
private static final ResolvedSchema SCHEMA =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* limitations under the License.
*/

package com.alibaba.ververica.cdc.connectors.oracle.utils;
package com.ververica.cdc.connectors.oracle.utils;

import org.testcontainers.containers.OracleContainer;

Expand Down
4 changes: 2 additions & 2 deletions flink-sql-connector-oracle-cdc/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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">
<parent>
<artifactId>flink-cdc-connectors</artifactId>
<groupId>com.alibaba.ververica</groupId>
<groupId>com.ververica</groupId>
<version>2.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
Expand All @@ -29,7 +29,7 @@ under the License.

<dependencies>
<dependency>
<groupId>com.alibaba.ververica</groupId>
<groupId>com.ververica</groupId>
<artifactId>flink-connector-oracle-cdc</artifactId>
<version>${project.version}</version>
</dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* 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. */
public class DummyDocs {}

0 comments on commit 12ce0f0

Please sign in to comment.