Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id AC391200CC4 for ; Wed, 7 Jun 2017 20:56:07 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AAD44160BE9; Wed, 7 Jun 2017 18:56:07 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D9645160BBF for ; Wed, 7 Jun 2017 20:56:05 +0200 (CEST) Received: (qmail 25334 invoked by uid 500); 7 Jun 2017 18:56:03 -0000 Mailing-List: contact commits-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list commits@apex.apache.org Received: (qmail 25317 invoked by uid 99); 7 Jun 2017 18:56:03 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Jun 2017 18:56:03 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 5E03CDFBC6; Wed, 7 Jun 2017 18:56:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: thw@apache.org To: commits@apex.apache.org Date: Wed, 07 Jun 2017 18:56:03 -0000 Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: [1/6] apex-malhar git commit: APEXMALHAR-2462 Fixed Checkstyle and Log4j Properties. archived-at: Wed, 07 Jun 2017 18:56:07 -0000 Repository: apex-malhar Updated Branches: refs/heads/master 07869c829 -> fc234b1df APEXMALHAR-2462 Fixed Checkstyle and Log4j Properties. Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/fc234b1d Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/fc234b1d Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/fc234b1d Branch: refs/heads/master Commit: fc234b1df959e96e1ca97ee98d364d39c87bfaaa Parents: 9b99e0a Author: Apex Dev Authored: Tue Apr 18 13:40:22 2017 -0700 Committer: Lakshmi Prasanna Velineni Committed: Wed Jun 7 10:33:00 2017 -0700 ---------------------------------------------------------------------- examples/jdbc/pom.xml | 20 +++++++++ examples/jdbc/src/assemble/appPackage.xml | 20 +++++++++ .../examples/FileToJdbcApp/CustomParser.java | 26 ++++++------ .../apex/examples/FileToJdbcApp/FileReader.java | 23 +++++++++- .../FileToJdbcApp/FileToJdbcCsvParser.java | 30 ++++++++++--- .../FileToJdbcApp/FileToJdbcCustomParser.java | 37 ++++++++++++---- .../apex/examples/FileToJdbcApp/PojoEvent.java | 18 ++++++++ .../JdbcIngest/JdbcPollerApplication.java | 18 ++++++++ .../apex/examples/JdbcIngest/PojoEvent.java | 18 ++++++++ .../apex/examples/JdbcToJdbc/JdbcToJdbcApp.java | 2 +- .../apex/examples/JdbcToJdbc/PojoEvent.java | 18 ++++++++ .../META-INF/properties-FileToJdbcApp.xml | 20 +++++++++ .../META-INF/properties-JdbcToJdbcApp.xml | 20 +++++++++ .../META-INF/properties-PollJdbcToHDFSApp.xml | 20 +++++++++ .../META-INF/properties-SimpleJdbcToHDFSApp.xml | 20 +++++++++ .../examples/FileToJdbcApp/ApplicationTest.java | 44 +++++++++++++++----- .../examples/JdbcIngest/JdbcInputAppTest.java | 4 +- .../JdbcIngest/JdbcPollerApplicationTest.java | 22 +++++++++- .../examples/JdbcToJdbc/ApplicationTest.java | 17 +++++++- .../examples/JdbcToJdbc/JdbcOperatorTest.java | 7 ++-- .../resources/example-FileToJdbcApp-sql.txt | 8 ++++ .../test/resources/example-FileToJdbcApp.sql | 8 ---- .../test/resources/example-JdbcIngest-sql.txt | 24 +++++++++++ .../src/test/resources/example-JdbcIngest.sql | 24 ----------- .../test/resources/example-JdbcToJdbc-sql.txt | 36 ++++++++++++++++ .../src/test/resources/example-JdbcToJdbc.sql | 36 ---------------- .../jdbc/src/test/resources/log4j.properties | 21 ++++++++++ .../src/test/resources/test-FileToJdbcApp.xml | 20 +++++++++ 28 files changed, 464 insertions(+), 117 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/pom.xml b/examples/jdbc/pom.xml index b697a68..b01028a 100644 --- a/examples/jdbc/pom.xml +++ b/examples/jdbc/pom.xml @@ -1,4 +1,24 @@ + 4.0.0 http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/assemble/appPackage.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/assemble/appPackage.xml b/examples/jdbc/src/assemble/appPackage.xml index 7ad071c..a870807 100644 --- a/examples/jdbc/src/assemble/appPackage.xml +++ b/examples/jdbc/src/assemble/appPackage.xml @@ -1,3 +1,23 @@ + http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/CustomParser.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/CustomParser.java b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/CustomParser.java index a22acc9..d5fc509 100755 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/CustomParser.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/CustomParser.java @@ -18,15 +18,14 @@ */ 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 +41,11 @@ public class CustomParser extends BaseOperator @OutputPortFieldAnnotation(optional = false) public final transient DefaultOutputPort output = new DefaultOutputPort<>(); - public final transient DefaultInputPort - input = new DefaultInputPort() { - - @Override - public void process(String line) - { + public final transient DefaultInputPort input = new DefaultInputPort() + { + @Override + public void process(String line) + { // use custom regex to split line into words final String[] words = regexPattern.split(line); @@ -70,14 +68,16 @@ public class CustomParser extends BaseOperator 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; } http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java index 4065a5f..89515f7 100755 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileReader.java @@ -1,10 +1,29 @@ +/** + * 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 com.datatorrent.api.DefaultOutputPort; import org.apache.apex.malhar.lib.fs.LineByLineFileInputOperator; -public class FileReader extends LineByLineFileInputOperator{ +import com.datatorrent.api.DefaultOutputPort; +public class FileReader extends LineByLineFileInputOperator +{ /** * output in bytes to match CsvParser input type */ http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCsvParser.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCsvParser.java b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCsvParser.java index d60b275..be1db6b 100755 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCsvParser.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCsvParser.java @@ -1,3 +1,21 @@ +/** + * 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 java.util.List; @@ -19,10 +37,11 @@ import static java.sql.Types.INTEGER; import static java.sql.Types.VARCHAR; @ApplicationAnnotation(name = "FileToJdbcCsvParser") -public class FileToJdbcCsvParser implements StreamingApplication{ - +public class FileToJdbcCsvParser implements StreamingApplication +{ @Override - public void populateDAG(DAG dag, Configuration configuration) { + public void populateDAG(DAG dag, Configuration configuration) + { // create operators FileReader fileReader = dag.addOperator("FileReader", FileReader.class); CsvParser csvParser = dag.addOperator("CsvParser", CsvParser.class); @@ -45,9 +64,10 @@ public class FileToJdbcCsvParser implements StreamingApplication{ * This method can be modified to have field mappings based on used defined * class */ - private List addFieldInfos() { + private List addFieldInfos() + { List fieldInfos = Lists.newArrayList(); - fieldInfos.add(new JdbcFieldInfo("ACCOUNT_NO", "accountNumber", JdbcFieldInfo.SupportType.INTEGER , INTEGER)); + fieldInfos.add(new JdbcFieldInfo("ACCOUNT_NO", "accountNumber", JdbcFieldInfo.SupportType.INTEGER, INTEGER)); fieldInfos.add(new JdbcFieldInfo("NAME", "name", JdbcFieldInfo.SupportType.STRING, VARCHAR)); fieldInfos.add(new JdbcFieldInfo("AMOUNT", "amount", JdbcFieldInfo.SupportType.INTEGER, INTEGER)); return fieldInfos; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCustomParser.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCustomParser.java b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCustomParser.java index 42d1d23..037ca51 100755 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCustomParser.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/FileToJdbcCustomParser.java @@ -1,24 +1,45 @@ +/** + * 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 java.util.List; + +import org.apache.hadoop.conf.Configuration; + +import com.google.common.collect.Lists; + import com.datatorrent.api.DAG; import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; import com.datatorrent.lib.db.jdbc.JdbcFieldInfo; import com.datatorrent.lib.db.jdbc.JdbcPOJOInsertOutputOperator; import com.datatorrent.lib.db.jdbc.JdbcTransactionalStore; -import com.google.common.collect.Lists; -import org.apache.hadoop.conf.Configuration; - -import java.util.List; import static java.sql.Types.INTEGER; import static java.sql.Types.VARCHAR; @ApplicationAnnotation(name = "FileToJdbcCustomParser") -public class FileToJdbcCustomParser implements StreamingApplication{ - +public class FileToJdbcCustomParser implements StreamingApplication +{ @Override - public void populateDAG(DAG dag, Configuration configuration) { + public void populateDAG(DAG dag, Configuration configuration) + { // create operators FileReader fileReader = dag.addOperator("FileReader", FileReader.class); CustomParser customParser = dag.addOperator("CustomParser", CustomParser.class); @@ -41,7 +62,7 @@ public class FileToJdbcCustomParser implements StreamingApplication{ private List addFieldInfos() { List fieldInfos = Lists.newArrayList(); - fieldInfos.add(new JdbcFieldInfo("ACCOUNT_NO", "accountNumber", JdbcFieldInfo.SupportType.INTEGER , INTEGER)); + fieldInfos.add(new JdbcFieldInfo("ACCOUNT_NO", "accountNumber", JdbcFieldInfo.SupportType.INTEGER, INTEGER)); fieldInfos.add(new JdbcFieldInfo("NAME", "name", JdbcFieldInfo.SupportType.STRING, VARCHAR)); fieldInfos.add(new JdbcFieldInfo("AMOUNT", "amount", JdbcFieldInfo.SupportType.INTEGER, INTEGER)); return fieldInfos; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java index 6de9274..2ce2d9f 100755 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/FileToJdbcApp/PojoEvent.java @@ -1,3 +1,21 @@ +/** + * 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; public class PojoEvent http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/JdbcPollerApplication.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/JdbcPollerApplication.java b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/JdbcPollerApplication.java index de47ef4..4f351ef 100644 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/JdbcPollerApplication.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/JdbcPollerApplication.java @@ -1,3 +1,21 @@ +/** + * 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.JdbcIngest; import java.util.List; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java index be366b6..5a66464 100644 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcIngest/PojoEvent.java @@ -1,3 +1,21 @@ +/** + * 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.JdbcIngest; public class PojoEvent http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/JdbcToJdbcApp.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/JdbcToJdbcApp.java b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/JdbcToJdbcApp.java index e85e4af..53a41ea 100644 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/JdbcToJdbcApp.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/JdbcToJdbcApp.java @@ -84,7 +84,7 @@ public class JdbcToJdbcApp implements StreamingApplication fieldInfos.add(new com.datatorrent.lib.db.jdbc.JdbcFieldInfo("AMOUNT", "amount", SupportType.INTEGER,0)); return fieldInfos; } - + /** * This method can be modified to have field mappings based on used defined * class http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java index 0abf74d..f40d930 100644 --- a/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java +++ b/examples/jdbc/src/main/java/org/apache/apex/examples/JdbcToJdbc/PojoEvent.java @@ -1,3 +1,21 @@ +/** + * 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.JdbcToJdbc; public class PojoEvent http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/resources/META-INF/properties-FileToJdbcApp.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/resources/META-INF/properties-FileToJdbcApp.xml b/examples/jdbc/src/main/resources/META-INF/properties-FileToJdbcApp.xml index 29b911b..53374fc 100755 --- a/examples/jdbc/src/main/resources/META-INF/properties-FileToJdbcApp.xml +++ b/examples/jdbc/src/main/resources/META-INF/properties-FileToJdbcApp.xml @@ -1,4 +1,24 @@ + dt.operator.JdbcOutput.prop.store.databaseDriver http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/resources/META-INF/properties-JdbcToJdbcApp.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/resources/META-INF/properties-JdbcToJdbcApp.xml b/examples/jdbc/src/main/resources/META-INF/properties-JdbcToJdbcApp.xml index d9199c6..b32f8cc 100644 --- a/examples/jdbc/src/main/resources/META-INF/properties-JdbcToJdbcApp.xml +++ b/examples/jdbc/src/main/resources/META-INF/properties-JdbcToJdbcApp.xml @@ -1,4 +1,24 @@ + http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/fc234b1d/examples/jdbc/src/main/resources/META-INF/properties-SimpleJdbcToHDFSApp.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/src/main/resources/META-INF/properties-SimpleJdbcToHDFSApp.xml b/examples/jdbc/src/main/resources/META-INF/properties-SimpleJdbcToHDFSApp.xml index 589dbcd..a57dcf7 100644 --- a/examples/jdbc/src/main/resources/META-INF/properties-SimpleJdbcToHDFSApp.xml +++ b/examples/jdbc/src/main/resources/META-INF/properties-SimpleJdbcToHDFSApp.xml @@ -1,4 +1,24 @@ + dt.operator.JdbcOutput.prop.store.databaseDriver