org.corfudb.runtime.object

Class StreamViewSMRAdapter

java.lang.Object

org.corfudb.runtime.object.StreamViewSMRAdapter

All Implemented Interfaces:

ISMRStream

Deprecated.

@Deprecated
public class StreamViewSMRAdapter
extends Object
implements ISMRStream

StreamViewSMRAdapter wraps a stream and implements the ISMRStream API over it.

This is a relatively thin wrapper. For example, an underlying stream returns from current() a LogData entry. StreamViewSMRAdapter verifies that the entry contains data (otherwise, return null), and that the payload is of type ISMRConsumable (otherwise, again return null). Since the underlying log supports multi-stream entries, it collects and returns the SMREntries related to the current stream.

Created by mwei on 3/10/17.

Constructor Summary

Constructors

Constructor and Description
StreamViewSMRAdapter(CorfuRuntime runtime, IStreamView streamView) Deprecated.

Method Summary

Modifier and Type	Method and Description
long	append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated. Append a SMREntry to the stream, returning the global address it was written at.
List<SMREntry>	current() Deprecated. Returns the list of SMREntries positioned at the current global log.
void	gc(long trimMark) Deprecated.
UUID	getID() Deprecated. Get the UUID for this stream (optional operation).
long	pos() Deprecated.
List<SMREntry>	previous() Deprecated. Returns the list of SMREntries positioned at the previous log position of this stream.
List<SMREntry>	remainingUpTo(long maxGlobal) Deprecated. Returns all entries remaining upto the specified the global address specified.
void	reset() Deprecated.
void	seek(long globalAddress) Deprecated.
Stream<SMREntry>	stream() Deprecated.
Stream<SMREntry>	streamUpTo(long maxGlobal) Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamViewSMRAdapter

public StreamViewSMRAdapter(CorfuRuntime runtime,
                            IStreamView streamView)

Deprecated.

Method Detail

gc

public void gc(long trimMark)

Deprecated.

Specified by:

gc in interface ISMRStream

remainingUpTo

public List<SMREntry> remainingUpTo(long maxGlobal)

Deprecated.

Returns all entries remaining upto the specified the global address specified.

Specified by:

remainingUpTo in interface ISMRStream

Parameters:

maxGlobal - Max Global up to which SMR Entries are required.

Returns:

Returns a list of SMR Entries upto the maxGlobal.

current

public List<SMREntry> current()

Deprecated.

Returns the list of SMREntries positioned at the current global log. It returns null of no data is null.

Specified by:

current in interface ISMRStream

Returns:

Returns the list of SMREntries positioned at the current global log.

previous

public List<SMREntry> previous()

Deprecated.

Returns the list of SMREntries positioned at the previous log position of this stream.

Specified by:

previous in interface ISMRStream

Returns:

Returns the list of SMREntries positioned at the previous log position of this stream.

pos

public long pos()

Deprecated.

Specified by:

pos in interface ISMRStream

reset

public void reset()

Deprecated.

Specified by:

reset in interface ISMRStream

seek

public void seek(long globalAddress)

Deprecated.

Specified by:

seek in interface ISMRStream

stream

public Stream<SMREntry> stream()

Deprecated.

Specified by:

stream in interface ISMRStream

streamUpTo

public Stream<SMREntry> streamUpTo(long maxGlobal)

Deprecated.

Specified by:

streamUpTo in interface ISMRStream

append

public long append(SMREntry entry,
                   Function<TokenResponse,Boolean> acquisitionCallback,
                   Function<TokenResponse,Boolean> deacquisitionCallback)

Deprecated.

Append a SMREntry to the stream, returning the global address it was written at.

Optionally, provide a method to be called when an address is acquired, and also a method to be called when an address is released (due to an unsuccessful append).

Specified by:

append in interface ISMRStream

Parameters:

entry - The SMR entry to append.

acquisitionCallback - A function to call when an address is acquired. It should return true to continue with the append.

deacquisitionCallback - A function to call when an address is released. It should return true to retry writing.

Returns:

The (global) address the object was written at.

getID

public UUID getID()

Deprecated.

Get the UUID for this stream (optional operation).

Specified by:

getID in interface ISMRStream

Returns:

The UUID for this stream.