From e97738fb0dcd224cc19641786f8a52877063382e Mon Sep 17 00:00:00 2001 From: Pablo Lalloni Date: Fri, 4 Mar 2011 11:41:26 -0300 Subject: [PATCH] Remove implicit conversions of BigDecimals and BigIntegers to doubles and longs --- src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java b/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java index 2fb6748..87b141c 100644 --- a/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java +++ b/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java @@ -8,8 +8,6 @@ import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import java.math.BigDecimal; -import java.math.BigInteger; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; @@ -119,7 +117,7 @@ public long getPos() throws IOException { /** {@inheritDoc} */ @Override public float getProgress() throws IOException { - return (pos / (float) split.getLength()); + return pos / (float) split.getLength(); } /** {@inheritDoc} */ @@ -137,10 +135,6 @@ public boolean next(LongWritable key, TupleWrapper value) throws IOException { Object o = results.getObject(i+1); if(o instanceof byte[]) { o = new BytesWritable((byte[]) o); - } else if(o instanceof BigInteger) { - o = ((BigInteger) o).longValue(); - } else if (o instanceof BigDecimal) { - o = ((BigDecimal) o).doubleValue(); } try { value.tuple.add(o);