fixing volt column selection

lensesio · Sep 12, 2016 · 2f0bd3b · 2f0bd3b
1 parent ebb8133
commit 2f0bd3b
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -165,6 +165,8 @@ allprojects {
 
     task compile(dependsOn: 'compileScala')
 
+    task fatJar(dependsOn: [test, shadowJar])
+
     task collectJars(type: Copy){
         into "${buildDir}/libs-dependencies"
         from configurations.runtime

diff --git a/...n/scala/com/datamountaineer/streamreactor/connect/rethink/sink/ReThinkSinkConverter.scala b/...n/scala/com/datamountaineer/streamreactor/connect/rethink/sink/ReThinkSinkConverter.scala
@@ -134,8 +134,8 @@ object ReThinkSinkConverter extends StrictLogging {
         fields.map(f => buildField(rethink, f, nested, mo))
         hm.`with`(field.name, mo)
       case Type.BYTES => {
-        logger.warn(s"Discarding binary field ${field.name()}")
-        hm
+        val str = new String(struct.getBytes(field.name()), "utf-8")
+        hm.`with`(field.name(), str)
       }
       case _ => hm.`with`(field.name(), struct.get(field.name()))
     }

diff --git a/...scala/com/datamountaineer/streamreactor/connect/voltdb/writers/VoltDbMetadataReader.scala b/...scala/com/datamountaineer/streamreactor/connect/voltdb/writers/VoltDbMetadataReader.scala
@@ -36,7 +36,8 @@ object VoltDbMetadataReader extends StrictLogging {
           val row = vt.fetchRow(i)
           (row.getString("TABLE_NAME") ->
             (row.getString("COLUMN_NAME") -> row.get("ORDINAL_POSITION", VoltType.INTEGER).asInstanceOf[Int]))
-        })
+        }).filter( {case (k,v) => k.equals(tableName)})
+
       }.flatMap( t => t.map(s => s._2))
         .sortBy(_._2)
         .map(_._1)