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

Class FlinkKafkaPublisher

java.lang.Object

com.here.platform.data.client.flink.javadsl.FlinkKafkaPublisher

All Implemented Interfaces:

Serializable

public class FlinkKafkaPublisher
extends Object
implements Serializable

Use this class for manually managing publishing to a stream layer. Requires call terminate() method after multiple usage of publish(java.util.Iterator<com.here.platform.data.client.model.PendingPartition>) method.

param: hrn catalog identifier.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkKafkaPublisher(HRN hrn)

Method Summary

Modifier and Type	Method	Description
static void	apply(HRN hrn, Iterator<PendingPartition> partitions)	Publish new partitions to a stream layer.
void	publish(Iterator<PendingPartition> partitions)	Publish new partitions to a stream layer without closing publisher.
void	terminate()	Close publisher.

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkKafkaPublisher

public FlinkKafkaPublisher(HRN hrn)

Method Details

apply

public static void apply(HRN hrn,
 Iterator<PendingPartition> partitions)

Publish new partitions to a stream layer.

Parameters:

hrn - catalog identifier.

partitions - partitions to publish.

Throws:

DataClientNonRetriableException - in case of non-retriable error

DataClientRetriableException - in case of retriable error

publish

public void publish(Iterator<PendingPartition> partitions)

Publish new partitions to a stream layer without closing publisher.

Parameters:

partitions - partitions to publish.

Throws:

DataClientNonRetriableException - in case of non-retriable error

DataClientRetriableException - in case of retriable error

terminate

public void terminate()

Close publisher.