Package org.apache.spark.sql.connector.catalog

Record Class ChangelogRange.TimestampRange

Object
Record
org.apache.spark.sql.connector.catalog.ChangelogRange.TimestampRange
Record Components:
startingTimestamp - the starting timestamp in microseconds since epoch
endingTimestamp - the ending timestamp in microseconds since epoch (empty means latest)
startingBoundInclusive - whether the starting bound is inclusive
endingBoundInclusive - whether the ending bound is inclusive
All Implemented Interfaces:
ChangelogRange
Enclosing interface:
ChangelogRange
public static record ChangelogRange.TimestampRange(long startingTimestamp, Optional<Long> endingTimestamp, boolean startingBoundInclusive, boolean endingBoundInclusive) extends Record implements ChangelogRange
A changelog range defined by timestamps.

  • Constructor Details

    • TimestampRange

      public TimestampRange(long startingTimestamp, Optional<Long> endingTimestamp, boolean startingBoundInclusive, boolean endingBoundInclusive)
      Creates an instance of a TimestampRange record class.
      Parameters:
      startingTimestamp - the value for the startingTimestamp record component
      endingTimestamp - the value for the endingTimestamp record component
      startingBoundInclusive - the value for the startingBoundInclusive record component
      endingBoundInclusive - the value for the endingBoundInclusive record component

  • Method Details

    • toString

      public final String toString()
      Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.
      Specified by:
      toString in class Record
      Returns:
      a string representation of this object

    • hashCode

      public final int hashCode()
      Returns a hash code value for this object. The value is derived from the hash code of each of the record components.
      Specified by:
      hashCode in class Record
      Returns:
      a hash code value for this object

    • equals

      public final boolean equals(Object o)
      Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared with Objects::equals(Object,Object); primitive components are compared with '=='.
      Specified by:
      equals in class Record
      Parameters:
      o - the object with which to compare
      Returns:
      true if this object is the same as the o argument; false otherwise.

    • startingTimestamp

      public long startingTimestamp()
      Returns the value of the startingTimestamp record component.
      Returns:
      the value of the startingTimestamp record component

    • endingTimestamp

      public Optional<Long> endingTimestamp()
      Returns the value of the endingTimestamp record component.
      Returns:
      the value of the endingTimestamp record component

    • startingBoundInclusive

      public boolean startingBoundInclusive()
      Returns the value of the startingBoundInclusive record component.
      Specified by:
      startingBoundInclusive in interface ChangelogRange
      Returns:
      the value of the startingBoundInclusive record component

    • endingBoundInclusive

      public boolean endingBoundInclusive()
      Returns the value of the endingBoundInclusive record component.
      Specified by:
      endingBoundInclusive in interface ChangelogRange
      Returns:
      the value of the endingBoundInclusive record component