Examples of Deserializer

ariba.util.io.Deserializer
FilterInputStream subclass that can deserialize Maps, Lists, arrays, and Strings from an ASCII stream. The serialization format is very similar to the output of Map's and List's toString() methods, except strings with non-alphanumeric characters are quoted and special characters are escaped so that the output can be unambiguously deserialized. @see Serializer @aribaapi private
br.com.caelum.vraptor.deserialization.Deserializer
Deserializes request body according to a given content type. @author Lucas Cavalcanti, Ricardo Nakamura @since 3.0.2
br.com.caelum.vraptor.serialization.Deserializer
Deserializes request body according to a given content type. @author Lucas Cavalcanti, Ricardo Nakamura @since 3.0.2
com.carrotsearch.ant.tasks.junit4.events.Deserializer
Event deserializer.
com.caucho.hessian.io.Deserializer
Deserializing an object.
com.taobao.metamorphosis.utils.codec.Deserializer
@author wuxin @since 1.0, 2009-10-20 ��09:42:35
info.ata4.unity.serdes.Deserializer
Deserializer for Unity objects. @author Nico Bergemann
javax.xml.rpc.encoding.Deserializer
Interface for a deserializer.
jfun.yan.util.deserializer.Deserializer
This interface is responsible for converting string to a target type.
@author Ben YuFeb 1, 2006 12:30:07 AM
org.apache.axis.encoding.Deserializer
The Deserializer base class. Still needs some work. @author Glen Daniels (gdaniels@allaire.com)
org.apache.axis2.databinding.Deserializer
Deserializer
org.apache.hadoop.hive.serde2.Deserializer
HiveDeserializer is used to deserialize the data from hadoop Writable to a custom java object that can be of any type that the developer wants. HiveDeserializer also provides the ObjectInspector which can be used to inspect the internal structure of the object (that is returned by deserialize function).
org.apache.hadoop.io.serializer.Deserializer

Provides a facility for deserializing objects of type from an {@link InputStream}.

Deserializers are stateful, but must not buffer the input since other producers may read from the input between calls to {@link #deserialize(Object)}.
@param < T>
org.apache.soap.util.xml.Deserializer
A Deserializer ... @author Matthew J. Duftler (duftler@us.ibm.com) @author Sanjiva Weerawarana (sanjiva@watson.ibm.com) @author Francisco Curbera (curbera@us.ibm.com)
org.hibernate.search.indexes.serialization.codex.spi.Deserializer
Contract between Hibernate Search and the Deserializer. All the LuceneWork construction is delegated to methods of PluggableSerializationLuceneWorkSerializer. After deserialize is call, Hibernate Search will extract the built List of LuceneWork @author Emmanuel Bernard
org.hibernate.search.indexes.serialization.spi.Deserializer
Contract between Hibernate Search and the Deserializer. All the LuceneWork construction is delegated to methods of PluggableSerializationLuceneWorkSerializer. After deserialize is call, Hibernate Search will extract the built List of LuceneWork @author Emmanuel Bernard
org.jsefa.Deserializer
org.neo4j.smack.serialization.Deserializer
org.red5.io.object.Deserializer
The Deserializer class reads data input and handles the data according to the core data types @author The Red5 Project (red5@osflash.org) @author Luke Hubbard, Codegent Ltd (luke@codegent.com)

Examples of org.apache.hadoop.hive.serde2.Deserializer

    return createRowInspector(getStructOIFrom(partitionOI), partKeys);
  }


  private StructObjectInspector getRowInspectorFromPartitionedTable(TableDesc table)
      throws Exception {
    Deserializer serde = table.getDeserializerClass().newInstance();
    serde.initialize(job, table.getProperties());
    String pcols = table.getProperties().getProperty(
        org.apache.hadoop.hive.metastore.api.hive_metastoreConstants.META_TABLE_PARTITION_COLUMNS);
    String[] partKeys = pcols.trim().split("/");
    row[1] = null;
    return createRowInspector(getStructOIFrom(serde.getObjectInspector()), partKeys);
  }

View Full Code Here

Examples of org.apache.hadoop.hive.serde2.Deserializer

      }


      // Choose any partition. It's OI needs to be converted to the table OI
      // Whenever a new partition is being read, a new converter is being created
      PartitionDesc partition = listParts.get(0);
      Deserializer tblSerde = partition.getTableDesc().getDeserializerClass().newInstance();
      tblSerde.initialize(job, partition.getTableDesc().getProperties());


      partitionedTableOI = null;
      ObjectInspector tableOI = tblSerde.getObjectInspector();


      // Get the OI corresponding to all the partitions
      for (PartitionDesc listPart : listParts) {
        partition = listPart;
        Deserializer partSerde = listPart.getDeserializerClass().newInstance();
        partSerde.initialize(job, listPart.getOverlayedProperties());


        partitionedTableOI = ObjectInspectorConverters.getConvertedOI(
            partSerde.getObjectInspector(), tableOI, true);
        if (!partitionedTableOI.equals(tableOI)) {
          break;
        }
      }
      return getRowInspectorFromPartition(partition, partitionedTableOI);

View Full Code Here

