Merge pull request #4 from viveknaskar/develop

Updated the package name

Author: viveknaskar

README.md

@@ -2,15 +2,15 @@
 A custom implementation of HSET for storing data Memorystore in a cloud dataflow project.
 
 ## What does it do here?
-This is a cloud dataflow pipline code that processes data from a cloud storage bucket, transform it and stores in Google's highly scalable, reduced latency in-memory database called memorystore which is an implementation of Redis (5.0 version)
+This is a cloud dataflow pipeline code that processes data from a cloud storage bucket, transform it and stores in Google's highly scalable, reduced latency in-memory database called Memorystore which is an implementation of Redis (5.0 version)
 
 ## What the heck is cloud dataflow?
-Well, its a pipeline provided by Google to process data to a form we need and it just takes seconds to transform bulk of data. Companies like Spotify and Dailymotion uses this service.
+Well, it's a pipeline provided by Google to process data to a form we need and it just takes seconds to transform bulk of data. Companies like Spotify and Dailymotion uses this service.
 
 ## Command to execute the pipeline:
 ```
 mvn compile exec:java \
-  -Dexec.mainClass=com.click.example.StarterPipeline \
+  -Dexec.mainClass=com.viveknaskar.StarterPipeline \
   -Dexec.args="--project=your-project-id \
   --jobName=dataflow-custom-redis-job \
   --redisHost=127.0.0.1 \

pom.xml

@@ -5,9 +5,9 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
-    <groupId>com.click.example</groupId>
+    <groupId>com.viveknaskar</groupId>
     <artifactId>dataflow-redis-example</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.1</version>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/click/example/StarterPipeline.java renamed to src/main/java/com/viveknaskar/StarterPipeline.java

@@ -1,6 +1,6 @@
-package com.click.example;
+package com.viveknaskar;
 
-import com.click.example.functions.*;
+import com.viveknaskar.functions.*;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.io.FileIO;
 import org.apache.beam.sdk.io.TextIO;

src/main/java/com/click/example/StorageToRedisOptions.java renamed to src/main/java/com/viveknaskar/StorageToRedisOptions.java

@@ -1,4 +1,4 @@
-package com.click.example;
+package com.viveknaskar;
 
 import org.apache.beam.sdk.options.Default;
 import org.apache.beam.sdk.options.Description;

src/main/java/com/click/example/constants/KeyPrefix.java renamed to src/main/java/com/viveknaskar/constants/KeyPrefix.java

@@ -1,4 +1,4 @@
-package com.click.example.constants;
+package com.viveknaskar.constants;
 
 /**
  * Enum to store the key prefixes in the Redis instance

src/main/java/com/click/example/constants/PipelineConstants.java renamed to src/main/java/com/viveknaskar/constants/PipelineConstants.java

@@ -1,4 +1,4 @@
-package com.click.example.constants;
+package com.viveknaskar.constants;
 
 public class PipelineConstants {
 

src/main/java/com/click/example/constants/RedisFieldIndex.java renamed to src/main/java/com/viveknaskar/constants/RedisFieldIndex.java

@@ -1,4 +1,4 @@
-package com.click.example.constants;
+package com.viveknaskar.constants;
 
 /**
  * Enum for the Field indexes

src/main/java/com/click/example/functions/CombiningTransforms.java renamed to src/main/java/com/viveknaskar/functions/CombiningTransforms.java

@@ -1,4 +1,4 @@
-package com.click.example.functions;
+package com.viveknaskar.functions;
 
 import org.apache.beam.sdk.transforms.SerializableFunction;
 

src/main/java/com/click/example/functions/FlushingMemorystore.java renamed to src/main/java/com/viveknaskar/functions/FlushingMemorystore.java

@@ -1,4 +1,4 @@
-package com.click.example.functions;
+package com.viveknaskar.functions;
 
 import org.checkerframework.checker.nullness.qual.Nullable;
 import com.google.auto.value.AutoValue;

src/main/java/com/click/example/functions/LogInvalidRecords.java renamed to src/main/java/com/viveknaskar/functions/LogInvalidRecords.java

@@ -1,4 +1,4 @@
-package com.click.example.functions;
+package com.viveknaskar.functions;
 
 import org.apache.beam.sdk.transforms.DoFn;
 import org.slf4j.Logger;