You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by be...@apache.org on 2015/11/02 20:46:44 UTC
[2/3] cassandra git commit: comment out NativeCellTest,
since we don't support it in 3.0
comment out NativeCellTest, since we don't support it in 3.0
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/fd59549a
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/fd59549a
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/fd59549a
Branch: refs/heads/trunk
Commit: fd59549a39542386e681524b8760a8533d9c227d
Parents: 79f230f
Author: Benedict Elliott Smith <be...@apache.org>
Authored: Mon Nov 2 19:46:19 2015 +0000
Committer: Benedict Elliott Smith <be...@apache.org>
Committed: Mon Nov 2 19:46:19 2015 +0000
----------------------------------------------------------------------
.../org/apache/cassandra/db/NativeCellTest.java | 551 +++++++++----------
1 file changed, 271 insertions(+), 280 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/fd59549a/test/unit/org/apache/cassandra/db/NativeCellTest.java
----------------------------------------------------------------------
diff --git a/test/unit/org/apache/cassandra/db/NativeCellTest.java b/test/unit/org/apache/cassandra/db/NativeCellTest.java
index 70b7b87..b804412 100644
--- a/test/unit/org/apache/cassandra/db/NativeCellTest.java
+++ b/test/unit/org/apache/cassandra/db/NativeCellTest.java
@@ -1,280 +1,271 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.cassandra.db;
-
-import java.io.ByteArrayInputStream;
-import java.io.DataInputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-import java.util.Arrays;
-import java.util.Random;
-import java.util.concurrent.ThreadLocalRandom;
-
-import org.junit.Assert;
-import org.junit.Test;
-
-import org.apache.cassandra.config.CFMetaData;
-import org.apache.cassandra.config.ColumnDefinition;
-import org.apache.cassandra.cql3.ColumnIdentifier;
-import org.apache.cassandra.db.composites.CellName;
-import org.apache.cassandra.db.composites.CellNameType;
-import org.apache.cassandra.db.composites.CompoundDenseCellNameType;
-import org.apache.cassandra.db.composites.CompoundSparseCellNameType;
-import org.apache.cassandra.db.composites.SimpleDenseCellNameType;
-import org.apache.cassandra.db.composites.SimpleSparseCellNameType;
-import org.apache.cassandra.db.context.CounterContext;
-import org.apache.cassandra.db.marshal.AbstractType;
-import org.apache.cassandra.db.marshal.UTF8Type;
-import org.apache.cassandra.exceptions.ConfigurationException;
-import org.apache.cassandra.io.util.DataOutputBuffer;
-import org.apache.cassandra.utils.concurrent.OpOrder;
-import org.apache.cassandra.utils.memory.NativeAllocator;
-import org.apache.cassandra.utils.memory.NativePool;
-
-import static org.apache.cassandra.db.composites.CellNames.compositeDense;
-import static org.apache.cassandra.db.composites.CellNames.compositeSparse;
-import static org.apache.cassandra.db.composites.CellNames.simpleDense;
-import static org.apache.cassandra.db.composites.CellNames.simpleSparse;
-import static org.apache.cassandra.utils.ByteBufferUtil.bytes;
-
-public class NativeCellTest
-{
-
- private static final NativeAllocator nativeAllocator = new NativePool(Integer.MAX_VALUE, Integer.MAX_VALUE, 1f, null).newAllocator();
- private static final OpOrder.Group group = new OpOrder().start();
-
- static class Name
- {
- final CellName name;
- final CellNameType type;
- Name(CellName name, CellNameType type)
- {
- this.name = name;
- this.type = type;
- }
- }
-
- static ByteBuffer[] bytess(String ... strings)
- {
- ByteBuffer[] r = new ByteBuffer[strings.length];
- for (int i = 0 ; i < r.length ; i++)
- r[i] = bytes(strings[i]);
- return r;
- }
-
- final static Name[] TESTS = new Name[]
- {
- new Name(simpleDense(bytes("a")), new SimpleDenseCellNameType(UTF8Type.instance)),
- new Name(simpleSparse(new ColumnIdentifier("a", true)), new SimpleSparseCellNameType(UTF8Type.instance)),
- new Name(compositeDense(bytes("a"), bytes("b")), new CompoundDenseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
- new Name(compositeSparse(bytess("b", "c"), new ColumnIdentifier("a", true), false), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
- new Name(compositeSparse(bytess("b", "c"), new ColumnIdentifier("a", true), true), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
- new Name(simpleDense(huge('a', 40000)), new SimpleDenseCellNameType(UTF8Type.instance)),
- new Name(simpleSparse(new ColumnIdentifier(hugestr('a', 40000), true)), new SimpleSparseCellNameType(UTF8Type.instance)),
- new Name(compositeDense(huge('a', 20000), huge('b', 20000)), new CompoundDenseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
- new Name(compositeSparse(huges(40000, 'b', 'c'), new ColumnIdentifier(hugestr('a', 10000), true), false), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
- new Name(compositeSparse(huges(40000, 'b', 'c'), new ColumnIdentifier(hugestr('a', 10000), true), true), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance)))
- };
-
- private static ByteBuffer huge(char ch, int count)
- {
- return bytes(hugestr(ch, count));
- }
-
- private static ByteBuffer[] huges(int count, char ... chs)
- {
- ByteBuffer[] r = new ByteBuffer[chs.length];
- for (int i = 0 ; i < chs.length ; i++)
- r[i] = huge(chs[i], count / chs.length);
- return r;
- }
-
- private static String hugestr(char ch, int count)
- {
- ThreadLocalRandom random = ThreadLocalRandom.current();
- byte[] bytes = new byte[count];
- random.nextBytes(bytes);
- bytes[0] = (byte) ch;
- for (int i = 0 ; i < bytes.length ; i++)
- bytes[i] &= 0x7f;
- return new String(bytes);
- }
-
- private static final CFMetaData metadata = new CFMetaData("", "", ColumnFamilyType.Standard, null);
- static
- {
- try
- {
- metadata.addColumnDefinition(new ColumnDefinition(null, null, new ColumnIdentifier("a", true), UTF8Type.instance, null, null, null, null, null));
- }
- catch (ConfigurationException e)
- {
- throw new AssertionError();
- }
- }
-
- @Test
- public void testCells() throws IOException
- {
- Random rand = ThreadLocalRandom.current();
- for (Name test : TESTS)
- {
- byte[] bytes = new byte[16];
- rand.nextBytes(bytes);
-
- // test regular Cell
- Cell buf, nat;
- buf = new BufferCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong());
- nat = buf.localCopy(metadata, nativeAllocator, group);
- test(test, buf, nat);
-
- // test DeletedCell
- buf = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
- nat = buf.localCopy(metadata, nativeAllocator, group);
- test(test, buf, nat);
-
- // test ExpiringCell
- buf = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong(), rand.nextInt(100000));
- nat = buf.localCopy(metadata, nativeAllocator, group);
- test(test, buf, nat);
-
- // test CounterCell
- buf = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
- nat = buf.localCopy(metadata, nativeAllocator, group);
- test(test, buf, nat);
- }
- }
-
-
- @Test
- public void testComparator()
- {
-
- Random rand = ThreadLocalRandom.current();
- for (Name test : TESTS)
- {
- byte[] bytes = new byte[7];
- byte[] bytes2 = new byte[7];
- rand.nextBytes(bytes);
- rand.nextBytes(bytes2);
-
- // test regular Cell
- Cell buf, nat, buf2, nat2;
- buf = new BufferCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong());
- nat = buf.localCopy(metadata, nativeAllocator, group);
-
- buf2 = new BufferCell(test.name, ByteBuffer.wrap(bytes2), rand.nextLong());
- nat2 = buf2.localCopy(metadata, nativeAllocator, group);
-
- assert test.type.compare(buf.name(), nat.name()) == 0;
- assert test.type.compare(buf2.name(), nat2.name()) == 0;
-
- int val = test.type.compare(buf.name(), buf2.name());
- assert test.type.compare(nat.name(), nat2.name()) == val;
- assert test.type.compare(nat.name(), buf2.name()) == val;
- assert test.type.compare(buf.name(), nat2.name()) == val;
-
-
- // test DeletedCell
- buf = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
- nat = buf.localCopy(metadata, nativeAllocator, group);
- buf2 = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
- nat2 = buf2.localCopy(metadata, nativeAllocator, group);
-
- assert test.type.compare(buf.name(), nat.name()) == 0;
- assert test.type.compare(buf2.name(), nat2.name()) == 0;
-
- val = test.type.compare(buf.name(), buf2.name());
- assert test.type.compare(nat.name(), nat2.name()) == val;
- assert test.type.compare(nat.name(), buf2.name()) == val;
- assert test.type.compare(buf.name(), nat2.name()) == val;
-
-
-
- // test ExpiringCell
- buf = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong(), rand.nextInt(100000));
- nat = buf.localCopy(metadata, nativeAllocator, group);
-
- buf2 = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes2), rand.nextLong(), rand.nextInt(100000));
- nat2 = buf2.localCopy(metadata, nativeAllocator, group);
-
- assert test.type.compare(buf.name(), nat.name()) == 0;
- assert test.type.compare(buf2.name(), nat2.name()) == 0;
-
- val = test.type.compare(buf.name(), buf2.name());
- assert test.type.compare(nat.name(), nat2.name()) == val;
- assert test.type.compare(nat.name(), buf2.name()) == val;
- assert test.type.compare(buf.name(), nat2.name()) == val;
-
-
- // test CounterCell
- buf = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
- nat = buf.localCopy(metadata, nativeAllocator, group);
-
- buf2 = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
- nat2 = buf2.localCopy(metadata, nativeAllocator, group);
-
- assert test.type.compare(buf.name(), nat.name()) == 0;
- assert test.type.compare(buf2.name(), nat2.name()) == 0;
-
- val = test.type.compare(buf.name(), buf2.name());
- assert test.type.compare(nat.name(), nat2.name()) == val;
- assert test.type.compare(nat.name(), buf2.name()) == val;
- assert test.type.compare(buf.name(), nat2.name()) == val;
-
- }
- }
-
- static void test(Name test, Cell buf, Cell nat) throws IOException
- {
- Assert.assertTrue(buf.equals(nat));
- Assert.assertTrue(nat.equals(buf));
- Assert.assertTrue(buf.equals(buf));
- Assert.assertTrue(nat.equals(nat));
-
- try
- {
- MessageDigest d1 = MessageDigest.getInstance("MD5");
- MessageDigest d2 = MessageDigest.getInstance("MD5");
- buf.updateDigest(d1);
- nat.updateDigest(d2);
- Assert.assertArrayEquals(d1.digest(), d2.digest());
- }
- catch (NoSuchAlgorithmException e)
- {
- throw new IllegalStateException(e);
- }
-
- byte[] serialized;
- try (DataOutputBuffer bufOut = new DataOutputBuffer())
- {
- test.type.columnSerializer().serialize(nat, bufOut);
- serialized = bufOut.getData();
- }
-
- ByteArrayInputStream bufIn = new ByteArrayInputStream(serialized, 0, serialized.length);
- Cell deserialized = test.type.columnSerializer().deserialize(new DataInputStream(bufIn));
- Assert.assertTrue(buf.equals(deserialized));
-
- }
-
-
-
-}
+///*
+//* Licensed to the Apache Software Foundation (ASF) under one
+//* or more contributor license agreements. See the NOTICE file
+//* distributed with this work for additional information
+//* regarding copyright ownership. The ASF licenses this file
+//* to you under the Apache License, Version 2.0 (the
+//* "License"); you may not use this file except in compliance
+//* with the License. You may obtain a copy of the License at
+//*
+//* http://www.apache.org/licenses/LICENSE-2.0
+//*
+//* Unless required by applicable law or agreed to in writing, software
+//* distributed under the License is distributed on an "AS IS" BASIS,
+//* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//* See the License for the specific language governing permissions and
+//* limitations under the License.
+//*/
+//package org.apache.cassandra.db;
+//
+//import java.io.ByteArrayInputStream;
+//import java.io.DataInputStream;
+//import java.io.IOException;
+//import java.nio.ByteBuffer;
+//import java.security.MessageDigest;
+//import java.security.NoSuchAlgorithmException;
+//import java.util.Arrays;
+//import java.util.Random;
+//import java.util.concurrent.ThreadLocalRandom;
+//
+//import org.junit.Assert;
+//import org.junit.Test;
+//
+//import org.apache.cassandra.config.CFMetaData;
+//import org.apache.cassandra.config.ColumnDefinition;
+//import org.apache.cassandra.cql3.ColumnIdentifier;
+//import org.apache.cassandra.db.context.CounterContext;
+//import org.apache.cassandra.db.marshal.AbstractType;
+//import org.apache.cassandra.db.marshal.UTF8Type;
+//import org.apache.cassandra.db.rows.Cell;
+//import org.apache.cassandra.exceptions.ConfigurationException;
+//import org.apache.cassandra.io.util.DataOutputBuffer;
+//import org.apache.cassandra.utils.concurrent.OpOrder;
+//import org.apache.cassandra.utils.memory.NativeAllocator;
+//import org.apache.cassandra.utils.memory.NativePool;
+//
+//import static org.apache.cassandra.utils.ByteBufferUtil.bytes;
+//
+//public class NativeCellTest
+//{
+//
+// private static final NativeAllocator nativeAllocator = new NativePool(Integer.MAX_VALUE, Integer.MAX_VALUE, 1f, null).newAllocator();
+// private static final OpOrder.Group group = new OpOrder().start();
+//
+// static class Name
+// {
+// final CellName name;
+// final CellNameType type;
+// Name(CellName name, CellNameType type)
+// {
+// this.name = name;
+// this.type = type;
+// }
+// }
+//
+// static ByteBuffer[] bytess(String ... strings)
+// {
+// ByteBuffer[] r = new ByteBuffer[strings.length];
+// for (int i = 0 ; i < r.length ; i++)
+// r[i] = bytes(strings[i]);
+// return r;
+// }
+//
+// final static Name[] TESTS = new Name[]
+// {
+// new Name(simpleDense(bytes("a")), new SimpleDenseCellNameType(UTF8Type.instance)),
+// new Name(simpleSparse(new ColumnIdentifier("a", true)), new SimpleSparseCellNameType(UTF8Type.instance)),
+// new Name(compositeDense(bytes("a"), bytes("b")), new CompoundDenseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
+// new Name(compositeSparse(bytess("b", "c"), new ColumnIdentifier("a", true), false), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
+// new Name(compositeSparse(bytess("b", "c"), new ColumnIdentifier("a", true), true), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
+// new Name(simpleDense(huge('a', 40000)), new SimpleDenseCellNameType(UTF8Type.instance)),
+// new Name(simpleSparse(new ColumnIdentifier(hugestr('a', 40000), true)), new SimpleSparseCellNameType(UTF8Type.instance)),
+// new Name(compositeDense(huge('a', 20000), huge('b', 20000)), new CompoundDenseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
+// new Name(compositeSparse(huges(40000, 'b', 'c'), new ColumnIdentifier(hugestr('a', 10000), true), false), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance))),
+// new Name(compositeSparse(huges(40000, 'b', 'c'), new ColumnIdentifier(hugestr('a', 10000), true), true), new CompoundSparseCellNameType(Arrays.<AbstractType<?>>asList(UTF8Type.instance, UTF8Type.instance)))
+// };
+//
+// private static ByteBuffer huge(char ch, int count)
+// {
+// return bytes(hugestr(ch, count));
+// }
+//
+// private static ByteBuffer[] huges(int count, char ... chs)
+// {
+// ByteBuffer[] r = new ByteBuffer[chs.length];
+// for (int i = 0 ; i < chs.length ; i++)
+// r[i] = huge(chs[i], count / chs.length);
+// return r;
+// }
+//
+// private static String hugestr(char ch, int count)
+// {
+// ThreadLocalRandom random = ThreadLocalRandom.current();
+// byte[] bytes = new byte[count];
+// random.nextBytes(bytes);
+// bytes[0] = (byte) ch;
+// for (int i = 0 ; i < bytes.length ; i++)
+// bytes[i] &= 0x7f;
+// return new String(bytes);
+// }
+//
+// private static final CFMetaData metadata = new CFMetaData("", "", ColumnFamilyType.Standard, null);
+// static
+// {
+// try
+// {
+// metadata.addColumnDefinition(new ColumnDefinition(null, null, new ColumnIdentifier("a", true), UTF8Type.instance, null, null, null, null, null));
+// }
+// catch (ConfigurationException e)
+// {
+// throw new AssertionError();
+// }
+// }
+//
+// @Test
+// public void testCells() throws IOException
+// {
+// Random rand = ThreadLocalRandom.current();
+// for (Name test : TESTS)
+// {
+// byte[] bytes = new byte[16];
+// rand.nextBytes(bytes);
+//
+// // test regular Cell
+// Cell buf, nat;
+// buf = new BufferCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong());
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+// test(test, buf, nat);
+//
+// // test DeletedCell
+// buf = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+// test(test, buf, nat);
+//
+// // test ExpiringCell
+// buf = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong(), rand.nextInt(100000));
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+// test(test, buf, nat);
+//
+// // test CounterCell
+// buf = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+// test(test, buf, nat);
+// }
+// }
+//
+//
+// @Test
+// public void testComparator()
+// {
+//
+// Random rand = ThreadLocalRandom.current();
+// for (Name test : TESTS)
+// {
+// byte[] bytes = new byte[7];
+// byte[] bytes2 = new byte[7];
+// rand.nextBytes(bytes);
+// rand.nextBytes(bytes2);
+//
+// // test regular Cell
+// Cell buf, nat, buf2, nat2;
+// buf = new BufferCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong());
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+//
+// buf2 = new BufferCell(test.name, ByteBuffer.wrap(bytes2), rand.nextLong());
+// nat2 = buf2.localCopy(metadata, nativeAllocator, group);
+//
+// assert test.type.compare(buf.name(), nat.name()) == 0;
+// assert test.type.compare(buf2.name(), nat2.name()) == 0;
+//
+// int val = test.type.compare(buf.name(), buf2.name());
+// assert test.type.compare(nat.name(), nat2.name()) == val;
+// assert test.type.compare(nat.name(), buf2.name()) == val;
+// assert test.type.compare(buf.name(), nat2.name()) == val;
+//
+//
+// // test DeletedCell
+// buf = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+// buf2 = new BufferDeletedCell(test.name, rand.nextInt(100000), rand.nextLong());
+// nat2 = buf2.localCopy(metadata, nativeAllocator, group);
+//
+// assert test.type.compare(buf.name(), nat.name()) == 0;
+// assert test.type.compare(buf2.name(), nat2.name()) == 0;
+//
+// val = test.type.compare(buf.name(), buf2.name());
+// assert test.type.compare(nat.name(), nat2.name()) == val;
+// assert test.type.compare(nat.name(), buf2.name()) == val;
+// assert test.type.compare(buf.name(), nat2.name()) == val;
+//
+//
+//
+// // test ExpiringCell
+// buf = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes), rand.nextLong(), rand.nextInt(100000));
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+//
+// buf2 = new BufferExpiringCell(test.name, ByteBuffer.wrap(bytes2), rand.nextLong(), rand.nextInt(100000));
+// nat2 = buf2.localCopy(metadata, nativeAllocator, group);
+//
+// assert test.type.compare(buf.name(), nat.name()) == 0;
+// assert test.type.compare(buf2.name(), nat2.name()) == 0;
+//
+// val = test.type.compare(buf.name(), buf2.name());
+// assert test.type.compare(nat.name(), nat2.name()) == val;
+// assert test.type.compare(nat.name(), buf2.name()) == val;
+// assert test.type.compare(buf.name(), nat2.name()) == val;
+//
+//
+// // test CounterCell
+// buf = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
+// nat = buf.localCopy(metadata, nativeAllocator, group);
+//
+// buf2 = new BufferCounterCell(test.name, CounterContext.instance().createLocal(rand.nextLong()), rand.nextLong(), rand.nextInt(100000));
+// nat2 = buf2.localCopy(metadata, nativeAllocator, group);
+//
+// assert test.type.compare(buf.name(), nat.name()) == 0;
+// assert test.type.compare(buf2.name(), nat2.name()) == 0;
+//
+// val = test.type.compare(buf.name(), buf2.name());
+// assert test.type.compare(nat.name(), nat2.name()) == val;
+// assert test.type.compare(nat.name(), buf2.name()) == val;
+// assert test.type.compare(buf.name(), nat2.name()) == val;
+//
+// }
+// }
+//
+// static void test(Name test, Cell buf, Cell nat) throws IOException
+// {
+// Assert.assertTrue(buf.equals(nat));
+// Assert.assertTrue(nat.equals(buf));
+// Assert.assertTrue(buf.equals(buf));
+// Assert.assertTrue(nat.equals(nat));
+//
+// try
+// {
+// MessageDigest d1 = MessageDigest.getInstance("MD5");
+// MessageDigest d2 = MessageDigest.getInstance("MD5");
+// buf.updateDigest(d1);
+// nat.updateDigest(d2);
+// Assert.assertArrayEquals(d1.digest(), d2.digest());
+// }
+// catch (NoSuchAlgorithmException e)
+// {
+// throw new IllegalStateException(e);
+// }
+//
+// byte[] serialized;
+// try (DataOutputBuffer bufOut = new DataOutputBuffer())
+// {
+// test.type.columnSerializer().serialize(nat, bufOut);
+// serialized = bufOut.getData();
+// }
+//
+// ByteArrayInputStream bufIn = new ByteArrayInputStream(serialized, 0, serialized.length);
+// Cell deserialized = test.type.columnSerializer().deserialize(new DataInputStream(bufIn));
+// Assert.assertTrue(buf.equals(deserialized));
+//
+// }
+//
+//
+//
+//}