java.lang.Object
- org.nuxeo.lib.stream.log.chronicle.ChronicleCompoundLogTailer<M>

All Implemented Interfaces:: AutoCloseable, LogTailer<M>

public class ChronicleCompoundLogTailer<M extends Externalizable>
extends Object
implements LogTailer<M>

A compound tailer to handle multiple partitions.

Since:: 9.3

Field Summary

Fields
Modifier and Type	Field	Description
`protected boolean`	`closed`
`protected Codec<M>`	`codec`
`protected long`	`counter`
`protected Name`	`group`
`protected List<LogPartition>`	`logPartitions`
`protected int`	`size`
`protected List<ChronicleLogTailer<M>>`	`tailers`

Constructor Summary

Constructors
Constructor Description

ChronicleCompoundLogTailer(Collection<ChronicleLogTailer<M>> tailers, Name group)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Collection<LogPartition>`	`assignments()`	Returns the list of Log name, partitions tuples currently assigned to this tailer.
`void`	`close()`
`boolean`	`closed()`	Returns `true` if the tailer has been closed.
`void`	`commit()`	Commit current positions for all partitions (last message offset returned by read).
`LogOffset`	`commit(LogPartition partition)`	Commit current position for the partition.
`Codec<M>`	`getCodec()`	Returns the codec used to read the records.
`Name`	`group()`	Returns the consumer group.
`LogOffset`	`offsetForTimestamp(LogPartition partition, long timestamp)`	Look up the offset for the given partition by timestamp.
`protected LogRecord<M>`	`read()`
`LogRecord<M>`	`read(Duration timeout)`	Read a message from assigned partitions within the timeout.
`void`	`reset()`	Reset all committed positions for this group, next read will be done from beginning.
`void`	`reset(LogPartition partition)`	Reset the committed position for this group on this partition, next read for this partition will be done from the beginning.
`void`	`seek(LogOffset offset)`	Set the current position for a single partition.
`void`	`toEnd()`	Set the current positions to the end of all partitions.
`void`	`toLastCommitted()`	Set the current positions to previously committed positions.
`void`	`toStart()`	Set the current positions to the beginning of all partitions.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - tailers
```
protected final List<ChronicleLogTailer<M extends Externalizable>> tailers
```
  - group
```
protected final Name group
```
  - size
```
protected final int size
```
  - logPartitions
```
protected final List<LogPartition> logPartitions
```
  - codec
```
protected final Codec<M extends Externalizable> codec
```
  - closed
```
protected boolean closed
```
  - counter
```
protected long counter
```
- Constructor Detail
  - ChronicleCompoundLogTailer
```
public ChronicleCompoundLogTailer(Collection<ChronicleLogTailer<M>> tailers,
                                  Name group)
```
- Method Detail
  - read
```
public LogRecord<M> read(Duration timeout)
                  throws InterruptedException
```
    Description copied from interface: LogTailer
    
    Read a message from assigned partitions within the timeout.
    
    Specified by:
    
    read in interface LogTailer<M extends Externalizable>
    
    Returns:
    
    null if there is no message in the queue after the timeout.
    
    Throws:
    
    InterruptedException
  - read
```
protected LogRecord<M> read()
```
  - commit
```
public LogOffset commit(LogPartition partition)
```
    Description copied from interface: LogTailer
    
    Commit current position for the partition.
    
    Specified by:
    
    commit in interface LogTailer<M extends Externalizable>
    
    Returns:
    
    the committed offset, can return null if there was no previous read done on this partition.
  - commit
```
public void commit()
```
    Description copied from interface: LogTailer
    
    Commit current positions for all partitions (last message offset returned by read).
    
    Specified by:
    
    commit in interface LogTailer<M extends Externalizable>
  - toEnd
```
public void toEnd()
```
    Description copied from interface: LogTailer
    
    Set the current positions to the end of all partitions.
    
    Specified by:
    
    toEnd in interface LogTailer<M extends Externalizable>
  - toStart
```
public void toStart()
```
    Description copied from interface: LogTailer
    
    Set the current positions to the beginning of all partitions.
    
    Specified by:
    
    toStart in interface LogTailer<M extends Externalizable>
  - toLastCommitted
```
public void toLastCommitted()
```
    Description copied from interface: LogTailer
    
    Set the current positions to previously committed positions.
    
    Specified by:
    
    toLastCommitted in interface LogTailer<M extends Externalizable>
  - assignments
```
public Collection<LogPartition> assignments()
```
    Description copied from interface: LogTailer
    
    Returns the list of Log name, partitions tuples currently assigned to this tailer. Assignments can change only if the tailer has been created using LogManager.subscribe(org.nuxeo.lib.stream.log.Name, java.util.Collection<org.nuxeo.lib.stream.log.Name>, org.nuxeo.lib.stream.log.RebalanceListener, org.nuxeo.lib.stream.codec.Codec<M>).
    
    Specified by:
    
    assignments in interface LogTailer<M extends Externalizable>
  - group
```
public Name group()
```
    Description copied from interface: LogTailer
    
    Returns the consumer group.
    
    Specified by:
    
    group in interface LogTailer<M extends Externalizable>
  - closed
```
public boolean closed()
```
    Description copied from interface: LogTailer
    
    Returns true if the tailer has been closed.
    
    Specified by:
    
    closed in interface LogTailer<M extends Externalizable>
  - getCodec
```
public Codec<M> getCodec()
```
    Description copied from interface: LogTailer
    
    Returns the codec used to read the records. A null codec is the default legacy encoding.
    
    Specified by:
    
    getCodec in interface LogTailer<M extends Externalizable>
  - seek
```
public void seek(LogOffset offset)
```
    Description copied from interface: LogTailer
    
    Set the current position for a single partition. Do not change other partitions positions.
    
    Specified by:
    
    seek in interface LogTailer<M extends Externalizable>
  - offsetForTimestamp
```
public LogOffset offsetForTimestamp(LogPartition partition,
                                    long timestamp)
```
    Description copied from interface: LogTailer
    
    Look up the offset for the given partition by timestamp. The position is the earliest offset whose timestamp is greater than or equal to the given timestamp.
    The timestamp used depends on the implementation, for Kafka this is the LogAppendTime. Returns null if no record offset is found with an appropriate timestamp.
    
    Specified by:
    
    offsetForTimestamp in interface LogTailer<M extends Externalizable>
  - reset
```
public void reset()
```
    Description copied from interface: LogTailer
    
    Reset all committed positions for this group, next read will be done from beginning.
    
    Specified by:
    
    reset in interface LogTailer<M extends Externalizable>
  - reset
```
public void reset(LogPartition partition)
```
    Description copied from interface: LogTailer
    
    Reset the committed position for this group on this partition, next read for this partition will be done from the beginning.
    
    Specified by:
    
    reset in interface LogTailer<M extends Externalizable>
  - close
```
public void close()
```
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface LogTailer<M extends Externalizable>

Class ChronicleCompoundLogTailer<M extends Externalizable>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

tailers

group

size

logPartitions

codec

closed

counter

Constructor Detail

ChronicleCompoundLogTailer

Method Detail

read

read

commit

commit

toEnd

toStart

toLastCommitted

assignments

group

closed

getCodec

seek

offsetForTimestamp

reset

reset

close