Utility Classes

Utility interfaces and classes that support the filesystem connector's operation.

Clock Interface

Interface for providing current time to bucketing strategies.

public interface Clock

Method

long currentTimeMillis()

Returns the current time in milliseconds since Unix epoch.

Returns: Current time in milliseconds

SystemClock

Default Clock implementation that uses system time.

public class SystemClock implements Clock

Constructor

public SystemClock()

Creates a SystemClock that returns System.currentTimeMillis().

Usage Example

import org.apache.flink.streaming.connectors.fs.Clock;
import org.apache.flink.streaming.connectors.fs.SystemClock;

// Typically used internally by the framework
Clock clock = new SystemClock();
long currentTime = clock.currentTimeMillis();

Note: Clock implementations are primarily used internally by bucketing strategies and are automatically provided by the BucketingSink.