Constructor and Description |
---|
RecordBatch(List<com.amazonaws.services.kinesis.model.Record> records,
StreamShardHandle subscribedShard,
Long millisBehindLatest) |
Modifier and Type | Method and Description |
---|---|
int |
getAggregatedRecordSize() |
long |
getAverageRecordSizeBytes() |
List<com.amazonaws.services.kinesis.clientlibrary.types.UserRecord> |
getDeaggregatedRecords() |
int |
getDeaggregatedRecordSize() |
Long |
getMillisBehindLatest() |
long |
getTotalSizeInBytes() |
public RecordBatch(List<com.amazonaws.services.kinesis.model.Record> records, StreamShardHandle subscribedShard, @Nullable Long millisBehindLatest)
public int getAggregatedRecordSize()
public int getDeaggregatedRecordSize()
public List<com.amazonaws.services.kinesis.clientlibrary.types.UserRecord> getDeaggregatedRecords()
public long getTotalSizeInBytes()
public long getAverageRecordSizeBytes()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.