Skip to content

Commit

Permalink
cursors are long, not int. i did a git blame on this and it's been br…
Browse files Browse the repository at this point in the history
…oken since basically the beginning of time.
  • Loading branch information
Robey Pointer committed Nov 17, 2010
1 parent d18069f commit 0f6d79f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/main/scala/com/twitter/flockdb/jobs/Copy.scala
Expand Up @@ -42,8 +42,8 @@ class CopyFactory(nameServer: NameServer[Shard], scheduler: JobScheduler[JsonJob
class CopyParser(nameServer: NameServer[Shard], scheduler: JobScheduler[JsonJob])
extends CopyJobParser[Shard] {
def deserialize(attributes: Map[String, Any], sourceId: ShardId, destinationId: ShardId, count: Int) = {
val cursor = (Cursor(attributes("cursor1").asInstanceOf[AnyVal].toInt),
Cursor(attributes("cursor2").asInstanceOf[AnyVal].toInt))
val cursor = (Cursor(attributes("cursor1").asInstanceOf[AnyVal].toLong),
Cursor(attributes("cursor2").asInstanceOf[AnyVal].toLong))
new Copy(sourceId, destinationId, cursor, count, nameServer, scheduler)
}
}
Expand Down Expand Up @@ -74,7 +74,7 @@ object MetadataCopy {
class MetadataCopyParser(nameServer: NameServer[Shard], scheduler: JobScheduler[JsonJob])
extends CopyJobParser[Shard] {
def deserialize(attributes: Map[String, Any], sourceId: ShardId, destinationId: ShardId, count: Int) = {
val cursor = Cursor(attributes("cursor").asInstanceOf[AnyVal].toInt)
val cursor = Cursor(attributes("cursor").asInstanceOf[AnyVal].toLong)
new MetadataCopy(sourceId, destinationId, cursor, count, nameServer, scheduler)
}
}
Expand Down

0 comments on commit 0f6d79f

Please sign in to comment.