Package com.here.platform.data.client.flink.impl

Class ContinuousSourceUtils

java.lang.Object

com.here.platform.data.client.flink.impl.ContinuousSourceUtils

public class ContinuousSourceUtils
extends Object

Shared FLIP-27 Source utilities for continuous (unbounded) polling sources that carry a timestamp as checkpoint state.

Used by QueryIndexPartitionsSource, QueryVolatilePartitionsSource, QueryVolatilePartitionsIdsSource, IndexPartsSource, ImlQuadKeysSource, ImlFeatureIdsSource.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ContinuousSourceUtils.AvailabilityHelper	Thread-safe availability notifier for bridging push (background thread) to pull (pollNext).
static final class	ContinuousSourceUtils.SingleSplitEnumerator
static final class	ContinuousSourceUtils.TimestampEnumCheckpointSerializer
static final class	ContinuousSourceUtils.TimestampSplit
static class	ContinuousSourceUtils.TimestampSplit$
static final class	ContinuousSourceUtils.TimestampSplitSerializer

Constructor Summary

Constructors

Constructor	Description
ContinuousSourceUtils()

Method Summary

Modifier and Type	Method	Description
static int	DEFAULT_BUFFER_CAPACITY()	Default capacity for the bounded element buffer in source readers.
static ArrayList<ContinuousSourceUtils.TimestampSplit>	newSingleSplitList()

Methods inherited from class java.lang.Object

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

Constructor Details

ContinuousSourceUtils

public ContinuousSourceUtils()

Method Details

DEFAULT_BUFFER_CAPACITY

public static int DEFAULT_BUFFER_CAPACITY()

Default capacity for the bounded element buffer in source readers.

newSingleSplitList

public static ArrayList<ContinuousSourceUtils.TimestampSplit> newSingleSplitList()