Package org.apache.beam.fn.harness.control

Class FinalizeBundleHandler.CallbackRegistration

java.lang.Object

org.apache.beam.fn.harness.control.FinalizeBundleHandler.CallbackRegistration

Enclosing class:

FinalizeBundleHandler

public abstract static class FinalizeBundleHandler.CallbackRegistration
extends java.lang.Object

A DoFn.BundleFinalizer.Callback and expiry time pair.

Constructor Summary

Constructors

Constructor	Description
CallbackRegistration()

Method Summary

Modifier and Type	Method	Description
static FinalizeBundleHandler.CallbackRegistration	create(org.joda.time.Instant expiryTime, org.apache.beam.sdk.transforms.DoFn.BundleFinalizer.Callback callback)
abstract org.apache.beam.sdk.transforms.DoFn.BundleFinalizer.Callback	getCallback()
abstract org.joda.time.Instant	getExpiryTime()

Methods inherited from class java.lang.Object

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

Constructor Detail

CallbackRegistration

public CallbackRegistration()

Method Detail

create

public static FinalizeBundleHandler.CallbackRegistration create(org.joda.time.Instant expiryTime,
                                                                org.apache.beam.sdk.transforms.DoFn.BundleFinalizer.Callback callback)

getExpiryTime

public abstract org.joda.time.Instant getExpiryTime()

getCallback

public abstract org.apache.beam.sdk.transforms.DoFn.BundleFinalizer.Callback getCallback()