Examples of org.apache.hadoop.hive.serde2.Deserializer


  public ArrayList<StructField> getFields() {


    ArrayList<StructField> fields = new ArrayList<StructField>();
    try {
      Deserializer decoder = getDeserializer();


      // Expand out all the columns of the table
      StructObjectInspector structObjectInspector = (StructObjectInspector) decoder
          .getObjectInspector();
      List<? extends StructField> fld_lst = structObjectInspector
          .getAllStructFieldRefs();
      for (StructField field : fld_lst) {
        fields.add(field);

View Full Code Here

Examples of org.apache.hadoop.hive.serde2.Deserializer

            tbl.getSd().getSerdeInfo().getSerializationLib());
        if (!getColsFromSerDe) {
          ret = tbl.getSd().getCols();
        } else {
          try {
            Deserializer s = MetaStoreUtils.getDeserializer(hiveConf, tbl);
            ret = MetaStoreUtils.getFieldsFromDeserializer(tableName, s);
          } catch (SerDeException e) {
            StringUtils.stringifyException(e);
            throw new MetaException(e.getMessage());
          }

View Full Code Here

Examples of org.apache.hadoop.hive.serde2.Deserializer

        int oldTag = newTagToOldTag[i];
        int childIndex = newTagToChildIndex[newTag];
        cntrs[newTag] = 0;
        nextCntrs[newTag] = 0;
        TableDesc keyTableDesc = conf.getKeysSerializeInfos().get(newTag);
        Deserializer inputKeyDeserializer = ReflectionUtils.newInstance(keyTableDesc
            .getDeserializerClass(), null);
        inputKeyDeserializer.initialize(null, keyTableDesc.getProperties());


        TableDesc valueTableDesc = conf.getValuesSerializeInfos().get(newTag);
        Deserializer inputValueDeserializer = ReflectionUtils.newInstance(valueTableDesc
            .getDeserializerClass(), null);
        inputValueDeserializer.initialize(null, valueTableDesc.getProperties());


        List<ObjectInspector> oi = new ArrayList<ObjectInspector>();
        oi.add(inputKeyDeserializer.getObjectInspector());
        oi.add(inputValueDeserializer.getObjectInspector());
        int childParentsCount = conf.getChildIndexToOriginalNumParents().get(childIndex);
        // Multiple newTags can point to the same child (e.g. when the child is a JoinOperator).
        // So, we first check if childInputObjInspectors contains the key of childIndex.
        if (childInputObjInspectors[childIndex] == null) {
          childInputObjInspectors[childIndex] = new ObjectInspector[childParentsCount];

View Full Code Here

Examples of org.apache.hadoop.io.serializer.Deserializer

        String splitClassName = is.readUTF();
        try {
            Class splitClass = conf.getClassByName(splitClassName);
            SerializationFactory sf = new SerializationFactory(conf);
            // The correct call sequence for Deserializer is, we shall open, then deserialize, but we shall not close
            Deserializer d = sf.getDeserializer(splitClass);
            d.open((InputStream) is);
            wrappedSplits = new InputSplit[splitLen];
            for (int i = 0; i < splitLen; i++)
            {
                wrappedSplits[i] = (InputSplit)ReflectionUtils.newInstance(splitClass, conf);
                d.deserialize(wrappedSplits[i]);
            }
        } catch (ClassNotFoundException e) {
            throw new IOException(e);
        }

View Full Code Here

Examples of org.apache.hadoop.io.serializer.Deserializer

    inputSplit = (InputSplit) ReflectionUtils.newInstance(inputSplitClass, conf);
    if (inputSplit instanceof Writable) {
      ((Writable) inputSplit).readFields(in);
    } else {
      SerializationFactory factory = new SerializationFactory(conf);
      Deserializer deserializer = factory.getDeserializer(inputSplitClass);
      deserializer.open((DataInputStream) in);
      inputSplit = (InputSplit) deserializer.deserialize(inputSplit);
      deserializer.close();
    }
  }

View Full Code Here

Examples of org.apache.hadoop.io.serializer.Deserializer

        try {
            Class splitClass = conf.getClassByName(splitClassName);
            wrappedSplit = (InputSplit)ReflectionUtils.newInstance(splitClass, conf);
            SerializationFactory sf = new SerializationFactory(conf);
            // The correct call sequence for Deserializer is, we shall open, then deserialize, but we shall not close
            Deserializer d = sf.getDeserializer(splitClass);
            d.open((InputStream) is);
            d.deserialize(wrappedSplit);
        } catch (ClassNotFoundException e) {
            throw new IOException(e);
        }
        
    }

View Full Code Here

Examples of org.apache.soap.util.xml.Deserializer

            } catch (Throwable ignored) {
            Trc.ignoredException(ignored);
            }


        Serializer literalSerializer = partSer;
        Deserializer literalDeserializer = partSer;
        Serializer soapSerializer = beanSer;
        Deserializer soapDeserializer = beanSer;
        String soapEncoding = Constants.NS_URI_SOAP_ENC;


        // initialize ApacheSOAP specific mappings here
        for (Iterator i = theTypeMap.iterator(); i.hasNext();) {
            WSIFDynamicTypeMapping mapping = (WSIFDynamicTypeMapping) i.next();

View Full Code Here

Examples of org.hibernate.search.indexes.serialization.codex.spi.Deserializer

  /**
   * Convert a byte[] to a List of LuceneWork (assuming the same SerializationProvider is used of course)
   */
  @Override
  public List<LuceneWork> toLuceneWorks(byte[] data) {
    Deserializer deserializer = provider.getDeserializer();
    LuceneWorkHydrator hydrator = new LuceneWorkHydrator( searchFactory );
    deserializer.deserialize( data, hydrator );
    return hydrator.getLuceneWorks();
  }

View Full Code Here

0 1 2 3 4 5 6

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.