Update Streaming Avro Record Output

[kevinjnguyen]

PR with the progress made towards debugging the streaming implementation.

Changes:

• Reverted the revert for Publish Time. The implementation was correct, just missing one more step.
• Added the missing step for publish time. When reading the stream, a flag is passed to consider adding the publish time.
  • In the execution phase, no publish time (false).
  • In the preparation phase, publish time (true).

[bjchambers]

Seems fine for getting things moving.

Ideally, we'd either introduce an enum for the boolean or we'd simplify things so we didn't need to pass it (possibly deciding based on the presence of the _publish_time field in the schema that we need to add it). If we did the enum, it would let us write something PublishTime::Add or PublishTime::None rather than true and false, which would make it clearer what the booleans mean, especially in the cases of the functions that take multiple booleans.