Table of Contents

Class LegacyRecord

Namespace
Org.Apache.Kafka.Common.Record
Assembly
MASES.KNet.dll
public class LegacyRecord : JVMBridgeBase<LegacyRecord>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<LegacyRecord>
LegacyRecord
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<LegacyRecord>.IsAssignableFrom(IJavaType)
JVMBridgeBase<LegacyRecord>.IsAssignableFrom<T>()
JVMBridgeBase<LegacyRecord>.Execute<T>(params T[])
JVMBridgeBase<LegacyRecord>.DynBridgeClazz
JVMBridgeBase<LegacyRecord>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

LegacyRecord()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public LegacyRecord()

LegacyRecord(ByteBuffer)

public LegacyRecord(ByteBuffer arg0)

Parameters

arg0 ByteBuffer

ByteBuffer

LegacyRecord(ByteBuffer, Long, TimestampType)

public LegacyRecord(ByteBuffer arg0, Long arg1, TimestampType arg2)

Parameters

arg0 ByteBuffer

ByteBuffer

arg1 Long

Long

arg2 TimestampType

TimestampType

LegacyRecord(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public LegacyRecord(params object[] args)

Parameters

args object[]

Properties

ATTRIBUTES_LENGTH

public static int ATTRIBUTES_LENGTH { get; }

Property Value

int

ATTRIBUTES_OFFSET

public static int ATTRIBUTES_OFFSET { get; }

Property Value

int

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

CRC_LENGTH

public static int CRC_LENGTH { get; }

Property Value

int

CRC_OFFSET

public static int CRC_OFFSET { get; }

Property Value

int

HEADER_SIZE_V0

public static int HEADER_SIZE_V0 { get; }

Property Value

int

HEADER_SIZE_V1

public static int HEADER_SIZE_V1 { get; }

Property Value

int

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

KEY_OFFSET_V0

public static int KEY_OFFSET_V0 { get; }

Property Value

int

KEY_OFFSET_V1

public static int KEY_OFFSET_V1 { get; }

Property Value

int

KEY_SIZE_LENGTH

public static int KEY_SIZE_LENGTH { get; }

Property Value

int

KEY_SIZE_OFFSET_V0

public static int KEY_SIZE_OFFSET_V0 { get; }

Property Value

int

KEY_SIZE_OFFSET_V1

public static int KEY_SIZE_OFFSET_V1 { get; }

Property Value

int

MAGIC_LENGTH

public static int MAGIC_LENGTH { get; }

Property Value

int

MAGIC_OFFSET

public static int MAGIC_OFFSET { get; }

Property Value

int

NO_TIMESTAMP

public static long NO_TIMESTAMP { get; }

Property Value

long

RECORD_OVERHEAD_V0

public static int RECORD_OVERHEAD_V0 { get; }

Property Value

int

RECORD_OVERHEAD_V1

public static int RECORD_OVERHEAD_V1 { get; }

Property Value

int

TIMESTAMP_LENGTH

public static int TIMESTAMP_LENGTH { get; }

Property Value

int

TIMESTAMP_OFFSET

public static int TIMESTAMP_OFFSET { get; }

Property Value

int

VALUE_SIZE_LENGTH

public static int VALUE_SIZE_LENGTH { get; }

Property Value

int

Methods

Attributes()

public byte Attributes()

Returns

byte

byte

Buffer()

public ByteBuffer Buffer()

Returns

ByteBuffer

ByteBuffer

Checksum()

public long Checksum()

Returns

long

long

CompressionType()

public CompressionType CompressionType()

Returns

CompressionType

CompressionType

ComputeAttributes(byte, CompressionType, TimestampType)

public static byte ComputeAttributes(byte arg0, CompressionType arg1, TimestampType arg2)

Parameters

arg0 byte

byte

arg1 CompressionType

CompressionType

arg2 TimestampType

TimestampType

Returns

byte

byte

ComputeChecksum()

public long ComputeChecksum()

Returns

long

long

ComputeChecksum(byte, byte, long, byte[], byte[])

public static long ComputeChecksum(byte arg0, byte arg1, long arg2, byte[] arg3, byte[] arg4)

Parameters

arg0 byte

byte

arg1 byte

byte

arg2 long

long

arg3 byte[]

byte

arg4 byte[]

byte

Returns

long

long

Create(byte, long, byte[], byte[])

public static LegacyRecord Create(byte arg0, long arg1, byte[] arg2, byte[] arg3)

Parameters

arg0 byte

byte

arg1 long

long

arg2 byte[]

byte

arg3 byte[]

byte

Returns

LegacyRecord

LegacyRecord

Create(byte, long, byte[], byte[], CompressionType, TimestampType)

public static LegacyRecord Create(byte arg0, long arg1, byte[] arg2, byte[] arg3, CompressionType arg4, TimestampType arg5)

Parameters

arg0 byte

byte

arg1 long

long

arg2 byte[]

byte

arg3 byte[]

byte

arg4 CompressionType

CompressionType

arg5 TimestampType

TimestampType

Returns

LegacyRecord

LegacyRecord

EnsureValid()

public void EnsureValid()

HasKey()

public bool HasKey()

Returns

bool

bool

HasNullValue()

public bool HasNullValue()

Returns

bool

bool

IsValid()

public bool IsValid()

Returns

bool

bool

Key()

public ByteBuffer Key()

Returns

ByteBuffer

ByteBuffer

KeySize()

public int KeySize()

Returns

int

int

Magic()

public byte Magic()

Returns

byte

byte

RecordSize(byte, int, int)

public static int RecordSize(byte arg0, int arg1, int arg2)

Parameters

arg0 byte

byte

arg1 int

int

arg2 int

int

Returns

int

int

SizeInBytes()

public int SizeInBytes()

Returns

int

int

Timestamp()

public long Timestamp()

Returns

long

long

TimestampType()

public TimestampType TimestampType()

Returns

TimestampType

TimestampType

TimestampType(byte, TimestampType, byte)

public static TimestampType TimestampType(byte arg0, TimestampType arg1, byte arg2)

Parameters

arg0 byte

byte

arg1 TimestampType

TimestampType

arg2 byte

byte

Returns

TimestampType

TimestampType

Value()

public ByteBuffer Value()

Returns

ByteBuffer

ByteBuffer

ValueSize()

public int ValueSize()

Returns

int

int

Write(DataOutputStream, byte, long, ByteBuffer, ByteBuffer, CompressionType, TimestampType)

public static long Write(DataOutputStream arg0, byte arg1, long arg2, ByteBuffer arg3, ByteBuffer arg4, CompressionType arg5, TimestampType arg6)

Parameters

arg0 DataOutputStream

DataOutputStream

arg1 byte

byte

arg2 long

long

arg3 ByteBuffer

ByteBuffer

arg4 ByteBuffer

ByteBuffer

arg5 CompressionType

CompressionType

arg6 TimestampType

TimestampType

Returns

long

long

Exceptions

IOException

Write(DataOutputStream, byte, long, byte, long, byte[], byte[])

public static void Write(DataOutputStream arg0, byte arg1, long arg2, byte arg3, long arg4, byte[] arg5, byte[] arg6)

Parameters

arg0 DataOutputStream

DataOutputStream

arg1 byte

byte

arg2 long

long

arg3 byte

byte

arg4 long

long

arg5 byte[]

byte

arg6 byte[]

byte

Exceptions

IOException

Write(DataOutputStream, byte, long, byte[], byte[], CompressionType, TimestampType)

public static long Write(DataOutputStream arg0, byte arg1, long arg2, byte[] arg3, byte[] arg4, CompressionType arg5, TimestampType arg6)

Parameters

arg0 DataOutputStream

DataOutputStream

arg1 byte

byte

arg2 long

long

arg3 byte[]

byte

arg4 byte[]

byte

arg5 CompressionType

CompressionType

arg6 TimestampType

TimestampType

Returns

long

long

Exceptions

IOException

WriteCompressedRecordHeader(ByteBuffer, byte, int, long, CompressionType, TimestampType)

public static void WriteCompressedRecordHeader(ByteBuffer arg0, byte arg1, int arg2, long arg3, CompressionType arg4, TimestampType arg5)

Parameters

arg0 ByteBuffer

ByteBuffer

arg1 byte

byte

arg2 int

int

arg3 long

long

arg4 CompressionType

CompressionType

arg5 TimestampType

TimestampType