You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/11/14 12:52:12 UTC
[5/8] storm git commit: [STORM-2177][SQL] add input output prefix
[STORM-2177][SQL] add input output prefix
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/424f65b4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/424f65b4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/424f65b4
Branch: refs/heads/master
Commit: 424f65b484ff0de8c9ff79859f0d7997e8310248
Parents: 7c1aff5
Author: Xin Wang <be...@163.com>
Authored: Mon Nov 14 13:04:22 2016 +0800
Committer: GitHub <no...@github.com>
Committed: Mon Nov 14 13:04:22 2016 +0800
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/424f65b4/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
----------------------------------------------------------------------
diff --git a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
index 0f46649..6b3dfc9 100644
--- a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
+++ b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
@@ -47,7 +47,7 @@ public final class SerdeUtils {
if (JsonScheme.class.getName().equals(inputFormatClass)) {
scheme = new JsonScheme(fieldNames);
} else if (TsvScheme.class.getName().equals(inputFormatClass)) {
- String delimiter = properties.getProperty("tsv.delimiter", "\t");
+ String delimiter = properties.getProperty("input.tsv.delimiter", "\t");
scheme = new TsvScheme(fieldNames, delimiter.charAt(0));
} else if (CsvScheme.class.getName().equals(inputFormatClass)) {
scheme = new CsvScheme(fieldNames);
@@ -71,7 +71,7 @@ public final class SerdeUtils {
if (JsonSerializer.class.getName().equals(outputFormatClass)) {
serializer = new JsonSerializer(fieldNames);
} else if (TsvSerializer.class.getName().equals(outputFormatClass)) {
- String delimiter = properties.getProperty("tsv.delimiter", "\t");
+ String delimiter = properties.getProperty("output.tsv.delimiter", "\t");
serializer = new TsvSerializer(fieldNames, delimiter.charAt(0));
} else if (CsvSerializer.class.getName().equals(outputFormatClass)) {
serializer = new CsvSerializer(fieldNames);