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

Class SingleSplitSourceUtils

java.lang.Object

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

public class SingleSplitSourceUtils
extends Object

Shared FLIP-27 Source utilities for bounded (one-shot) sources.

These are used by QueryApiSource, QueryApiPartsSource, AdminApiSource and similar bounded sources that produce a finite set of elements from a single logical split.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SingleSplitSourceUtils.EnumCheckpointSerializer
static final class	SingleSplitSourceUtils.SingleSplitEnumerator
static final class	SingleSplitSourceUtils.Split	Trivial split carrying only a string identifier.
static class	SingleSplitSourceUtils.Split$
static final class	SingleSplitSourceUtils.SplitSerializer

Constructor Summary

Constructors

Constructor	Description
SingleSplitSourceUtils()

Method Summary

Modifier and Type	Method	Description
static ArrayList<SingleSplitSourceUtils.Split>	newSingleSplitList()

Methods inherited from class java.lang.Object

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

Constructor Details

SingleSplitSourceUtils

public SingleSplitSourceUtils()

Method Details

newSingleSplitList

public static ArrayList<SingleSplitSourceUtils.Split> newSingleSplitList()