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 <sylv...@datastax.com> Authored: Fri Aug 8 17:50:56 2014 +0200 Committer: Sylvain Lebresne <sylv...@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);