public class WrappedExcerpt extends net.openhft.lang.io.WrappedBytes implements ExcerptTailer, ExcerptAppender, Excerpt, MappingProvider<WrappedExcerpt>
Modifier and Type | Field and Description |
---|---|
protected ExcerptAppender |
wrappedAppender |
protected ExcerptCommon |
wrappedCommon |
protected Excerpt |
wrappedExcerpt |
protected ExcerptTailer |
wrappedTailer |
Constructor and Description |
---|
WrappedExcerpt(ExcerptCommon excerptCommon) |
Modifier and Type | Method and Description |
---|---|
void |
addPaddedEntry()
Add a padded entry to keep the index in sync with a master source.
|
Chronicle |
chronicle() |
long |
findMatch(ExcerptComparator comparator)
Find any entry which return a match i.e.
|
void |
findRange(long[] startEnd,
ExcerptComparator comparator)
Find entries which return a match.
|
long |
index() |
boolean |
index(long index)
Randomly select an Excerpt.
|
long |
lastWrittenIndex() |
boolean |
nextIndex()
Wind to the next entry, no matter how many padded index entries you need to skip.
|
long |
nextSetBit(long l) |
boolean |
nextSynchronous()
The default value is ChronicleConfig.synchronousMode()
|
void |
nextSynchronous(boolean nextSynchronous) |
boolean |
read8bitText(StringBuilder builder) |
protected void |
setExcerpt(ExcerptCommon excerptCommon) |
void |
startExcerpt()
Start an excerpt with the default message capacity of 128K (can be configured)
This can waste up to 0.1% of disk space, unless you have sparse file support like Linux,
when you will waste far less.
|
void |
startExcerpt(long capacity)
Ensure there is enough capacity for a new entry of up to the size given.
|
Excerpt |
toEnd()
Wind to the end.
|
Excerpt |
toStart()
Replay from the start.
|
boolean |
wasPadding()
Not for public use.
|
MappingFunction |
withMapping() |
WrappedExcerpt |
withMapping(MappingFunction mapping) |
void |
write8bitText(CharSequence sequence) |
void |
writeEnum(long l,
int i,
Object o) |
addAndGetInt, addAtomicDouble, addAtomicFloat, addAtomicInt, addAtomicLong, addByte, addDouble, addFloat, addInt, addLong, address, addShort, addUnsignedByte, addUnsignedInt, addUnsignedShort, alignPositionAddr, append, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillis, asString, asString, available, busyLockInt, busyLockLong, byteOrder, bytes, bytes, capacity, charAt, checkEndOfBuffer, clear, clearThreadAssociation, close, compare, compareAndSwapDouble, compareAndSwapInt, compareAndSwapLong, file, finish, flip, flush, free, getAndAdd, inputStream, isFinished, length, limit, limit, load, objectSerializer, outputStream, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, position, position, read, read, read, read, read, readBoolean, readBoolean, readByte, readByte, readChar, readChar, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readDouble, readDouble, readEnum, readEnum, readFloat, readFloat, readFully, readFully, readFully, readFully, readFully, readIncompleteLong, readInstance, readInt, readInt, readInt24, readInt24, readInt48, readInt48, readLine, readList, readLong, readLong, readMap, readMarshallable, readObject, readObject, readObject, readShort, readShort, readStopBit, readUnsignedByte, readUnsignedByte, readUnsignedByteOrThrow, readUnsignedInt, readUnsignedInt, readUnsignedShort, readUnsignedShort, readUTF, readUTFΔ, readUTFΔ, readUTFΔ, readVolatileDouble, readVolatileFloat, readVolatileInt, readVolatileInt, readVolatileLong, readVolatileLong, refCount, release, remaining, reserve, resetLockInt, resetLockLong, selfTerminating, selfTerminating, size, skip, skipBytes, skipTo, slice, slice, sliceAsByteBuffer, startsWith, stepBackAndSkipTo, subSequence, threadIdForLockInt, threadIdForLockLong, toDebugString, toDebugString, toHexString, toString, tryLockInt, tryLockLong, tryLockNanosInt, tryLockNanosLong, tryRWReadLock, tryRWWriteLock, unlockInt, unlockLong, unlockRWReadLock, unlockRWWriteLock, write, write, write, write, write, write, write, write, write, write, write, write, writeBoolean, writeBoolean, writeByte, writeByte, writeBytes, writeChar, writeChar, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeDouble, writeDouble, writeEnum, writeFloat, writeFloat, writeInstance, writeInt, writeInt, writeInt24, writeInt24, writeInt48, writeInt48, writeList, writeLong, writeLong, writeMap, writeMarshallable, writeObject, writeObject, writeOrderedDouble, writeOrderedFloat, writeOrderedInt, writeOrderedInt, writeOrderedLong, writeOrderedLong, writeShort, writeShort, writeStopBit, writeUnsignedByte, writeUnsignedByte, writeUnsignedInt, writeUnsignedInt, writeUnsignedShort, writeUnsignedShort, writeUTF, writeUTFΔ, writeUTFΔ, zeroOut, zeroOut, zeroOut
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
finish, size
available, compare, read, read, read, read, read, readBoolean, readBoolean, readByte, readByte, readChar, readChar, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readDouble, readDouble, readEnum, readEnum, readFloat, readFloat, readFully, readFully, readFully, readFully, readFully, readIncompleteLong, readInstance, readInt, readInt, readInt24, readInt24, readInt48, readInt48, readLine, readList, readLong, readLong, readMap, readObject, readObject, readObject, readShort, readShort, readStopBit, readUnsignedByte, readUnsignedByte, readUnsignedInt, readUnsignedInt, readUnsignedShort, readUnsignedShort, readUTF, readUTFΔ, readUTFΔ, readUTFΔ, readVolatileDouble, readVolatileFloat, readVolatileInt, readVolatileInt, readVolatileLong, readVolatileLong, skip, skipBytes, startsWith
addAndGetInt, close, compareAndSwapDouble, compareAndSwapInt, compareAndSwapLong, flush, getAndAdd, write, write, write, write, write, write, write, write, write, write, write, write, writeBoolean, writeBoolean, writeByte, writeByte, writeBytes, writeChar, writeChar, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeDouble, writeDouble, writeEnum, writeFloat, writeFloat, writeInstance, writeInt, writeInt, writeInt24, writeInt24, writeInt48, writeInt48, writeList, writeLong, writeLong, writeMap, writeObject, writeObject, writeOrderedDouble, writeOrderedFloat, writeOrderedInt, writeOrderedInt, writeOrderedLong, writeOrderedLong, writeShort, writeShort, writeStopBit, writeUnsignedByte, writeUnsignedByte, writeUnsignedInt, writeUnsignedInt, writeUnsignedShort, writeUnsignedShort, writeUTF, writeUTFΔ, writeUTFΔ, zeroOut, zeroOut, zeroOut
addAtomicDouble, addAtomicFloat, addAtomicInt, addAtomicLong, addByte, addDouble, addFloat, addInt, addLong, addShort, addUnsignedByte, addUnsignedInt, addUnsignedShort, busyLockInt, busyLockLong, resetLockInt, resetLockLong, threadIdForLockInt, threadIdForLockLong, tryLockInt, tryLockLong, tryLockNanosInt, tryLockNanosLong, tryRWReadLock, tryRWWriteLock, unlockInt, unlockLong, unlockRWReadLock, unlockRWWriteLock
address, bytes, bytes, file, free, objectSerializer
append, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillis
asString, asString, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, readUnsignedByteOrThrow, selfTerminating, selfTerminating, skipTo, stepBackAndSkipTo
alignPositionAddr, byteOrder, capacity, checkEndOfBuffer, clear, flip, inputStream, isFinished, limit, limit, load, objectSerializer, outputStream, position, position, remaining, slice, slice, sliceAsByteBuffer, toDebugString, toDebugString, toHexString, toString
charAt, chars, codePoints, length, subSequence, toString
protected ExcerptTailer wrappedTailer
protected ExcerptAppender wrappedAppender
protected ExcerptCommon wrappedCommon
protected Excerpt wrappedExcerpt
public WrappedExcerpt(ExcerptCommon excerptCommon)
public WrappedExcerpt withMapping(MappingFunction mapping)
withMapping
in interface MappingProvider<WrappedExcerpt>
public MappingFunction withMapping()
withMapping
in interface MappingProvider<WrappedExcerpt>
protected void setExcerpt(ExcerptCommon excerptCommon)
public Chronicle chronicle()
chronicle
in interface ExcerptCommon
public boolean nextIndex()
ExcerptTailer
nextIndex
in interface ExcerptTailer
public boolean index(long index) throws IndexOutOfBoundsException
ExcerptTailer
index
in interface Excerpt
index
in interface ExcerptTailer
index
- index to look upIndexOutOfBoundsException
public void startExcerpt()
ExcerptAppender
startExcerpt
in interface ExcerptAppender
public void startExcerpt(long capacity)
ExcerptAppender
startExcerpt
in interface ExcerptAppender
capacity
- to allow for, but not exceed.public void addPaddedEntry()
ExcerptAppender
addPaddedEntry
in interface ExcerptAppender
public boolean nextSynchronous()
ExcerptAppender
nextSynchronous
in interface ExcerptAppender
public void nextSynchronous(boolean nextSynchronous)
nextSynchronous
in interface ExcerptAppender
nextSynchronous
- make the next write synchronous or not.public long index()
index
in interface ExcerptCommon
public long lastWrittenIndex()
lastWrittenIndex
in interface ExcerptAppender
@NotNull public Excerpt toStart()
ExcerptTailer
toStart
in interface Excerpt
toStart
in interface ExcerptTailer
@NotNull public Excerpt toEnd()
ExcerptTailer
toEnd
in interface Excerpt
toEnd
in interface ExcerptTailer
public boolean wasPadding()
ExcerptCommon
wasPadding
in interface ExcerptCommon
public long findMatch(@NotNull ExcerptComparator comparator)
Excerpt
public void findRange(@NotNull long[] startEnd, @NotNull ExcerptComparator comparator)
Excerpt
public boolean read8bitText(@NotNull StringBuilder builder) throws StreamCorruptedException
read8bitText
in interface net.openhft.lang.io.RandomDataInput
read8bitText
in class net.openhft.lang.io.WrappedBytes
StreamCorruptedException
public long nextSetBit(long l)
nextSetBit
in interface net.openhft.lang.io.RandomDataInput
public void write8bitText(CharSequence sequence)
write8bitText
in interface net.openhft.lang.io.RandomDataOutput
write8bitText
in class net.openhft.lang.io.WrappedBytes
public void writeEnum(long l, int i, Object o)
writeEnum
in interface net.openhft.lang.io.RandomDataOutput
writeEnum
in class net.openhft.lang.io.WrappedBytes
Copyright © 2017. All rights reserved.