public class KinesisConfig extends Object
Constructor and Description |
---|
KinesisConfig()
No args constructor for use in serialization
|
KinesisConfig(String identifier,
String kinesisStreamName,
Long batchSize,
Long batchIntervalMillis,
Long priority,
Long startSequenceNumber,
Boolean disabled) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object other) |
Long |
getBatchIntervalMillis()
The time in milliseconds between the earliest un-uploaded message and the current time.
|
Long |
getBatchSize()
The maximum size of a batch to send to Kinesis.
|
Boolean |
getDisabled()
Enable or disable this export.
|
String |
getIdentifier()
A unique identifier to identify this individual upload stream.
|
String |
getKinesisStreamName()
The name of the Kinesis data stream that this exporter should upload to.
|
Long |
getPriority()
Priority for this upload stream.
|
Long |
getStartSequenceNumber()
The sequence number of the message to use as the starting message in the export.
|
int |
hashCode() |
void |
setBatchIntervalMillis(Long batchIntervalMillis)
The time in milliseconds between the earliest un-uploaded message and the current time.
|
void |
setBatchSize(Long batchSize)
The maximum size of a batch to send to Kinesis.
|
void |
setDisabled(Boolean disabled)
Enable or disable this export.
|
void |
setIdentifier(String identifier)
A unique identifier to identify this individual upload stream.
|
void |
setKinesisStreamName(String kinesisStreamName)
The name of the Kinesis data stream that this exporter should upload to.
|
void |
setPriority(Long priority)
Priority for this upload stream.
|
void |
setStartSequenceNumber(Long startSequenceNumber)
The sequence number of the message to use as the starting message in the export.
|
String |
toString() |
KinesisConfig |
withBatchIntervalMillis(Long batchIntervalMillis) |
KinesisConfig |
withBatchSize(Long batchSize) |
KinesisConfig |
withDisabled(Boolean disabled) |
KinesisConfig |
withIdentifier(String identifier) |
KinesisConfig |
withKinesisStreamName(String kinesisStreamName) |
KinesisConfig |
withPriority(Long priority) |
KinesisConfig |
withStartSequenceNumber(Long startSequenceNumber) |
public KinesisConfig()
public KinesisConfig(String identifier, String kinesisStreamName, Long batchSize, Long batchIntervalMillis, Long priority, Long startSequenceNumber, Boolean disabled)
identifier
- startSequenceNumber
- kinesisStreamName
- disabled
- batchSize
- priority
- batchIntervalMillis
- public String getIdentifier()
public void setIdentifier(String identifier)
public KinesisConfig withIdentifier(String identifier)
public String getKinesisStreamName()
public void setKinesisStreamName(String kinesisStreamName)
public KinesisConfig withKinesisStreamName(String kinesisStreamName)
public Long getBatchSize()
public void setBatchSize(Long batchSize)
public KinesisConfig withBatchSize(Long batchSize)
public Long getBatchIntervalMillis()
public void setBatchIntervalMillis(Long batchIntervalMillis)
public KinesisConfig withBatchIntervalMillis(Long batchIntervalMillis)
public Long getPriority()
public void setPriority(Long priority)
public KinesisConfig withPriority(Long priority)
public Long getStartSequenceNumber()
public void setStartSequenceNumber(Long startSequenceNumber)
public KinesisConfig withStartSequenceNumber(Long startSequenceNumber)
public Boolean getDisabled()
public void setDisabled(Boolean disabled)
public KinesisConfig withDisabled(Boolean disabled)