You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/01/01 04:54:05 UTC
svn commit: r894969 -
/incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
Author: jbellis
Date: Fri Jan 1 03:54:04 2010
New Revision: 894969
URL: http://svn.apache.org/viewvc?rev=894969&view=rev
Log:
fix import in contrib. patch by jbellis
Modified:
incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
Modified: incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java?rev=894969&r1=894968&r2=894969&view=diff
==============================================================================
--- incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java (original)
+++ incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java Fri Jan 1 03:54:04 2010
@@ -57,7 +57,7 @@
import org.apache.cassandra.db.RowMutation;
import org.apache.cassandra.db.filter.QueryPath;
import org.apache.cassandra.dht.BigIntegerToken;
-import org.apache.cassandra.io.DataOutputBuffer;
+import org.apache.cassandra.io.util.DataOutputBuffer;
import java.net.InetAddress;
import java.net.UnknownHostException;
@@ -218,7 +218,7 @@
public static Message createMessage(String Keyspace, String Key, String CFName, List<ColumnFamily> ColumnFamiles)
{
ColumnFamily baseColumnFamily;
- DataOutputBuffer bufOut = new org.apache.cassandra.io.DataOutputBuffer();
+ DataOutputBuffer bufOut = new DataOutputBuffer();
RowMutation rm;
Message message;
Column column;