public class Record extends Object implements Externalizable
Modifier and Type | Class and Description |
---|---|
static class |
Record.Flag |
Modifier and Type | Field and Description |
---|---|
byte[] |
data
Deprecated.
10.2 use
getData() or setData(byte[]) instead |
protected static EnumSet<Record.Flag> |
DEFAULT_FLAG |
EnumSet<Record.Flag> |
flags
Deprecated.
10.2 use
getFlags() or setFlags(EnumSet) instead |
protected byte |
flagsAsByte |
String |
key
Deprecated.
10.2 use
getKey() or setKey(String) instead |
protected static byte[] |
NO_DATA |
long |
watermark
Deprecated.
10.2 use
getWatermark() or setWatermark(long) instead |
Constructor and Description |
---|
Record() |
Record(String key,
byte[] data)
Creates a record using current watermark corresponding to the current time, with a default flag
|
Record(String key,
byte[] data,
long watermark)
Creates a record using a default flag
|
Record(String key,
byte[] data,
long watermark,
EnumSet<Record.Flag> flags) |
Modifier and Type | Method and Description |
---|---|
protected EnumSet<Record.Flag> |
decodeFlags(short encoded) |
protected short |
encodeFlags(EnumSet<Record.Flag> enumSet) |
boolean |
equals(Object o) |
byte[] |
getData() |
EnumSet<Record.Flag> |
getFlags() |
String |
getKey() |
long |
getWatermark() |
int |
hashCode() |
static Record |
of(String key,
byte[] data)
Creates a record using current timestamp and default flag
|
void |
readExternal(ObjectInput in) |
void |
setData(byte[] data) |
void |
setFlags(EnumSet<Record.Flag> flags) |
void |
setKey(String key) |
void |
setWatermark(long watermark) |
String |
toString() |
void |
writeExternal(ObjectOutput out) |
protected static final EnumSet<Record.Flag> DEFAULT_FLAG
protected static final byte[] NO_DATA
@Deprecated public long watermark
getWatermark()
or setWatermark(long)
instead@Deprecated public String key
getKey()
or setKey(String)
instead@Deprecated public byte[] data
getData()
or setData(byte[])
instead@Deprecated public transient EnumSet<Record.Flag> flags
getFlags()
or setFlags(EnumSet)
insteadprotected byte flagsAsByte
public Record()
public Record(String key, byte[] data)
public Record(String key, byte[] data, long watermark, EnumSet<Record.Flag> flags)
public static Record of(String key, byte[] data)
public long getWatermark()
public void setWatermark(long watermark)
public EnumSet<Record.Flag> getFlags()
public void setFlags(EnumSet<Record.Flag> flags)
public byte[] getData()
public void setData(byte[] data)
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
protected short encodeFlags(EnumSet<Record.Flag> enumSet)
protected EnumSet<Record.Flag> decodeFlags(short encoded)
Copyright © 2018 Nuxeo. All rights reserved.