Package org.apache.beam.sdk.io.mongodb

Interface MongoDbGridFSIO.ParserCallback<T>

All Superinterfaces:
Serializable
Enclosing class:
MongoDbGridFSIO
public static interface MongoDbGridFSIO.ParserCallback<T> extends Serializable
Callback for the parser to use to submit data.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    output(T output)
    Output the object.
    void
    output(T output, Instant timestamp)
    Output the object using the specified timestamp.

  • Method Details

    • output

      void output(T output)
      Output the object. The default timestamp will be the GridFSDBFile creation timestamp.

    • output

      void output(T output, Instant timestamp)
      Output the object using the specified timestamp.