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 |
---|---|
String |
dataOverview(int maxLength) |
protected EnumSet<Record.Flag> |
decodeFlags(byte 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 String dataOverview(int maxLength)
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(byte encoded)
Copyright © 2019 Nuxeo. All rights reserved.