Trigger

java.lang.Object

org.apache.iceberg.flink.maintenance.api.Trigger

public class Trigger extends Object

Method Summary

Modifier and Type

Method

Description

static Trigger

create(long timestamp, int taskId)

boolean

isRecovery()

static Trigger

recovery(long timestamp)

Integer

taskId()

long

timestamp()

String

toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details
- create
  
  @Internal public static Trigger create(long timestamp, int taskId)
- recovery
  
  @Internal public static Trigger recovery(long timestamp)
- timestamp
  
  public long timestamp()
- taskId
  
  public Integer taskId()
- isRecovery
  
  public boolean isRecovery()
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object