Class DefaultRecordBatch
public class DefaultRecordBatch : MutableRecordBatch, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEnumerableExtension, IEnumerable<Record>, IEnumerable, IAsyncEnumerable<Record>, IIterable<Record>, IMutableRecordBatch, IRecordBatch- Inheritance
-
JVMBridgeBaseDefaultRecordBatch
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinitionIEnumerableExtension
- Inherited Members
-
JVMBridgeBaseEnumerable<Iterable<Record>, Record>.GetEnumerator()JVMBridgeBaseEnumerable<Iterable<Record>>.GetEnumerator()JVMBridgeBase<Iterable<Record>>.IsAssignableFrom(IJavaType)JVMBridgeBase<Iterable<Record>>.IsAssignableFrom<T>()JVMBridgeBase<Iterable<Record>>.Execute<T>(params T[])JVMBridgeBase<Iterable<Record>>.DynBridgeClazzJVMBridgeBase<Iterable<Record>>.BridgeClazzJVMBridgeBase.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.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
DefaultRecordBatch()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public DefaultRecordBatch()DefaultRecordBatch(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 DefaultRecordBatch(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
CRC_OFFSET
public static int CRC_OFFSET { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
LAST_OFFSET_DELTA_OFFSET
public static int LAST_OFFSET_DELTA_OFFSET { get; }Property Value
RECORDS_COUNT_OFFSET
public static int RECORDS_COUNT_OFFSET { get; }Property Value
RECORD_BATCH_OVERHEAD
public static int RECORD_BATCH_OVERHEAD { get; }Property Value
Methods
BaseTimestamp()
public long BaseTimestamp()Returns
DecrementSequence(int, int)
public static int DecrementSequence(int arg0, int arg1)Parameters
Returns
IncrementSequence(int, int)
public static int IncrementSequence(int arg0, int arg1)Parameters
Returns
RecordInputStream(BufferSupplier)
public InputStream RecordInputStream(BufferSupplier arg0)Parameters
Returns
SetLastOffset(long)
public void SetLastOffset(long arg0)Parameters
SetMaxTimestamp(TimestampType, long)
public void SetMaxTimestamp(TimestampType arg0, long arg1)Parameters
arg0TimestampTypearg1long
SetPartitionLeaderEpoch(int)
public void SetPartitionLeaderEpoch(int arg0)Parameters
SizeInBytes(Iterable<SimpleRecord>)
public static int SizeInBytes(Iterable<SimpleRecord> arg0)Parameters
arg0Iterable<SimpleRecord>
Returns
SizeInBytes(long, Iterable<Record>)
public static int SizeInBytes(long arg0, Iterable<Record> arg1)Parameters
Returns
SkipKeyValueIterator(BufferSupplier)
public CloseableIterator<Record> SkipKeyValueIterator(BufferSupplier arg0)Parameters
Returns
WriteEmptyHeader(ByteBuffer, byte, long, short, int, long, long, int, TimestampType, long, bool, bool)
public static void WriteEmptyHeader(ByteBuffer arg0, byte arg1, long arg2, short arg3, int arg4, long arg5, long arg6, int arg7, TimestampType arg8, long arg9, bool arg10, bool arg11)Parameters
arg0ByteBufferarg1bytearg2longarg3shortarg4intarg5longarg6longarg7intarg8TimestampTypearg9longarg10boolarg11bool
WriteHeader(ByteBuffer, long, int, int, byte, CompressionType, TimestampType, long, long, long, short, int, bool, bool, bool, int, int)
public static void WriteHeader(ByteBuffer arg0, long arg1, int arg2, int arg3, byte arg4, CompressionType arg5, TimestampType arg6, long arg7, long arg8, long arg9, short arg10, int arg11, bool arg12, bool arg13, bool arg14, int arg15, int arg16)Parameters
arg0ByteBufferarg1longarg2intarg3intarg4bytearg5CompressionTypearg6TimestampTypearg7longarg8longarg9longarg10shortarg11intarg12boolarg13boolarg14boolarg15intarg16int
WriteTo(ByteBufferOutputStream)
public void WriteTo(ByteBufferOutputStream arg0)