Merge pull request #21 from treasure-data/log_query

Enabled log query
treasure-data · Jun 2, 2017 · be9afa5 · be9afa5
2 parents 5c0e5a0 + eb2d649
commit be9afa5
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 0.3.5.1 - 2017-06-02
+- Enabled log query for logging on console temporary [#21](https://github.com/treasure-data/embulk-output-mailchimp/pull/21)
+
 ## 0.3.4 - 2017-06-01
 - Enable JSON type for `address` MERGE field [#20](https://github.com/treasure-data/embulk-output-mailchimp/pull/20)
 

diff --git a/build.gradle b/build.gradle
@@ -18,7 +18,7 @@ configurations {
     provided
 }
 
-version = "0.3.4"
+version = "0.3.5.1"
 
 sourceCompatibility = 1.7
 targetCompatibility = 1.7

diff --git a/src/main/java/org/embulk/output/mailchimp/MailChimpAbstractRecordBuffer.java b/src/main/java/org/embulk/output/mailchimp/MailChimpAbstractRecordBuffer.java
@@ -260,6 +260,8 @@ private Function<JsonNode, JsonNode> contactMapper(final Map<String, String> all
             @Override
             public JsonNode apply(JsonNode input)
             {
+                LOG.info(">>>>> Row data <<<<< " + input.toString());
+
                 ObjectNode property = JsonNodeFactory.instance.objectNode();
                 property.put("email_address", input.findPath(task.getEmailColumn()).asText());
                 property.put("status", task.getDoubleOptIn() ? PENDING.getType() : SUBSCRIBED.getType());
@@ -272,6 +274,7 @@ public JsonNode apply(JsonNode input)
                 // Update additional merge fields if exist
                 if (task.getMergeFields().isPresent() && !task.getMergeFields().get().isEmpty()) {
                     for (final Column column : schema.getColumns()) {
+                        LOG.info(">>>>> Column name | Column type <<<<<, {} | {}", column.getName(), column.getType().getName());
                         if (!"".equals(containsCaseInsensitive(column.getName(), task.getMergeFields().get()))) {
                             if (column.getType().equals(JSON)) {
                                 mergeFields.set(column.getName().toUpperCase(), input.findValue(column.getName()));

diff --git a/src/main/java/org/embulk/output/mailchimp/MailChimpRecordBuffer.java b/src/main/java/org/embulk/output/mailchimp/MailChimpRecordBuffer.java
@@ -63,6 +63,7 @@ void cleanUp()
     public ReportResponse push(final ObjectNode node, MailChimpOutputPluginDelegate.PluginTask task)
             throws JsonProcessingException
     {
+        LOG.info(">>>>> Payload data <<<<< " + node.toString());
         String endpoint = MessageFormat.format(mailchimpEndpoint + "/lists/{0}",
                                                task.getListId());