scio icon indicating copy to clipboard operation
scio copied to clipboard

Fix withAllowedTimestampSkew deprecation warning

Open nevillelyh opened this issue 6 years ago • 2 comments

Need to look at the implications.

def timestampBy(f: T => Instant, allowedTimestampSkew: Duration = Duration.ZERO): SCollection[T] =
    this.applyTransform(WithTimestamps.of(Functions.serializableFn(f))
      .withAllowedTimestampSkew(allowedTimestampSkew))

https://issues.apache.org/jira/browse/BEAM-644

nevillelyh avatar Aug 30 '17 21:08 nevillelyh