Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Using string formatter in log statements. 

Clean up of imports on the pusher.
This commit is contained in:
Brian O'Neill 2013-05-17 12:54:03 -04:00
parent 61c014c49f
commit c8ff5ca2fb
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/main/java/com/metamx/druid/loading/cassandra/CassandraDataSegmentPuller.java
View File

@ -76,7 +76,7 @@ public class CassandraDataSegmentPuller extends CassandraStorage implements Data
{ {
try try
{ {
log.info("Writing to [" + outFile.getAbsolutePath() + "]"); log.info("Writing to [%s]", outFile.getAbsolutePath());
OutputStream os = Files.newOutputStreamSupplier(outFile).getOutput(); OutputStream os = Files.newOutputStreamSupplier(outFile).getOutput();
meta = ChunkedStorage meta = ChunkedStorage
.newReader(indexStorage, key, os) .newReader(indexStorage, key, os)
@ -109,7 +109,7 @@ public class CassandraDataSegmentPuller extends CassandraStorage implements Data
.execute(); .execute();
ColumnList<String> children = result.getResult(); ColumnList<String> children = result.getResult();
long lastModified = children.getColumnByName("lastmodified").getLongValue(); long lastModified = children.getColumnByName("lastmodified").getLongValue();
log.info("Read lastModified for [" + key + "] as [" + lastModified + "]"); log.info("Read lastModified for [%s] as [%d]", key, lastModified);
return lastModified; return lastModified;
} catch (ConnectionException e) } catch (ConnectionException e)
{ {

3
server/src/main/java/com/metamx/druid/loading/cassandra/CassandraDataSegmentPusher.java
View File

@ -13,11 +13,8 @@ import com.metamx.druid.index.v1.IndexIO;
import com.metamx.druid.loading.DataSegmentPusher; import com.metamx.druid.loading.DataSegmentPusher;
import com.metamx.druid.loading.DataSegmentPusherUtil; import com.metamx.druid.loading.DataSegmentPusherUtil;
import com.metamx.druid.utils.CompressionUtils; import com.metamx.druid.utils.CompressionUtils;
import com.netflix.astyanax.Keyspace;
import com.netflix.astyanax.MutationBatch; import com.netflix.astyanax.MutationBatch;
import com.netflix.astyanax.model.ColumnFamily;
import com.netflix.astyanax.recipes.storage.ChunkedStorage; import com.netflix.astyanax.recipes.storage.ChunkedStorage;
import com.netflix.astyanax.recipes.storage.ChunkedStorageProvider;
/** /**
* Cassandra Segment Pusher * Cassandra Segment Pusher