Package s2.types

Class Timestamping

java.lang.Object

s2.types.Timestamping

public class Timestamping
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
TimestampingMode	mode
boolean	uncapped

Constructor Summary

Constructors

Constructor	Description
Timestamping(TimestampingMode mode, boolean uncapped)	Instantiates a new Timestamping.

Method Summary

Modifier and Type	Method	Description
static Timestamping	fromProto(s2.v1alpha.StreamConfig.Timestamping proto)
s2.v1alpha.StreamConfig.Timestamping	toProto()

Methods inherited from class java.lang.Object

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

Field Detail

mode

public final TimestampingMode mode

uncapped

public final boolean uncapped

Constructor Detail

Timestamping

public Timestamping(TimestampingMode mode,
                    boolean uncapped)

Instantiates a new Timestamping.

Parameters:

mode - selected timestamping behavior

uncapped - if client-specified timestamps should be allowed to exceed the arrival time

Method Detail

fromProto

public static Timestamping fromProto(s2.v1alpha.StreamConfig.Timestamping proto)

toProto

public s2.v1alpha.StreamConfig.Timestamping toProto()