Package org.apache.beam.runners.spark.io

Class SparkUnboundedSource.Metadata

java.lang.Object

org.apache.beam.runners.spark.io.SparkUnboundedSource.Metadata

All Implemented Interfaces:

Serializable

Enclosing class:

SparkUnboundedSource

public static class SparkUnboundedSource.Metadata
extends Object
implements Serializable

A metadata holder for an input stream partition.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Metadata(long numRecords, Instant lowWatermark, Instant highWatermark, long readDurationMillis, org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainer)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Metadata

public Metadata(long numRecords,
 Instant lowWatermark,
 Instant highWatermark,
 long readDurationMillis,
 org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainer)