public class SinglePartitionWithoutOffsetsSystemAdmin extends java.lang.Object implements SystemAdmin
Constructor and Description |
---|
SinglePartitionWithoutOffsetsSystemAdmin() |
Modifier and Type | Method and Description |
---|---|
void |
createChangelogStream(java.lang.String streamName,
int numOfPartitions)
An API to create a change log stream
|
void |
createCoordinatorStream(java.lang.String streamName)
Create a stream for the job coordinator.
|
java.util.Map<SystemStreamPartition,java.lang.String> |
getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Fetches the offsets for the messages immediately after the supplied offsets
for a group of SystemStreamPartitions.
|
java.util.Map<java.lang.String,SystemStreamMetadata> |
getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames)
Fetch metadata from a system for a set of streams.
|
java.lang.Integer |
offsetComparator(java.lang.String offset1,
java.lang.String offset2)
Compare the two offsets.
|
void |
validateChangelogStream(java.lang.String streamName,
int numOfPartitions)
Validates change log stream
|
public SinglePartitionWithoutOffsetsSystemAdmin()
public java.util.Map<java.lang.String,SystemStreamMetadata> getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames)
SystemAdmin
getSystemStreamMetadata
in interface SystemAdmin
streamNames
- The streams to to fetch metadata for.public void createChangelogStream(java.lang.String streamName, int numOfPartitions)
SystemAdmin
createChangelogStream
in interface SystemAdmin
streamName
- The name of the stream to be created in the underlying streamnumOfPartitions
- The number of partitions in the changelog streampublic void validateChangelogStream(java.lang.String streamName, int numOfPartitions)
SystemAdmin
validateChangelogStream
in interface SystemAdmin
streamName
- The name of the stream to be created in the underlying streamnumOfPartitions
- The number of partitions in the changelog streampublic java.util.Map<SystemStreamPartition,java.lang.String> getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
SystemAdmin
getOffsetsAfter
in interface SystemAdmin
offsets
- Map from SystemStreamPartition to current offsets.public void createCoordinatorStream(java.lang.String streamName)
SystemAdmin
createCoordinatorStream
in interface SystemAdmin
streamName
- The name of the coordinator stream to create.public java.lang.Integer offsetComparator(java.lang.String offset1, java.lang.String offset2)
SystemAdmin
offsetComparator
in interface SystemAdmin
offset1
- First offset for comparison.offset2
- Second offset for comparison.