Class DataEndpoint

Method Details

• getNestedEndpoint

  public DataEndpoint getNestedEndpoint()

  Description copied from class: Endpoint

  Returns the Endpoint held inside this one or null if there isn't one.

  Overrides:

  getNestedEndpoint in class Endpoint

• getRootEndpoint

  public DataEndpoint getRootEndpoint()

  Description copied from class: Endpoint

  Returns the deepest, nested Endpoint held inside this one, otherwise this instance is returned if there aren't any nested Endpoints.

  Overrides:

  getRootEndpoint in class Endpoint

• getLastRecord

  public Record getLastRecord()

  Returns the most recent record seen by this endpoint while it is open or null.

• open

  public void open() throws DataException

  Makes this endpoint ready for reading or writing.

  Overrides:

  open in class Endpoint

  Throws:

  DataException

• close

  public void close() throws DataException

  Indicates that this endpoint has finished reading or writing.

  Overrides:

  close in class Endpoint

  Throws:

  DataException

• addExceptionProperties

  public DataException addExceptionProperties(DataException exception)

  Description copied from class: Endpoint

  Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.

  Overrides:

  addExceptionProperties in class Endpoint

• toString

  public String toString()

  Overrides:

  toString in class Endpoint

• incrementRecordCount

  protected void incrementRecordCount()

  Increases this endpoint's record-count by 1.

  See Also:

  • getRecordCountAsBigInteger()
  • getRecordCount()
  • isRecordCountBigInteger()

• decrementRecordCount

  protected void decrementRecordCount()

  Reduces this endpoint's record-count by 1.

  See Also:

  • getRecordCountAsBigInteger()
  • getRecordCount()
  • isRecordCountBigInteger()

• resetRecordCount

  protected void resetRecordCount()

  Restarts this endpoint's record-count at 0.

  See Also:

  • getRecordCountAsBigInteger()
  • getRecordCount()
  • isRecordCountBigInteger()

• isRecordCountBigInteger

  public boolean isRecordCountBigInteger()

  Indicates if this endpoint's record-count is too big (over 1000000000000000000L or 1.0e+18) for a long and should be retrieved as a BigInteger using getRecordCountAsBigInteger().

  See Also:

  • getRecordCountAsBigInteger()
  • getRecordCount()

• getRecordCount

  public long getRecordCount()

  Returns this endpoint's record-count as a long. If the count grows above 1000000000000000000L or 1.0e+18, it will wrap to 1, but getRecordCountAsBigInteger() will contain the full value.

  See Also:

  • getRecordCountAsBigInteger()
  • isRecordCountBigInteger()

• getRecordCountAsBigInteger

  public BigInteger getRecordCountAsBigInteger()

  Returns this endpoint's record-count as a BigInteger.

  See Also:

  • getRecordCount()
  • isRecordCountBigInteger()

• getRecordCountAsString

  public String getRecordCountAsString()

  Returns this endpoint's record-count as a String.

  See Also:

  • getRecordCountAsBigInteger()
  • getRecordCount()
  • isRecordCountBigInteger()

• enableJmx

  public static void enableJmx()

  Turns JMX (Java Management Extensions) monitoring invalid input: '&' management on and exposes running Jobs and EventBuses as managed beans.