Uses of Class
org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord.Builder

Packages that use IngressRecord.Builder

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

Uses of IngressRecord.Builder in org.apache.flink.statefun.sdk.kinesis.ingress

Methods in org.apache.flink.statefun.sdk.kinesis.ingress that return IngressRecord.Builder

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