@PublicEvolving @FunctionalInterface public interface TimestampAssignerSupplier<T> extends Serializable
TimestampAssigners
. The supplier pattern is used to
avoid having to make TimestampAssigner
Serializable
for use in API methods.
This interface is Serializable
because the supplier may be shipped to workers during
distributed execution.
Modifier and Type | Interface and Description |
---|---|
static interface |
TimestampAssignerSupplier.Context
Additional information available to
createTimestampAssigner(Context) . |
static class |
TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>
We need an actual class.
|
Modifier and Type | Method and Description |
---|---|
TimestampAssigner<T> |
createTimestampAssigner(TimestampAssignerSupplier.Context context)
Instantiates a
TimestampAssigner . |
static <T> TimestampAssignerSupplier<T> |
of(SerializableTimestampAssigner<T> assigner) |
TimestampAssigner<T> createTimestampAssigner(TimestampAssignerSupplier.Context context)
TimestampAssigner
.static <T> TimestampAssignerSupplier<T> of(SerializableTimestampAssigner<T> assigner)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.