Examples of Mergeable


Examples of mil.nga.giat.geowave.index.Mergeable

{
  @Override
  public Value reduce(
      final Key key,
      final Iterator<Value> iter ) {
    Mergeable currentMergeable = null;
    while (iter.hasNext()) {
      final Value val = iter.next();
      Mergeable mergeable = PersistenceUtils.fromBinary(
          val.get(),
          Mergeable.class);
      // hopefully its never the case that null stastics are stored,
      // but just in case, check
      mergeable = transform(
View Full Code Here

Examples of mil.nga.giat.geowave.index.Mergeable

  @Override
  protected void transformRange(
      final SortedKeyValueIterator<Key, Value> input,
      final KVBuffer output )
      throws IOException {
    Mergeable currentMergeable = null;
    Key outputKey = null;
    while (input.hasTop()) {
      final Value val = input.getTopValue();
      // the SortedKeyValueIterator uses the same instance of topKey to hold keys (a wrapper)
      final Key currentKey = new Key(input.getTopKey());
      if (outputKey == null) {
        outputKey = currentKey;
      } else if (currentMergeable != null &&
             !outputKey.getRowData().equals(currentKey.getRowData())) {
        output.append(
            outputKey,
            new Value(
                PersistenceUtils.toBinary(currentMergeable)));
        currentMergeable = null;
        outputKey = currentKey;
        continue;
      }
      else {
        final Text combinedVisibility = new Text(
            combineVisibilities(
                currentKey.getColumnVisibility().getBytes(),
                outputKey.getColumnVisibility().getBytes()));
        outputKey = replaceColumnVisibility(
            outputKey,
            combinedVisibility);
      }
      Mergeable mergeable = PersistenceUtils.fromBinary(
          val.get(),
          Mergeable.class);
      // hopefully its never the case that null mergeables are stored,
      // but just in case, check
      mergeable = transform(
View Full Code Here

Examples of org.springframework.beans.Mergeable

   * @param newValue the argument value in the form of a ValueHolder
   */
  private void addOrMergeIndexedArgumentValue(Integer key, ValueHolder newValue) {
    ValueHolder currentValue = this.indexedArgumentValues.get(key);
    if (currentValue != null && newValue.getValue() instanceof Mergeable) {
      Mergeable mergeable = (Mergeable) newValue.getValue();
      if (mergeable.isMergeEnabled()) {
        newValue.setValue(mergeable.merge(currentValue.getValue()));
      }
    }
    this.indexedArgumentValues.put(key, newValue);
  }
View Full Code Here

Examples of org.springframework.beans.Mergeable

    if (newValue.getName() != null) {
      for (Iterator<ValueHolder> it = this.genericArgumentValues.iterator(); it.hasNext();) {
        ValueHolder currentValue = it.next();
        if (newValue.getName().equals(currentValue.getName())) {
          if (newValue.getValue() instanceof Mergeable) {
            Mergeable mergeable = (Mergeable) newValue.getValue();
            if (mergeable.isMergeEnabled()) {
              newValue.setValue(mergeable.merge(currentValue.getValue()));
            }
          }
          it.remove();
        }
      }
View Full Code Here

Examples of org.springframework.beans.Mergeable

   * @param newValue the argument value in the form of a ValueHolder
   */
  private void addOrMergeIndexedArgumentValue(Integer key, ValueHolder newValue) {
    ValueHolder currentValue = this.indexedArgumentValues.get(key);
    if (currentValue != null && newValue.getValue() instanceof Mergeable) {
      Mergeable mergeable = (Mergeable) newValue.getValue();
      if (mergeable.isMergeEnabled()) {
        newValue.setValue(mergeable.merge(currentValue.getValue()));
      }
    }
    this.indexedArgumentValues.put(key, newValue);
  }
View Full Code Here

Examples of org.springframework.beans.Mergeable

    if (newValue.getName() != null) {
      for (Iterator<ValueHolder> it = this.genericArgumentValues.iterator(); it.hasNext();) {
        ValueHolder currentValue = it.next();
        if (newValue.getName().equals(currentValue.getName())) {
          if (newValue.getValue() instanceof Mergeable) {
            Mergeable mergeable = (Mergeable) newValue.getValue();
            if (mergeable.isMergeEnabled()) {
              newValue.setValue(mergeable.merge(currentValue.getValue()));
            }
          }
          it.remove();
        }
      }
View Full Code Here

Examples of org.springframework.beans.Mergeable

   * @param newValue the argument value in the form of a ValueHolder
   */
  private void addOrMergeIndexedArgumentValue(Object key, ValueHolder newValue) {
    ValueHolder currentValue = (ValueHolder) this.indexedArgumentValues.get(key);
    if (currentValue != null && newValue.getValue() instanceof Mergeable) {
      Mergeable mergeable = (Mergeable) newValue.getValue();
      if (mergeable.isMergeEnabled()) {
        newValue.setValue(mergeable.merge(currentValue.getValue()));
      }
    }
    this.indexedArgumentValues.put(key, newValue);
  }
View Full Code Here

Examples of org.springframework.beans.Mergeable

   * @param newValue the argument value in the form of a ValueHolder
   */
  private void addOrMergeIndexedArgumentValue(Integer key, ValueHolder newValue) {
    ValueHolder currentValue = this.indexedArgumentValues.get(key);
    if (currentValue != null && newValue.getValue() instanceof Mergeable) {
      Mergeable mergeable = (Mergeable) newValue.getValue();
      if (mergeable.isMergeEnabled()) {
        newValue.setValue(mergeable.merge(currentValue.getValue()));
      }
    }
    this.indexedArgumentValues.put(key, newValue);
  }
View Full Code Here

Examples of org.springframework.beans.Mergeable

    if (newValue.getName() != null) {
      for (Iterator<ValueHolder> it = this.genericArgumentValues.iterator(); it.hasNext();) {
        ValueHolder currentValue = it.next();
        if (newValue.getName().equals(currentValue.getName())) {
          if (newValue.getValue() instanceof Mergeable) {
            Mergeable mergeable = (Mergeable) newValue.getValue();
            if (mergeable.isMergeEnabled()) {
              newValue.setValue(mergeable.merge(currentValue.getValue()));
            }
          }
          it.remove();
        }
      }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.