Skip to content

Commit 63ed65a

Browse files
chtyimchtyim
committed
Rename from co.cask to io.cdap
1 parent 76a7da0 commit 63ed65a

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

44 files changed

+380
-390
lines changed

‎kafka-plugins-0.10/pom.xml‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
55
<parent>
66
<artifactId>kafka-plugins</artifactId>
7-
<groupId>co.cask.hydrator</groupId>
7+
<groupId>io.cdap.plugin</groupId>
88
<version>2.1.0-SNAPSHOT</version>
99
</parent>
1010
<modelVersion>4.0.0</modelVersion>
@@ -15,7 +15,7 @@
1515

1616
<dependencies>
1717
<dependency>
18-
<groupId>co.cask.hydrator</groupId>
18+
<groupId>io.cdap.plugin</groupId>
1919
<artifactId>kafka-plugins-common</artifactId>
2020
<version>${project.parent.version}</version>
2121
</dependency>
@@ -116,25 +116,25 @@
116116
</exclusions>
117117
</dependency>
118118
<dependency>
119-
<groupId>co.cask.cdap</groupId>
119+
<groupId>io.cdap.cdap</groupId>
120120
<artifactId>cdap-spark-core2_2.11</artifactId>
121121
<version>${cdap.version}</version>
122122
<scope>test</scope>
123123
</dependency>
124124
<dependency>
125-
<groupId>co.cask.cdap</groupId>
125+
<groupId>io.cdap.cdap</groupId>
126126
<artifactId>cdap-data-pipeline2_2.11</artifactId>
127127
<version>${cdap.version}</version>
128128
<scope>test</scope>
129129
</dependency>
130130
<dependency>
131-
<groupId>co.cask.cdap</groupId>
131+
<groupId>io.cdap.cdap</groupId>
132132
<artifactId>cdap-data-streams2_2.11</artifactId>
133133
<version>${cdap.version}</version>
134134
<scope>test</scope>
135135
</dependency>
136136
<dependency>
137-
<groupId>co.cask.hydrator</groupId>
137+
<groupId>io.cdap.plugin</groupId>
138138
<artifactId>kafka-plugins-common</artifactId>
139139
<version>${project.parent.version}</version>
140140
<type>test-jar</type>
@@ -160,7 +160,7 @@
160160
<version>3.3.0</version>
161161
<configuration>
162162
<instructions>
163-
<_exportcontents>co.cask.hydrator.plugin.*;org.apache.spark.streaming.kafka010.*;
163+
<_exportcontents>io.cdap.plugin.*;org.apache.spark.streaming.kafka010.*;
164164
org.apache.kafka.*;com.google.common.base.*;</_exportcontents>
165165
<Embed-Dependency>*;inline=false;scope=compile</Embed-Dependency>
166166
<Embed-Transitive>true</Embed-Transitive>
@@ -177,9 +177,9 @@
177177
</executions>
178178
</plugin>
179179
<plugin>
180-
<groupId>co.cask</groupId>
180+
<groupId>io.cdap</groupId>
181181
<artifactId>cdap-maven-plugin</artifactId>
182-
<version>1.0.1</version>
182+
<version>1.1.0</version>
183183
<configuration>
184184
<cdapArtifacts>
185185
<parent>system:cdap-data-pipeline[5.1.0,7.0.0-SNAPSHOT)</parent>

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/alertpublisher/KafkaAlertPublisher.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/alertpublisher/KafkaAlertPublisher.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -14,22 +14,22 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.alertpublisher;
18-
19-
import co.cask.cdap.api.annotation.Description;
20-
import co.cask.cdap.api.annotation.Macro;
21-
import co.cask.cdap.api.annotation.Name;
22-
import co.cask.cdap.api.annotation.Plugin;
23-
import co.cask.cdap.api.dataset.lib.KeyValue;
24-
import co.cask.cdap.api.plugin.PluginConfig;
25-
import co.cask.cdap.etl.api.Alert;
26-
import co.cask.cdap.etl.api.AlertPublisher;
27-
import co.cask.cdap.etl.api.AlertPublisherContext;
28-
import co.cask.cdap.etl.api.PipelineConfigurer;
29-
import co.cask.hydrator.common.KeyValueListParser;
30-
import co.cask.hydrator.plugin.common.KafkaHelpers;
17+
package io.cdap.plugin.alertpublisher;
18+
3119
import com.google.common.base.Strings;
3220
import com.google.gson.Gson;
21+
import io.cdap.cdap.api.annotation.Description;
22+
import io.cdap.cdap.api.annotation.Macro;
23+
import io.cdap.cdap.api.annotation.Name;
24+
import io.cdap.cdap.api.annotation.Plugin;
25+
import io.cdap.cdap.api.dataset.lib.KeyValue;
26+
import io.cdap.cdap.api.plugin.PluginConfig;
27+
import io.cdap.cdap.etl.api.Alert;
28+
import io.cdap.cdap.etl.api.AlertPublisher;
29+
import io.cdap.cdap.etl.api.AlertPublisherContext;
30+
import io.cdap.cdap.etl.api.PipelineConfigurer;
31+
import io.cdap.plugin.common.KafkaHelpers;
32+
import io.cdap.plugin.common.KeyValueListParser;
3333
import kafka.common.Topic;
3434
import org.apache.kafka.clients.producer.KafkaProducer;
3535
import org.apache.kafka.clients.producer.ProducerConfig;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/batch/source/Kafka10Reader.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/batch/source/Kafka10Reader.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.batch.source;
17+
package io.cdap.plugin.batch.source;
1818

