Class MeteredWriter

Method Details

• getMeter

  public RecordMeter getMeter()

  Specified by:

  getMeter in interface Metered

• interceptRecord

  protected Record interceptRecord(Record record) throws Throwable

  Description copied from class: ProxyWriter

  Overridden by subclasses to transform, drop, or observe a record on its way through this proxy.

  Contract for subclasses (see also docs/authoring/ProxyWriter.md):

  • Return the record (possibly modified) to forward it to the nested DataWriter.
  • Return null to drop the record; the framework will not write it downstream.
  • Throw to fail the pipeline; the framework wraps the throwable in a DataException with .setRecord(record).
  • The nested DataWriter is opened and closed for you; do not write to it here.
  • Do not call DataEndpoint.incrementRecordCount() here.

  Overrides:

  interceptRecord in class ProxyWriter

  Throws:

  Throwable

• 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 ProxyWriter

• close

  public void close() throws DataException

  Description copied from class: DataEndpoint

  Indicates that this endpoint has finished reading or writing.

  Overrides:

  close in class ProxyWriter

  Throws:

  DataException