Class RecordBatch
public class RecordBatch : Iterable<Record>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEnumerableExtension, IEnumerable<Record>, IEnumerable, IAsyncEnumerable<Record>, IIterable<Record>, IRecordBatch- Inheritance
-
JVMBridgeBaseRecordBatch
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinitionIEnumerableExtension
- Derived
- 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
RecordBatch()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
[Obsolete("RecordBatch class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public RecordBatch()RecordBatch(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
[Obsolete("RecordBatch class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public RecordBatch(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
CURRENT_MAGIC_VALUE
public static byte CURRENT_MAGIC_VALUE { 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
MAGIC_VALUE_V0
public static byte MAGIC_VALUE_V0 { get; }Property Value
MAGIC_VALUE_V1
public static byte MAGIC_VALUE_V1 { get; }Property Value
MAGIC_VALUE_V2
public static byte MAGIC_VALUE_V2 { get; }Property Value
NO_PARTITION_LEADER_EPOCH
public static int NO_PARTITION_LEADER_EPOCH { get; }Property Value
NO_PRODUCER_EPOCH
public static short NO_PRODUCER_EPOCH { get; }Property Value
NO_PRODUCER_ID
public static long NO_PRODUCER_ID { get; }Property Value
NO_SEQUENCE
public static int NO_SEQUENCE { get; }Property Value
NO_TIMESTAMP
public static long NO_TIMESTAMP { get; }Property Value
Methods
BaseOffset()
public long BaseOffset()Returns
BaseSequence()
public int BaseSequence()Returns
Checksum()
public long Checksum()Returns
CompressionType()
public CompressionType CompressionType()Returns
CountOrNull()
public Integer CountOrNull()Returns
DeleteHorizonMs()
public OptionalLong DeleteHorizonMs()Returns
EnsureValid()
public void EnsureValid()HasProducerId()
public bool HasProducerId()Returns
IsCompressed()
public bool IsCompressed()Returns
IsControlBatch()
public bool IsControlBatch()Returns
IsTransactional()
public bool IsTransactional()Returns
IsValid()
public bool IsValid()Returns
LastOffset()
public long LastOffset()Returns
LastSequence()
public int LastSequence()Returns
Magic()
public byte Magic()Returns
MaxTimestamp()
public long MaxTimestamp()Returns
NextOffset()
public long NextOffset()Returns
OffsetOfMaxTimestamp()
public Optional<Long> OffsetOfMaxTimestamp()Returns
PartitionLeaderEpoch()
public int PartitionLeaderEpoch()Returns
ProducerEpoch()
public short ProducerEpoch()Returns
ProducerId()
public long ProducerId()Returns
SizeInBytes()
public int SizeInBytes()Returns
StreamingIterator(BufferSupplier)
public CloseableIterator<Record> StreamingIterator(BufferSupplier arg0)Parameters
Returns
TimestampType()
public TimestampType TimestampType()Returns
WriteTo(ByteBuffer)
public void WriteTo(ByteBuffer arg0)Parameters
arg0ByteBuffer