other naming thing, unnecessary type annotation

twitter-archive · Feb 17, 2011 · 6e6975f · 6e6975f
1 parent ab4bfb7
commit 6e6975f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/main/scala/com/twitter/flockdb/FlockDB.scala b/src/main/scala/com/twitter/flockdb/FlockDB.scala
@@ -108,9 +108,9 @@ class FlockDB(config: FlockDBConfig, w3c: W3CStats) extends GizzardServer[shards
   }
 
   lazy val flockThriftServer = {
-    val processor = new flockdb.thrift.FlockDB.Processor(
+    val processor = new thrift.FlockDB.Processor(
       FlockExceptionWrappingProxyFactory(
-        LoggingProxy[flockdb.thrift.FlockDB.Iface](
+        LoggingProxy[thrift.FlockDB.Iface](
           Stats, w3c, "FlockDB",
           flockService)))
 

diff --git a/src/main/scala/com/twitter/flockdb/jobs/Repair.scala b/src/main/scala/com/twitter/flockdb/jobs/Repair.scala
@@ -98,7 +98,7 @@ class Repair(shardIds: Seq[ShardId], cursor: Repair.RepairCursor, count: Int,
 
 
   def repair(shards: Seq[Shard]) = {
-    val tableIds = shards.map((shard:Shard) => nameServer.getRootForwardings(shard.shardInfo.id).toSeq(0).tableId)
+    val tableIds = shards.map(shard => nameServer.getRootForwardings(shard.shardInfo.id).head.tableId)
 
     val listCursors = shards.map( (shard) => {
       val (seq, newCursor) = shard.selectAll(cursor, count)
@@ -181,7 +181,7 @@ class MetadataRepair(shardIds: Seq[ShardId], cursor: MetadataRepair.RepairCursor
   }
 
   def repair(shards: Seq[Shard]) = {
-    val tableIds = shards.map((shard:Shard) => nameServer.getRootForwardings(shard.shardInfo.id).toSeq(0).tableId)
+    val tableIds = shards.map(shard => nameServer.getRootForwardings(shard.shardInfo.id).head.tableId)
 
     val listCursors = shards.map( (shard) => {
       val (seq, newCursor) = shard.selectAllMetadata(cursor, count)