test_class.file: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java
test_class.identifier: StreamRecordTest
test_case.body: @Test
  	public void testAllowedTimestampRange() {
  		assertEquals(0L, new StreamRecord<>("test", 0).getTimestamp());
  		assertEquals(-1L, new StreamRecord<>("test", -1).getTimestamp());
  		assertEquals(1L, new StreamRecord<>("test", 1).getTimestamp());
  		assertEquals(Long.MIN_VALUE, new StreamRecord<>("test", Long.MIN_VALUE).getTimestamp());
  		assertEquals(Long.MAX_VALUE, new StreamRecord<>("test", Long.MAX_VALUE).getTimestamp());
  	}
test_case.class_method_signature: StreamRecordTest.testAllowedTimestampRange()
test_case.full_signature: @Test public void testAllowedTimestampRange()
test_case.identifier: testAllowedTimestampRange
test_case.invocations: assertEquals getTimestamp assertEquals getTimestamp assertEquals getTimestamp assertEquals getTimestamp assertEquals getTimestamp
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testAllowedTimestampRange()
focal_class.declarator: value
focal_class.modifier: private
focal_class.original_string: private T value;
focal_class.type: T
focal_class.var_name: value
focal_class.declarator: timestamp
focal_class.modifier: private
focal_class.original_string: private long timestamp;
focal_class.type: long
focal_class.var_name: timestamp
focal_class.declarator: hasTimestamp
focal_class.modifier: private
focal_class.original_string: private boolean hasTimestamp;
focal_class.type: boolean
focal_class.var_name: hasTimestamp
focal_class.file: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java
focal_class.identifier: StreamRecord
focal_class.class_method_signature: StreamRecord.StreamRecord(T value)
focal_class.full_signature: public  StreamRecord(T value)
focal_class.identifier: StreamRecord
focal_class.modifiers: public
focal_class.parameters: (T value)
focal_class.signature:  StreamRecord(T value)
focal_class.class_method_signature: StreamRecord.StreamRecord(T value, long timestamp)
focal_class.full_signature: public  StreamRecord(T value, long timestamp)
focal_class.identifier: StreamRecord
focal_class.modifiers: public
focal_class.parameters: (T value, long timestamp)
focal_class.signature:  StreamRecord(T value, long timestamp)
focal_class.class_method_signature: StreamRecord.getValue()
focal_class.full_signature: public T getValue()
focal_class.identifier: getValue
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: T
focal_class.signature: T getValue()
focal_class.class_method_signature: StreamRecord.getTimestamp()
focal_class.full_signature: public long getTimestamp()
focal_class.identifier: getTimestamp
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getTimestamp()
focal_class.class_method_signature: StreamRecord.hasTimestamp()
focal_class.full_signature: public boolean hasTimestamp()
focal_class.identifier: hasTimestamp
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasTimestamp()
focal_class.class_method_signature: StreamRecord.replace(X element)
focal_class.full_signature: @SuppressWarnings("unchecked") public StreamRecord<X> replace(X element)
focal_class.identifier: replace
focal_class.modifiers: @SuppressWarnings("unchecked") public
focal_class.parameters: (X element)
focal_class.return: StreamRecord<X>
focal_class.signature: StreamRecord<X> replace(X element)
focal_class.class_method_signature: StreamRecord.replace(X value, long timestamp)
focal_class.full_signature: @SuppressWarnings("unchecked") public StreamRecord<X> replace(X value, long timestamp)
focal_class.identifier: replace
focal_class.modifiers: @SuppressWarnings("unchecked") public
focal_class.parameters: (X value, long timestamp)
focal_class.return: StreamRecord<X>
focal_class.signature: StreamRecord<X> replace(X value, long timestamp)
focal_class.class_method_signature: StreamRecord.setTimestamp(long timestamp)
focal_class.full_signature: public void setTimestamp(long timestamp)
focal_class.identifier: setTimestamp
focal_class.modifiers: public
focal_class.parameters: (long timestamp)
focal_class.return: void
focal_class.signature: void setTimestamp(long timestamp)
focal_class.class_method_signature: StreamRecord.eraseTimestamp()
focal_class.full_signature: public void eraseTimestamp()
focal_class.identifier: eraseTimestamp
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void eraseTimestamp()
focal_class.class_method_signature: StreamRecord.copy(T valueCopy)
focal_class.full_signature: public StreamRecord<T> copy(T valueCopy)
focal_class.identifier: copy
focal_class.modifiers: public
focal_class.parameters: (T valueCopy)
focal_class.return: StreamRecord<T>
focal_class.signature: StreamRecord<T> copy(T valueCopy)
focal_class.class_method_signature: StreamRecord.copyTo(T valueCopy, StreamRecord<T> target)
focal_class.full_signature: public void copyTo(T valueCopy, StreamRecord<T> target)
focal_class.identifier: copyTo
focal_class.modifiers: public
focal_class.parameters: (T valueCopy, StreamRecord<T> target)
focal_class.return: void
focal_class.signature: void copyTo(T valueCopy, StreamRecord<T> target)
focal_class.class_method_signature: StreamRecord.equals(Object o)
focal_class.full_signature: @Override public boolean equals(Object o)
focal_class.identifier: equals
focal_class.modifiers: @Override public
focal_class.parameters: (Object o)
focal_class.return: boolean
focal_class.signature: boolean equals(Object o)
focal_class.class_method_signature: StreamRecord.hashCode()
focal_class.full_signature: @Override public int hashCode()
focal_class.identifier: hashCode
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int hashCode()
focal_class.class_method_signature: StreamRecord.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.superclass: extends StreamElement
focal_method.body: public long getTimestamp() {
  		if (hasTimestamp) {
  			return timestamp;
  		} else {
  			return Long.MIN_VALUE;
  //			throw new IllegalStateException(
  //					"Record has no timestamp. Is the time characteristic set to 'ProcessingTime', or " +
  //							"did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'?");
  		}
  	}
focal_method.class_method_signature: StreamRecord.getTimestamp()
focal_method.full_signature: public long getTimestamp()
focal_method.identifier: getTimestamp
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: long
focal_method.signature: long getTimestamp()