@Internal public interface XidGenerator extends Serializable, AutoCloseable
Xid
generator.Modifier and Type | Method and Description |
---|---|
boolean |
belongsToSubtask(Xid xid,
RuntimeContext ctx) |
default void |
close() |
Xid |
generateXid(RuntimeContext runtimeContext,
long checkpointId)
Generate new
Xid . |
default void |
open() |
static XidGenerator |
semanticXidGenerator()
Creates a
XidGenerator that generates xids from:
job id
subtask index
checkpoint id
four random bytes generated using SecureRandom )
|
Xid generateXid(RuntimeContext runtimeContext, long checkpointId)
Xid
. Requirements for generated Xids:
runtimeContext
- can be used for example to derive global transaction idcheckpointId
- can be used for example to derive global transaction iddefault void open()
boolean belongsToSubtask(Xid xid, RuntimeContext ctx)
default void close()
close
in interface AutoCloseable
static XidGenerator semanticXidGenerator()
XidGenerator
that generates xids
from:
SecureRandom
)
Each created XidGenerator
instance MUST be used for only one Sink instance
(otherwise Xids could collide).
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.