org.apache.flink.statefun.sdk.kinesis.ingress

Class IngressRecord.Builder

java.lang.Object

org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord.Builder

Enclosing class:

IngressRecord

public static final class IngressRecord.Builder
extends java.lang.Object

Builder for IngressRecord.

Method Summary

Modifier and Type	Method and Description
IngressRecord	build()
IngressRecord.Builder	withApproximateArrivalTimestamp(long approximateArrivalTimestamp)
IngressRecord.Builder	withData(byte[] data)
IngressRecord.Builder	withPartitionKey(java.lang.String partitionKey)
IngressRecord.Builder	withSequenceNumber(java.lang.String sequenceNumber)
IngressRecord.Builder	withShardId(java.lang.String shardId)
IngressRecord.Builder	withStream(java.lang.String stream)

Methods inherited from class java.lang.Object

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

Method Detail

withData

public IngressRecord.Builder withData(byte[] data)

withStream

public IngressRecord.Builder withStream(java.lang.String stream)

withShardId

public IngressRecord.Builder withShardId(java.lang.String shardId)

withPartitionKey

public IngressRecord.Builder withPartitionKey(java.lang.String partitionKey)

withSequenceNumber

public IngressRecord.Builder withSequenceNumber(java.lang.String sequenceNumber)

withApproximateArrivalTimestamp

public IngressRecord.Builder withApproximateArrivalTimestamp(long approximateArrivalTimestamp)

build

public IngressRecord build()