Package cz.o2.proxima.core.transaction

Class State

java.lang.Object

cz.o2.proxima.core.transaction.State

All Implemented Interfaces:

java.io.Serializable

@Internal
public class State
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	State.Flags

Constructor Summary

Constructors

Constructor	Description
State()

Method Summary

Modifier and Type	Method	Description
State	aborted()	Move this state to State.Flags.ABORTED.
State	committed(java.util.Collection<StreamElement> outputs)	Create new State that is marked as State.Flags.COMMITTED.
static State	empty()
boolean	isFinal()
static State	open(long sequentialId, long stamp, java.util.Collection<KeyAttribute> openAttributes)
State	update(java.util.Collection<KeyAttribute> additionalAttributes)

Methods inherited from class java.lang.Object

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

Constructor Detail

State

public State()

Method Detail

open

public static State open(long sequentialId,
                         long stamp,
                         java.util.Collection<KeyAttribute> openAttributes)

empty

public static State empty()

committed

public State committed(java.util.Collection<StreamElement> outputs)

Create new State that is marked as State.Flags.COMMITTED.

Parameters:

outputs - the attributes that are to be committed

Returns:

new State marked as State.Flags.COMMITTED.

update

public State update(java.util.Collection<KeyAttribute> additionalAttributes)

aborted

public State aborted()

Move this state to State.Flags.ABORTED.

Returns:

new State marked as State.Flags.ABORTED.

isFinal

public boolean isFinal()