Examples of KeySerDe

com.cloudera.cdk.data.hbase.impl.KeySerDe
This class handles key serialization and deserialization. @param < K> The type of the key
org.kitesdk.data.hbase.impl.KeySerDe
This class handles key serialization and deserialization.

Examples of com.cloudera.cdk.data.hbase.impl.KeySerDe

   */
  private void initializeEntityVersionEntityMapper() {
    // Create a special key serde that doesn't try to serialize/deserialize
    // the key for the ManagedSchemaEntityVersion record. This schema
    // doesn't have any key mapping types since it's added to every table.
    KeySerDe keySerDe = new KeySerDe() {
      @Override
      public byte[] serialize(PartitionKey partitionKey) {
        return new byte[0];
      }
      @Override

View Full Code Here

Examples of com.cloudera.cdk.data.hbase.impl.KeySerDe

      readSchema = AvroUtils.mergeSpecificStringTypes(entityClass, readSchema);
      AvroEntityComposer entityComposer = new AvroEntityComposer(readSchema,
          true);
      AvroEntitySerDe entitySerDe = new AvroEntitySerDe(entityComposer,
          readSchema, writeSchema, true);
      KeySerDe keySerDe = new AvroKeySerDe(keySchema.getAvroSchema(), keySchema.getPartitionStrategy());
      return new BaseEntityMapper(keySchema, readSchema, keySerDe, entitySerDe);
    } else {
      KeySerDe keySerDe = new AvroKeySerDe(keySchema.getAvroSchema(), keySchema.getPartitionStrategy());
      AvroEntityComposer entityComposer = new AvroEntityComposer(readSchema,
          false);
      AvroEntitySerDe entitySerDe = new AvroEntitySerDe(entityComposer,
          readSchema, writeSchema, false);
      return new BaseEntityMapper(keySchema, readSchema, keySerDe, entitySerDe);

View Full Code Here

Examples of org.kitesdk.data.hbase.impl.KeySerDe

      readSchema = AvroUtils.mergeSpecificStringTypes(entityClass, readSchema);
      AvroEntityComposer entityComposer = new AvroEntityComposer(readSchema,
          true);
      AvroEntitySerDe entitySerDe = new AvroEntitySerDe(entityComposer,
          readSchema, writeSchema, true);
      KeySerDe keySerDe = new AvroKeySerDe(keySchema.getAvroSchema(), keySchema.getPartitionStrategy());
      return new BaseEntityMapper(keySchema, readSchema, keySerDe, entitySerDe);
    } else {
      KeySerDe keySerDe = new AvroKeySerDe(keySchema.getAvroSchema(), keySchema.getPartitionStrategy());
      AvroEntityComposer entityComposer = new AvroEntityComposer(readSchema,
          false);
      AvroEntitySerDe entitySerDe = new AvroEntitySerDe(entityComposer,
          readSchema, writeSchema, false);
      return new BaseEntityMapper(keySchema, readSchema, keySerDe, entitySerDe);

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.