Fixed Checkstyle and Log4j Properties.

Author: Apex Dev

examples/JDBC/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java

@@ -1,9 +1,29 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   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>
 
-  <artifactId>malhar-examples-JDBC</artifactId>
+  <artifactId>malhar-examples-jdbc</artifactId>
   <packaging>jar</packaging>
 
   <!-- change these to the appropriate values -->

examples/JDBC/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java

@@ -1,3 +1,23 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <assembly xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2 http://maven.apache.org/xsd/assembly-1.1.2.xsd">

examples/JDBC/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java

@@ -16,17 +16,19 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.apex.examples.FileToJdbcApp;
 
+import java.util.regex.Pattern;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.datatorrent.api.Context.OperatorContext;
 import com.datatorrent.api.DefaultInputPort;
 import com.datatorrent.api.DefaultOutputPort;
 import com.datatorrent.api.annotation.OutputPortFieldAnnotation;
 import com.datatorrent.common.util.BaseOperator;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.regex.Pattern;
 
 // parse input line into pojo event
 public class CustomParser extends BaseOperator
@@ -42,12 +44,11 @@ public class CustomParser extends BaseOperator
   @OutputPortFieldAnnotation(optional = false)
   public final transient DefaultOutputPort<PojoEvent> output = new DefaultOutputPort<>();
 
-  public final transient DefaultInputPort<String>
-    input = new DefaultInputPort<String>() {
-
-      @Override
-      public void process(String line)
-      {
+  public final transient DefaultInputPort<String> input = new DefaultInputPort<String>()
+  {
+    @Override
+    public void process(String line)
+    {
       // use custom regex to split line into words
       final String[] words = regexPattern.split(line);
 
@@ -70,14 +71,16 @@ public void process(String line)
         pojo.setAmount(0);
       }
       output.emit(pojo);
-      }
+    }
   };
 
-  public String getRegexStr() {
+  public String getRegexStr()
+  {
     return this.regexStr;
   }
 
-  public void setRegexStr(String regex) {
+  public void setRegexStr(String regex)
+  {
     this.regexStr = regex;
   }
 

examples/JDBC/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java

@@ -0,0 +1,39 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.apex.examples.FileToJdbcApp;
+
+import org.apache.apex.malhar.lib.fs.LineByLineFileInputOperator;
+import com.datatorrent.api.DefaultOutputPort;
+
+public class FileReader extends LineByLineFileInputOperator
+{
+  /**
+   * output in bytes to match CsvParser input type
+   */
+  public final transient DefaultOutputPort<byte[]> byteOutput  = new DefaultOutputPort<>();
+
+  @Override
+  protected void emit(String tuple)
+  {
+    output.emit(tuple);
+    byteOutput.emit(tuple.getBytes());
+  }
+}
+