Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-26 13:16:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

More NumberedShardSpec serde tests

Browse Source
This commit is contained in:
Gian Merlino 2013-08-21 14:45:24 -07:00
parent 9cc7580427
commit 08a95103bd
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
client/src/test/java/com/metamx/druid/shard/NumberedShardSpecTest.java
View File

@ -33,12 +33,26 @@ import java.util.List;
public class NumberedShardSpecTest
{
@Test
public void testSerde() throws Exception
public void testSerdeRoundTrip() throws Exception
{
final ObjectMapper jsonMapper = new DefaultObjectMapper();
final ShardSpec spec = new NumberedShardSpec(1, 2);
final ShardSpec spec2 = jsonMapper.readValue(jsonMapper.writeValueAsBytes(spec), ShardSpec.class);
Assert.assertEquals(1, spec2.getPartitionNum());
final ShardSpec spec = jsonMapper.readValue(
jsonMapper.writeValueAsBytes(new NumberedShardSpec(1, 2)),
ShardSpec.class
);
Assert.assertEquals(1, spec.getPartitionNum());
Assert.assertEquals(2, ((NumberedShardSpec) spec).getPartitions());
}
@Test
public void testSerdeBackwardsCompat() throws Exception
{
final ObjectMapper jsonMapper = new DefaultObjectMapper();
final ShardSpec spec = jsonMapper.readValue(
"{\"type\": \"numbered\", \"partition\": 1, \"partitionNum\": 2}",
ShardSpec.class
);
Assert.assertEquals(1, spec.getPartitionNum());
Assert.assertEquals(2, ((NumberedShardSpec) spec).getPartitions());
}