1919
import com.google.common.collect.Lists;
2020
import org.apache.kafka.clients.consumer.Consumer;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/batch/source/KafkaBatchSource.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/batch/source/KafkaBatchSource.java‎

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -14,31 +14,31 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.batch.source;
18-
19-
import co.cask.cdap.api.annotation.Description;
20-
import co.cask.cdap.api.annotation.Macro;
21-
import co.cask.cdap.api.annotation.Name;
22-
import co.cask.cdap.api.annotation.Plugin;
23-
import co.cask.cdap.api.data.batch.Input;
24-
import co.cask.cdap.api.data.format.FormatSpecification;
25-
import co.cask.cdap.api.data.format.RecordFormat;
26-
import co.cask.cdap.api.data.format.StructuredRecord;
27-
import co.cask.cdap.api.data.schema.Schema;
28-
import co.cask.cdap.api.dataset.lib.KeyValue;
29-
import co.cask.cdap.common.io.ByteBuffers;
30-
import co.cask.cdap.etl.api.Emitter;
31-
import co.cask.cdap.etl.api.PipelineConfigurer;
32-
import co.cask.cdap.etl.api.batch.BatchRuntimeContext;
33-
import co.cask.cdap.etl.api.batch.BatchSource;
34-
import co.cask.cdap.etl.api.batch.BatchSourceContext;
35-
import co.cask.cdap.format.RecordFormats;
36-
import co.cask.hydrator.common.KeyValueListParser;
37-
import co.cask.hydrator.common.LineageRecorder;
38-
import co.cask.hydrator.common.SourceInputFormatProvider;
39-
import co.cask.hydrator.common.batch.JobUtils;
40-
import co.cask.hydrator.plugin.common.KafkaHelpers;
17+
package io.cdap.plugin.batch.source;
18+
4119
import com.google.common.base.Strings;
20+
import io.cdap.cdap.api.annotation.Description;
21+
import io.cdap.cdap.api.annotation.Macro;
22+
import io.cdap.cdap.api.annotation.Name;
23+
import io.cdap.cdap.api.annotation.Plugin;
24+
import io.cdap.cdap.api.data.batch.Input;
25+
import io.cdap.cdap.api.data.format.FormatSpecification;
26+
import io.cdap.cdap.api.data.format.RecordFormat;
27+
import io.cdap.cdap.api.data.format.StructuredRecord;
28+
import io.cdap.cdap.api.data.schema.Schema;
29+
import io.cdap.cdap.api.dataset.lib.KeyValue;
30+
import io.cdap.cdap.common.io.ByteBuffers;
31+
import io.cdap.cdap.etl.api.Emitter;
32+
import io.cdap.cdap.etl.api.PipelineConfigurer;
33+
import io.cdap.cdap.etl.api.batch.BatchRuntimeContext;
34+
import io.cdap.cdap.etl.api.batch.BatchSource;
35+
import io.cdap.cdap.etl.api.batch.BatchSourceContext;
36+
import io.cdap.cdap.format.RecordFormats;
37+
import io.cdap.plugin.common.KafkaHelpers;
38+
import io.cdap.plugin.common.KeyValueListParser;
39+
import io.cdap.plugin.common.LineageRecorder;
40+
import io.cdap.plugin.common.SourceInputFormatProvider;
41+
import io.cdap.plugin.common.batch.JobUtils;
4242
import org.apache.hadoop.conf.Configuration;
4343
import org.apache.hadoop.fs.FileAlreadyExistsException;
4444
import org.apache.hadoop.fs.FileContext;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/batch/source/KafkaInputFormat.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/batch/source/KafkaInputFormat.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,11 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.batch.source;
17+
package io.cdap.plugin.batch.source;
1818

19-
import co.cask.hydrator.plugin.common.KafkaHelpers;
2019
import com.google.gson.Gson;
2120
import com.google.gson.reflect.TypeToken;
21+
import io.cdap.plugin.common.KafkaHelpers;
2222
import org.apache.hadoop.conf.Configuration;
2323
import org.apache.hadoop.mapreduce.InputFormat;
2424
import org.apache.hadoop.mapreduce.InputSplit;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/common/KafkaHelpers.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/common/KafkaHelpers.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.common;
17+
package io.cdap.plugin.common;
1818

