Clears the dest ColumnBuffer and inserts all entries in dest where the timestamp passes the
timestampTest.

@param dest Destination ColumnBuffer
@param timestampTest Test to determine which timestamps get added to dest
505362
public void copyTo(ColumnBuffer dest, LongPredicate timestampTest) {
    dest.clear();

    if (key != null) {
      dest.key = new Key(key);
    }

    for (int i = 0; i < timeStamps.size(); i++) {
      long time = timeStamps.get(i);
      if (timestampTest.test(time)) {
        dest.add(time, values.get(i));
      }
    }
  }
448817
public static boolean isUnixTimeStamp(String timeStamp) {
    if (timeStamp.length() != ComplianceConfigurationKeys.TIME_STAMP_LENGTH) {
      return false;
    }
    try {
      Long.parseLong(timeStamp);
      return true;
    } catch (NumberFormatException e) {
      return false;
    }
  }
913872
@Override
	public void updateTimestamp(final String columnLabel, final Timestamp x) throws SQLException {
		wrapped.updateTimestamp(columnLabel, x);
	}
746934
public void addColumn(ByteBuffer name, ByteBuffer value, long timestamp) throws IOException
    {
        addColumn(new BufferCell(metadata.comparator.cellFromByteBuffer(name), value, timestamp));
    }
1038599
public void add(final int articleID, final int revisionCounter,
			final long timestamp)
	{

		if (this.articleID != articleID) {

			if (list != null) {
				addToBuffer();
			}

			this.articleID = articleID;
			this.list = new ArrayList<ChronoIndexData>();
		}

		this.list.add(new ChronoIndexData(timestamp, revisionCounter));
	}
295268
public static TimestampSpec mergeTimestampSpec(List<TimestampSpec> toMerge)
  {
    if (toMerge == null || toMerge.size() == 0) {
      return null;
    }

    TimestampSpec result = toMerge.get(0);
    for (int i = 1; i < toMerge.size(); i++) {
      if (toMerge.get(i) == null) {
        continue;
      }
      if (!Objects.equals(result, toMerge.get(i))) {
        return null;
      }
    }

    return result;
  }
591276
@Override
    public void setTimestamp(int parameterIndex, Timestamp x) throws SQLException {
        internalStmt.setTimestamp(parameterIndex, x);
    }
683176
protected void clearStatementCaches(boolean internalClose) {

		if (this.statementCachingEnabled){ // safety

			if (internalClose){
				this.callableStatementCache.clear();
				this.preparedStatementCache.clear();
			} else {
				if (this.pool.closeConnectionWatch){ // debugging enabled?
					this.callableStatementCache.checkForProperClosure();
					this.preparedStatementCache.checkForProperClosure();
				}
			}
		}
	}
490611
public void clearField(final FieldDescriptorType descriptor) {
    fields.remove(descriptor);
    if (fields.isEmpty()) {
      hasLazyField = false;
    }
  }
5115
@Override
	public final void deleteTemporaryQueue(String queueName) throws JMSException
    {
        DeleteTemporaryQueueQuery query = new DeleteTemporaryQueueQuery();
        query.setQueueName(queueName);
        transportEndpoint.blockingRequest(query);
    }
284772
protected synchronized void flushBuffer(boolean chunkComplete,
      boolean keepPartialData) throws IOException {
    if (count != 0) {
      int chunkLen = count;
      count = 0;
      writeChecksumChunk(buf, 0, chunkLen, keepPartialData && !chunkComplete);
      if (!chunkComplete) {
        if (!keepPartialData) {
          bytesSentInChunk += chunkLen;
        } else {
          count = chunkLen;
        }
      } else {
        bytesSentInChunk = 0;
      }
    }
  }
533562
public void setLastUpdatedTimes(java.util.Collection<DateTimeRange> lastUpdatedTimes) {
        if (lastUpdatedTimes == null) {
            this.lastUpdatedTimes = null;
            return;
        }

        this.lastUpdatedTimes = new java.util.ArrayList<DateTimeRange>(lastUpdatedTimes);
    }
1216241
public <T> void clear(ElementDescriptor<T> property)
	{
		if (mSet != null)
		{
			mSet.remove(property);
		}
	}
1168035
public static final void clearRemaining(ByteBuffer bb)
    {
        if (bb.hasArray())
        {
            Arrays.fill(bb.array(), bb.arrayOffset()+bb.position(), bb.arrayOffset()+bb.limit(), (byte)0);
        }
        else
        {
            int limit = bb.limit();
            for (int ii=bb.position();ii<limit;ii++)
            {
                bb.put(ii, (byte)0);
            }
        }
    }
901877
private function cleanupTimestamp($timestamp): void
    {
        $key = sprintf('%s:%s', self::AT_QUEUE_NAME, $timestamp);

        if ($this->client->llen($key)) {
            $this->client->del([$key]);
            $this->client->zrem(self::AT_QUEUE_NAME, $timestamp);
        }
    }
1090237
public void update(VectorTimestamp<T> timestamp) {
    VectorTimestamp<T> currentTimestamp = vector.get(timestamp.identifier());
    if (currentTimestamp == null || currentTimestamp.value() < timestamp.value()) {
      vector.put(timestamp.identifier(), timestamp);
    }
  }
466061
public void updateAllTimestamp(long timestamp)
  {
    if (topLevel.markedForDeleteAt != Long.MIN_VALUE)
      topLevel = new DeletionTime(timestamp, topLevel.localDeletionTime);

    if (ranges != null)
      ranges.updateAllTimestamp(timestamp);
  }