You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2014/08/11 00:07:53 UTC
[08/17] git commit: Fix build
Fix build
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d93b8519
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d93b8519
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d93b8519
Branch: refs/heads/cassandra-2.1
Commit: d93b8519100076321228935b853829ac78df44ac
Parents: 2af8c9d
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Fri Aug 8 17:50:56 2014 +0200
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Fri Aug 8 17:50:56 2014 +0200
----------------------------------------------------------------------
src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d93b8519/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
index 6f17468..3b7b0df 100644
--- a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
+++ b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
@@ -58,11 +58,11 @@ public class CqlStorage extends AbstractCassandraStorage
{
private static final Logger logger = LoggerFactory.getLogger(CqlStorage.class);
private RecordReader<Map<String, ByteBuffer>, Map<String, ByteBuffer>> reader;
- private RecordWriter<Map<String, ByteBuffer>, List<ByteBuffer>> writer;
+ protected RecordWriter<Map<String, ByteBuffer>, List<ByteBuffer>> writer;
- private int pageSize = 1000;
+ protected int pageSize = 1000;
private String columns;
- private String outputQuery;
+ protected String outputQuery;
private String whereClause;
private boolean hasCompactValueAlias = false;
@@ -130,7 +130,7 @@ public class CqlStorage extends AbstractCassandraStorage
}
/** set the value to the position of the tuple */
- private void setTupleValue(Tuple tuple, int position, Object value, AbstractType<?> validator) throws ExecException
+ protected void setTupleValue(Tuple tuple, int position, Object value, AbstractType<?> validator) throws ExecException
{
if (validator instanceof CollectionType)
setCollectionTupleValues(tuple, position, value, validator);
@@ -184,7 +184,7 @@ public class CqlStorage extends AbstractCassandraStorage
}
/** convert a cql column to an object */
- private Object cqlColumnToObj(Cell col, CfDef cfDef) throws IOException
+ protected Object cqlColumnToObj(Cell col, CfDef cfDef) throws IOException
{
// standard
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);