1919
import com.google.common.base.Strings;
2020
import org.apache.kafka.clients.consumer.Consumer;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/sink/KafkaBatchSink.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/sink/KafkaBatchSink.java‎

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -14,29 +14,29 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.sink;
18-
19-
import co.cask.cdap.api.annotation.Description;
20-
import co.cask.cdap.api.annotation.Macro;
21-
import co.cask.cdap.api.annotation.Name;
22-
import co.cask.cdap.api.annotation.Plugin;
23-
import co.cask.cdap.api.data.batch.Output;
24-
import co.cask.cdap.api.data.batch.OutputFormatProvider;
25-
import co.cask.cdap.api.data.format.StructuredRecord;
26-
import co.cask.cdap.api.data.schema.Schema;
27-
import co.cask.cdap.api.dataset.lib.KeyValue;
28-
import co.cask.cdap.etl.api.Emitter;
29-
import co.cask.cdap.etl.api.PipelineConfigurer;
30-
import co.cask.cdap.etl.api.batch.BatchSink;
31-
import co.cask.cdap.etl.api.batch.BatchSinkContext;
32-
import co.cask.cdap.format.StructuredRecordStringConverter;
33-
import co.cask.hydrator.common.KeyValueListParser;
34-
import co.cask.hydrator.common.LineageRecorder;
35-
import co.cask.hydrator.common.ReferenceBatchSink;
36-
import co.cask.hydrator.common.ReferencePluginConfig;
37-
import co.cask.hydrator.plugin.common.KafkaHelpers;
17+
package io.cdap.plugin.sink;
18+
3819
import com.google.common.base.Strings;
3920
import com.google.common.collect.Lists;
21+
import io.cdap.cdap.api.annotation.Description;
22+
import io.cdap.cdap.api.annotation.Macro;
23+
import io.cdap.cdap.api.annotation.Name;
24+
import io.cdap.cdap.api.annotation.Plugin;
25+
import io.cdap.cdap.api.data.batch.Output;
26+
import io.cdap.cdap.api.data.batch.OutputFormatProvider;
27+
import io.cdap.cdap.api.data.format.StructuredRecord;
28+
import io.cdap.cdap.api.data.schema.Schema;
29+
import io.cdap.cdap.api.dataset.lib.KeyValue;
30+
import io.cdap.cdap.etl.api.Emitter;
31+
import io.cdap.cdap.etl.api.PipelineConfigurer;
32+
import io.cdap.cdap.etl.api.batch.BatchSink;
33+
import io.cdap.cdap.etl.api.batch.BatchSinkContext;
34+
import io.cdap.cdap.format.StructuredRecordStringConverter;
35+
import io.cdap.plugin.common.KafkaHelpers;
36+
import io.cdap.plugin.common.KeyValueListParser;
37+
import io.cdap.plugin.common.LineageRecorder;
38+
import io.cdap.plugin.common.ReferenceBatchSink;
39+
import io.cdap.plugin.common.ReferencePluginConfig;
4040
import org.apache.commons.lang3.StringUtils;
4141
import org.apache.hadoop.io.Text;
4242
import org.apache.kafka.clients.producer.ProducerConfig;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/sink/KafkaOutputFormat.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/sink/KafkaOutputFormat.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,10 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.sink;
17+
package io.cdap.plugin.sink;
1818

19-
import co.cask.hydrator.plugin.common.KafkaHelpers;
2019
import com.google.common.base.Strings;
20+
import io.cdap.plugin.common.KafkaHelpers;
2121
import org.apache.hadoop.conf.Configuration;
2222
import org.apache.hadoop.io.Text;
2323
import org.apache.hadoop.mapreduce.JobContext;
@@ -97,7 +97,7 @@ public RecordWriter<Text, Text> getRecordWriter(TaskAttemptContext context)
9797

9898
if (!Strings.isNullOrEmpty(configuration.get("hasKey"))) {
9999
// set partitioner class only if key is provided
100-
props.put("partitioner.class", "co.cask.hydrator.plugin.sink.StringPartitioner");
100+
props.put("partitioner.class", "io.cdap.plugin.sink.StringPartitioner");
101101
}
102102

103103
if (configuration.get("async") != null && configuration.get("async").equalsIgnoreCase("true")) {

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/sink/KafkaRecordWriter.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/sink/KafkaRecordWriter.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.sink;
17+
package io.cdap.plugin.sink;
1818

1919
import org.apache.hadoop.io.Text;
2020
import org.apache.hadoop.mapreduce.RecordWriter;

‎kafka-plugins-0.10/src/main/java/co/cask/hydrator/plugin/sink/StringPartitioner.java‎ renamed to ‎kafka-plugins-0.10/src/main/java/io/cdap/plugin/sink/StringPartitioner.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* the License.
1515
*/
1616

17-
package co.cask.hydrator.plugin.sink;
17+
package io.cdap.plugin.sink;
1818

1919
import com.google.common.hash.Hashing;
2020
import org.apache.kafka.clients.producer.Partitioner;

0 commit comments

Comments
 (0)